rpcutil

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)

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

func IsBenignCloseErr(err error) bool

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.