dist

type Address struct {
	Domain               string // 主域
	BroadcastSubdomain   string // 广播地址子域
	BalanceSubdomain     string // 负载均衡地址子域
	NodeSubdomain        string // 服务节点地址子域
	GlobalBroadcastAddr  string // 全局广播地址
	GlobalBalanceAddr    string // 全局负载均衡地址
	ServiceBroadcastAddr string // 服务广播地址
	ServiceBalanceAddr   string // 服务负载均衡地址
	LocalAddr            string // 本服务节点地址
}

type DistributedOptions struct {
	Version           string            // 服务版本号
	Meta              map[string]string // 服务元数据，以键值对的形式保存附加信息
	Domain            string            // 服务地址域
	RefreshInterval   time.Duration     // 服务信息刷新间隔
	FutureTimeout     time.Duration     // 异步模型Future超时时间
	DecoderMsgCreator gap.IMsgCreator   // 消息包解码器的消息构建器
	RecvMsgHandler    RecvMsgHandler    // 接收消息的处理器（优先级低于监控器）
}

type IDistributed interface {
	// GetAddress 获取地址信息
	GetAddress() Address
	// GetFutures 获取异步模型Future控制器
	GetFutures() concurrent.IFutures
	// MakeServiceBroadcastAddr 创建服务广播地址
	MakeServiceBroadcastAddr(service string) string
	// MakeServiceBalanceAddr 创建服务负载均衡地址
	MakeServiceBalanceAddr(service string) string
	// MakeServiceNodeAddr 创建服务节点地址
	MakeServiceNodeAddr(service, node string) (string, error)
	// SendMsg 发送消息
	SendMsg(dst string, msg gap.Msg) error
	// WatchMsg 监听消息（优先级高）
	WatchMsg(ctx context.Context, handler RecvMsgHandler) IWatcher
}

type IWatcher interface {
	context.Context
	Stop() <-chan struct{}
}

type Option struct{}

type RecvMsgHandler = generic.DelegateFunc2[string, gap.MsgPacket, error] // 接收消息的处理器