INNER CODE UNIT · Go

NewClient

pace/bricks · grpc/client.go:33

func NewClient(addr string) (*grpc.ClientConn, error) {
	var conn *grpc.ClientConn

	clientMetrics := grpc_prometheus.NewClientMetrics()

	opts := []grpc_retry.CallOption{
		grpc_retry.WithBackoff(grpc_retry.BackoffLinear(100 * time.Millisecond)),
		grpc_retry.WithMax(10),
	}

	conn, err := grpc.NewClient(addr,
		grpc.WithTransportCredentials(insecure.NewCredentials()),
		grpc.WithChainStreamInterceptor(
			grpc_sentry.StreamClientInterceptor(),
			grpc_retry.StreamClientInterceptor(opts...),
			func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
				start := time.Now()
				cs, err := streamer(prepareClientContext(ctx), desc, cc, method, opts...)

View source record →