commandbushttp

package

v0.0.0-...-5fa8032 Latest Latest Go to latest Published: Aug 27, 2021 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(
	addr string,
	opts ...ClientOption,
) *Client

func (c *Client) CommandSink(ctx context.Context, cmd *command.Command) (*command.Reply, error)

type ClientOption func(*Client)

func WithClientCodec(c command.Encoding) ClientOption

func WithClientContextFunc(fn ContextFunc) ClientOption

func WithClientRequestFunc(fn ClientRequestFunc) ClientOption

func WithClientResponseFunc(fn ClientResponseFunc) ClientOption

func WithClientTransport(c Doer) ClientOption

type ClientRequestFunc func(r *http.Request, c *command.Command)

type ClientResponseFunc func(w *http.Response, r *command.Reply)

type ContextFunc func(ctx context.Context) context.Context

type Doer interface {
	Do(req *http.Request) (*http.Response, error)
}

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

func NewServer(
	mutator stream.CommandSinker,
	opts ...ServerOption,
) *Server

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerErrorHandler func(err error)

type ServerOption func(*Server)

func WithServerCodec(c command.Encoding) ServerOption

func WithServerContextFunc(fn ContextFunc) ServerOption

func WithServerErrorHandler(fn ServerErrorHandler) ServerOption

func WithServerRequestFunc(fn ServerRequestFunc) ServerOption

func WithServerResponseFunc(fn ServerResponseFunc) ServerOption

type ServerRequestFunc func(r *http.Request, c *command.Command)

type ServerResponseFunc func(w http.ResponseWriter, r *command.Reply)