rpcutil

package
v2.25.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2021 License: Apache-2.0 Imports: 11 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GrpcChannelOptions added in v2.1.0

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.

Types

This section is empty.

Directories

Path Synopsis
Package rpcerror provides helper types and functions for dealing with errors that cross gRPC boundaries.
Package rpcerror provides helper types and functions for dealing with errors that cross gRPC boundaries.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL