grpc

package
v1.4.2 Latest Latest
Warning

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

Go to latest
Published: Jan 24, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BlockingDial added in v0.3.0

func BlockingDial(ctx context.Context, network, address string, creds credentials.TransportCredentials, opts ...grpc.DialOption) (*grpc.ClientConn, error)

BlockingDial is a helper method to dial the given address, using optional TLS credentials, and blocking until the returned connection is ready. If the given credentials are nil, the connection will be insecure (plain-text). Lifted from: https://github.com/fullstorydev/grpcurl/blob/master/grpcurl.go

func ErrorCodeStreamServerInterceptor added in v0.3.0

func ErrorCodeStreamServerInterceptor() grpc.StreamServerInterceptor

ErrorCodeStreamServerInterceptor replaces Kubernetes errors with relevant gRPC equivalents, if any.

func ErrorCodeUnaryServerInterceptor added in v0.3.0

func ErrorCodeUnaryServerInterceptor() grpc.UnaryServerInterceptor

ErrorCodeUnaryServerInterceptor replaces Kubernetes errors with relevant gRPC equivalents, if any.

func PanicLoggerStreamServerInterceptor

func PanicLoggerStreamServerInterceptor(log *logrus.Entry) grpc.StreamServerInterceptor

PanicLoggerStreamServerInterceptor returns a new streaming server interceptor for recovering from panics and returning error

func PanicLoggerUnaryServerInterceptor

func PanicLoggerUnaryServerInterceptor(log *logrus.Entry) grpc.UnaryServerInterceptor

PanicLoggerUnaryServerInterceptor returns a new unary server interceptor for recovering from panics and returning error

func PayloadStreamServerInterceptor added in v0.7.0

func PayloadStreamServerInterceptor(entry *logrus.Entry, logClaims bool, decider grpc_logging.ServerPayloadLoggingDecider) grpc.StreamServerInterceptor

func PayloadUnaryServerInterceptor added in v0.7.0

func PayloadUnaryServerInterceptor(entry *logrus.Entry, logClaims bool, decider grpc_logging.ServerPayloadLoggingDecider) grpc.UnaryServerInterceptor

func UserAgentStreamServerInterceptor added in v0.11.0

func UserAgentStreamServerInterceptor(clientName, constraintStr string) grpc.StreamServerInterceptor

UserAgentStreamServerInterceptor returns a StreamServerInterceptor which enforces a minimum client version in the user agent

func UserAgentUnaryServerInterceptor added in v0.11.0

func UserAgentUnaryServerInterceptor(clientName, constraintStr string) grpc.UnaryServerInterceptor

UserAgentUnaryServerInterceptor returns a UnaryServerInterceptor which enforces a minimum client version in the user agent

func WithTimeout added in v0.12.3

func WithTimeout(duration time.Duration) grpc.UnaryClientInterceptor

Types

type TLSTestResult added in v0.3.0

type TLSTestResult struct {
	TLS         bool
	InsecureErr error
}

func TestTLS added in v0.3.0

func TestTLS(address string) (*TLSTestResult, error)

Jump to

Keyboard shortcuts

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