server

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

type Option func(*Options)

type Options struct {
	Registry  registry.Registry
	Metadata  map[string]string
	Name      string
	Address   string // use host:port nats_server.addr 不重要
	Advertise string // use host:port (优先) 不重要
	ID        string
	Version   string // module的版本

	RegisterInterval time.Duration
	RegisterTTL      time.Duration

	// 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() any
	// indicates whether the request will be streamed
	Stream() bool
}

type Server interface {
	ID() string // 模块服务ID
	Options() Options
	UpdMetadata(key, val string) // 更新元数据(正常需要等到下次注册时生效,如果要立即生效还需要调用ServiceRegister)
	OnInit(module app.IModule, settings *conf.ModuleSettings) error
	OnDestroy() error

	Register(id string, f any)   // 注册RPC方法
	RegisterGO(id string, f any) // 注册RPC方法
	SetListener(listener mqrpc.RPCListener)
	ServiceRegister() error   // 向Registry注册自己
	ServiceDeregister() error // 向Registry注销自己

	Start() error
	Stop() error

	String() string
}

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