grpc

Documentation

Index

• func ErrorResponseEncoder(encoder kitgrpc.EncodeResponseFunc, errorEncoder EncodeErrorResponseFunc) kitgrpc.EncodeResponseFunc
• func IsGRPCError(err error) bool
• func ServerOptions(options []grpc.ServerOption) grpc.ServerOption
• type EncodeErrorResponseFunc
  • func NewDefaultStatusErrorResponseEncoder() EncodeErrorResponseFunc
  • func NewStatusErrorResponseEncoder(statusConverter StatusConverter) EncodeErrorResponseFunc
• type ServerFactory
  • func NewServerFactory(options ...grpc.ServerOption) ServerFactory
• type StatusConverter

Functions

func ErrorResponseEncoder

func ErrorResponseEncoder(
	encoder kitgrpc.EncodeResponseFunc,
	errorEncoder EncodeErrorResponseFunc,
) kitgrpc.EncodeResponseFunc

ErrorResponseEncoder encodes the passed response object to a gRPC response or error.

func IsGRPCError

func IsGRPCError(err error) bool

IsGRPCError checks if an error is already encoded as a gRPC status.

func ServerOptions

func ServerOptions(options []grpc.ServerOption) grpc.ServerOption

ServerOptions collects a list of ServerOptions into a single option. Useful to avoid variadic hells when passing lists of options around.

Types

type EncodeErrorResponseFunc

type EncodeErrorResponseFunc func(context.Context, error) error

EncodeErrorResponseFunc transforms the passed error to a gRPC code error. It's designed to be used in gRPC servers, for server-side endpoints.

func NewDefaultStatusErrorResponseEncoder

func NewDefaultStatusErrorResponseEncoder() EncodeErrorResponseFunc

NewDefaultStatusErrorResponseEncoder returns an error response encoder that encodes errors as gRPC Status errors.

The returned encoder encodes every error as Internal error.

func NewStatusErrorResponseEncoder

func NewStatusErrorResponseEncoder(statusConverter StatusConverter) EncodeErrorResponseFunc

NewStatusErrorResponseEncoder returns an error response encoder that encodes errors as gRPC Status errors.

type ServerFactory

type ServerFactory interface {
	// NewServer constructs a new server, which wraps the provided endpoint and implements the grpc.Handler interface.
	NewServer(
		e endpoint.Endpoint,
		dec grpc.DecodeRequestFunc,
		enc grpc.EncodeResponseFunc,
		options ...grpc.ServerOption,
	) *grpc.Server
}

ServerFactory constructs a new server, which wraps the provided endpoint and implements the grpc.Handler interface.

func NewServerFactory

func NewServerFactory(options ...grpc.ServerOption) ServerFactory

NewServerFactory returns a new ServerFactory.

type StatusConverter

type StatusConverter interface {
	// NewStatus creates a new gRPC Status from an error.
	NewStatus(ctx context.Context, err error) *status.Status
}

StatusConverter creates a new gRPC Status from an error.