backend

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

type ErrorHandler func(err error) (interface{}, error)

type GrpcClient interface {
	ReceiveAddressList([]structure.AddressConfiguration) bool
	Invoke(method string, callerId int, requestBody, responsePointer interface{}, opts ...InvokeOption) error
	InvokeStream(method string, callerId int, consumer streaming.StreamConsumer) error
	Conn() isp.BackendServiceClient
	Close() error
}

type GrpcServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

type Interceptor func(ctx RequestCtx, proceed func() (interface{}, error)) (interface{}, error)

type InvokeOption func(opts *invokeOpts)

type PostProcessor func(ctx RequestCtx)

type RequestCtx interface {
	Method() string
	Metadata() metadata.MD
	RequestBody() []byte
	ResponseBody() []byte
	MappedRequest() interface{}
	MappedResponse() interface{}
	Error() error
}

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

type RxOption func(rc *RxGrpcClient)

type Validator func(ctx RequestCtx, mappedRequestBody interface{}) error