Documentation ¶
Index ¶
- type Client
- type ClientOption
- func WithClientCallOptions(opts ...grpc.CallOption) ClientOption
- func WithClientCodec(c command.Encoding) ClientOption
- func WithClientContextFunc(fn ContextFunc) ClientOption
- func WithClientRequestFunc(fn ClientRequestFunc) ClientOption
- func WithClientResponseFunc(fn ClientResponseFunc) ClientOption
- type ClientRequestFunc
- type ClientResponseFunc
- type ContextFunc
- type Server
- type ServerErrorHandler
- type ServerOption
- type ServerRequestFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient( conn *grpc.ClientConn, opts ...ClientOption, ) *Client
type ClientOption ¶
type ClientOption func(*Client)
func WithClientCallOptions ¶
func WithClientCallOptions(opts ...grpc.CallOption) ClientOption
func WithClientCodec ¶
func WithClientCodec(c command.Encoding) ClientOption
func WithClientContextFunc ¶
func WithClientContextFunc(fn ContextFunc) ClientOption
func WithClientRequestFunc ¶
func WithClientRequestFunc(fn ClientRequestFunc) ClientOption
func WithClientResponseFunc ¶
func WithClientResponseFunc(fn ClientResponseFunc) ClientOption
type Server ¶
type Server struct { proto.UnimplementedCommandBusServer // contains filtered or unexported fields }
func NewServer ¶
func NewServer( mutator stream.CommandSinker, opts ...ServerOption, ) *Server
func (*Server) CommandSink ¶
type ServerErrorHandler ¶
type ServerErrorHandler func(err error)
type ServerOption ¶
type ServerOption func(*Server)
func WithServerCodec ¶
func WithServerCodec(c command.Encoding) ServerOption
func WithServerContextFunc ¶
func WithServerContextFunc(fn ContextFunc) ServerOption
func WithServerErrorHandler ¶
func WithServerErrorHandler(fn ServerErrorHandler) ServerOption
func WithServerRequestFunc ¶
func WithServerRequestFunc(fn ServerRequestFunc) ServerOption
type ServerRequestFunc ¶
Click to show internal directories.
Click to hide internal directories.