grpc

Documentation

Index

• func BlockingDial(ctx context.Context, network, address string, ...) (*grpc.ClientConn, error)
• func ErrorCodeStreamServerInterceptor() grpc.StreamServerInterceptor
• func ErrorCodeUnaryServerInterceptor() grpc.UnaryServerInterceptor
• func PanicLoggerStreamServerInterceptor(log *logrus.Entry) grpc.StreamServerInterceptor
• func PanicLoggerUnaryServerInterceptor(log *logrus.Entry) grpc.UnaryServerInterceptor
• func PayloadStreamServerInterceptor(entry *logrus.Entry, logClaims bool, ...) grpc.StreamServerInterceptor
• func PayloadUnaryServerInterceptor(entry *logrus.Entry, logClaims bool, ...) grpc.UnaryServerInterceptor
• func UserAgentStreamServerInterceptor(clientName, constraintStr string) grpc.StreamServerInterceptor
• func UserAgentUnaryServerInterceptor(clientName, constraintStr string) grpc.UnaryServerInterceptor
• func WithTimeout(duration time.Duration) grpc.UnaryClientInterceptor
• type TLSTestResult
  • func TestTLS(address string) (*TLSTestResult, error)

Functions

func BlockingDial

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

func ErrorCodeStreamServerInterceptor() grpc.StreamServerInterceptor

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

func ErrorCodeUnaryServerInterceptor

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

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

func PayloadUnaryServerInterceptor

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

func UserAgentStreamServerInterceptor

func UserAgentStreamServerInterceptor(clientName, constraintStr string) grpc.StreamServerInterceptor

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

func UserAgentUnaryServerInterceptor

func UserAgentUnaryServerInterceptor(clientName, constraintStr string) grpc.UnaryServerInterceptor

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

func WithTimeout

func WithTimeout(duration time.Duration) grpc.UnaryClientInterceptor

Types

type TLSTestResult

type TLSTestResult struct {
	TLS         bool
	InsecureErr error
}

func TestTLS

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