func checkSecureConnectivityToBackend()

in dp_check/dp_check.go [582:603]


func checkSecureConnectivityToBackend(address string) error {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	altsCreds := alts.NewClientCreds(alts.DefaultClientOptions())
	altsCreds.OverrideServerName(*service)
	conn, err := grpc.Dial(address, grpc.WithTransportCredentials(altsCreds))
	const errMsg = "Secure connectivity to backend addr - %v failed: %v."
	if err != nil {
		return fmt.Errorf(errMsg, address, err)
	}
	lastState := conn.GetState()
	for lastState != connectivity.Ready {
		select {
		case <-ctx.Done():
			return fmt.Errorf(errMsg, address, ctx.Err())
		default:
		}
		conn.WaitForStateChange(ctx, lastState)
		lastState = conn.GetState()
	}
	return nil
}