server

type HandlerFunc func(ctx context.Context, req Request, rsp interface{}) error

type HandlerWrapper func(HandlerFunc) HandlerFunc

type Option func(*Options)

type Options struct {
	Codecs          map[string]codec.NewCodec
	Registry        registry.Registry
	Transport       transport.Transport
	Metadata        map[string]string
	Name            string
	Address         string
	Advertise       string
	PrivateIPBlocks string
	ID              string
	Version         string
	HdlrWrappers    []HandlerWrapper

	// RegisterCheck runs a check function before registering the service
	RegisterCheck func(context.Context) error
	// The register expiry time
	RegisterTTL time.Duration
	// The interval on which to register
	RegisterInterval time.Duration

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Request interface {
	ID() string
	// The action requested
	Method() string
	// Content type provided
	ContentType() string
	// Header of the request
	Header() map[string]string
	// Body is the initial decoded value
	Body() interface{}
}

type Server interface {
	Options() Options
	Init(...Option) error
	Handle(interface{}) error
	Start() error
	Stop() error
	String() string
}