grpc

Documentation

Index

• Variables
• func FromDomain(op *model.Operation) *operation.Record
• func RequestLoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type API
  • func New(addr string, svc domain.InternalService) *API
  • func (a *API) Run(ctx context.Context) error

Variables

var (
	ErrValidationFailed = status.New(codes.InvalidArgument, "request.validation_failed")
)

Functions

func FromDomain

func FromDomain(op *model.Operation) *operation.Record

func RequestLoggingInterceptor

func RequestLoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

RequestLoggingInterceptor write request body to logs.

Types

type API

type API struct {
	// contains filtered or unexported fields
}

API represents gRPC API server.

func New

func New(addr string, svc domain.InternalService) *API

func (*API) Run

func (a *API) Run(ctx context.Context) error