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
}