server

type Handler interface {
	Service() string // Service Interface
	Version() string
}

type Option func(*Options)

type Options struct {
	Codecs    map[string]codec.NewCodec
	Registry  registry.Registry
	Transport transport.Transport

	ConfList        []registry.ServerConfig
	ServiceConfList []registry.ServiceConfig
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Request interface {
	Service() string
	Method() string
	ContentType() string
	Request() interface{}
	// indicates whether the request will be streamed
	Stream() bool
}

type Server interface {
	Options() Options
	Handle(Handler) error
	Start() error
	Stop()
	String() string
}

type Streamer interface {
	Context() context.Context
	Request() Request
	Send(interface{}) error
	Recv(interface{}) error
	Error() error
	Close() error
}