Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

            Types

            type TLSTestResult

            type TLSTestResult struct {
            	TLS         bool
            	InsecureErr error
            }

            func TestTLS

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

            Source Files