server

type Message interface {
	Topic() string
	Payload() interface{}
	ContentType() string
}

type Option func(*Options)

type Options struct {
	Registry registry.Registry

	Metadata         map[string]string
	Name             string
	Address          string
	ID               string
	Version          string
	RegisterInterval time.Duration
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context

	RoutineCount int // RPC Server Routine Channel Buffer Length
}

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
	OnInit(module module.Module, app module.App, settings *conf.ModuleSettings) error
	Init(...Option) error
	SetListener(listener mqrpc.RPCListener)
	SetGoroutineControl(control mqrpc.GoroutineControl)
	Register(id string, f interface{})
	RegisterGO(id string, f interface{})
	ServiceRegister() error
	ServiceDeregister() error
	Start() error
	Stop() error
	OnDestroy() error
	String() string
	ID() string
}

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