Documentation
¶
Index ¶
- func GrpcChannelOptions() grpc.DialOption
- func IsBenignCloseErr(err error) bool
- func OpenTracingClientInterceptor() grpc.UnaryClientInterceptor
- func OpenTracingServerInterceptor(parentSpan opentracing.Span) grpc.UnaryServerInterceptor
- func Serve(port int, cancel chan bool, registers []func(*grpc.Server) error, ...) (int, chan error, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GrpcChannelOptions ¶
func GrpcChannelOptions() grpc.DialOption
GrpcChannelOptions returns the defaultCallOptions with the max_receive_message_length increased to 400mb We want to increase the default message size as per pulumi/pulumi#2319
func IsBenignCloseErr ¶
IsBenignCloseErr returns true if the error is "expected" upon shutdown of the server.
func OpenTracingClientInterceptor ¶
func OpenTracingClientInterceptor() grpc.UnaryClientInterceptor
OpenTracingClientInterceptor provides a default gRPC client interceptor for emitting tracing to the global OpenTracing tracer.
func OpenTracingServerInterceptor ¶
func OpenTracingServerInterceptor(parentSpan opentracing.Span) grpc.UnaryServerInterceptor
OpenTracingServerInterceptor provides a default gRPC server interceptor for emitting tracing to the global OpenTracing tracer.
func Serve ¶
func Serve(port int, cancel chan bool, registers []func(*grpc.Server) error, parentSpan opentracing.Span) (int, chan error, error)
Serve creates a new gRPC server, calls out to the supplied registration functions to bind interfaces, and then listens on the supplied TCP port. If the caller wishes for the kernel to choose a free port automatically, pass 0 as the port number. The return values are: the chosen port (the same as supplied if non-0), a channel that may eventually return an error, and an error, in case something went wrong. The channel is non-nil and waits until the server is finished, in the case of a successful launch of the RPC server.
Types ¶
This section is empty.
Source Files
Directories