communication

type CommunicationFactory interface {
	// CreateCommunication 创建通信实例
	// protocol: 通信协议
	// options: 选项
	// 返回: 通信实例和错误
	CreateCommunication(protocol sdk.CommunicationProtocol, options map[string]interface{}) (sdk.Communication, error)

	// RegisterHandler 注册协议处理器
	// protocol: 通信协议
	// handler: 处理器
	RegisterHandler(protocol sdk.CommunicationProtocol, handler sdk.CommunicationHandler)
}

type DefaultCommunicationFactory struct {
	// contains filtered or unexported fields
}

type DefaultEventBus struct {
	// contains filtered or unexported fields
}

type Event struct {
	// 事件类型
	Type EventType

	// 事件源
	Source string

	// 事件ID
	ID string

	// 事件优先级
	Priority EventPriority

	// 事件时间
	Timestamp time.Time

	// 事件数据
	Data map[string]interface{}
}

type EventBus interface {
	// Publish 发布事件
	// event: 事件
	// 返回: 错误
	Publish(event Event) error

	// Subscribe 订阅事件
	// eventType: 事件类型
	// handler: 事件处理器
	// 返回: 订阅ID和错误
	Subscribe(eventType EventType, handler EventHandler) (string, error)

	// SubscribeWithFilter 带过滤器订阅事件
	// eventType: 事件类型
	// handler: 事件处理器
	// filter: 事件过滤器
	// 返回: 订阅ID和错误
	SubscribeWithFilter(eventType EventType, handler EventHandler, filter EventFilter) (string, error)

	// SubscribeWithOptions 带选项订阅事件
	// options: 订阅选项
	// 返回: 订阅ID和错误
	SubscribeWithOptions(options SubscriptionOptions) (string, error)

	// Unsubscribe 取消订阅
	// subscriptionID: 订阅ID
	// 返回: 错误
	Unsubscribe(subscriptionID string) error

	// Close 关闭事件总线
	// 返回: 错误
	Close() error
}

type EventFilter func(event Event) bool

type EventHandler func(event Event) error

type EventPriority int

type EventSubscription struct {
	// 订阅ID
	ID string

	// 事件类型
	Type EventType

	// 事件源
	Source string

	// 事件处理器
	Handler EventHandler

	// 事件过滤器
	Filter EventFilter

	// 是否同步处理
	Synchronous bool

	// 订阅时间
	SubscribedAt time.Time
}

type EventType string

type GRPCCommunication struct {
	// contains filtered or unexported fields
}

type GRPCOptions struct {
	// 地址
	Address string

	// 是否为服务器
	IsServer bool

	// 日志记录器
	Logger hclog.Logger

	// 事件总线
	EventBus EventBus

	// 服务注册函数
	ServiceRegistrar func(*grpc.Server)

	// 客户端连接选项
	DialOptions []grpc.DialOption

	// 服务器选项
	ServerOptions []grpc.ServerOption

	// 超时时间
	Timeout time.Duration
}

type HTTPCommunication struct {
	// contains filtered or unexported fields
}

type HTTPOptions struct {
	// 地址
	Address string

	// 是否为服务器
	IsServer bool

	// 日志记录器
	Logger hclog.Logger

	// 事件总线
	EventBus EventBus

	// 路由注册函数
	RouteRegistrar func(*mux.Router)

	// 客户端选项
	ClientOptions *http.Client

	// 服务器选项
	ServerOptions *http.Server

	// 超时时间
	Timeout time.Duration
}

type InProcessCommunication struct {
	// contains filtered or unexported fields
}

type Message struct {
	// 消息类型
	Type string `json:"type"`

	// 消息目标
	Target string `json:"target"`

	// 消息源
	Source string `json:"source"`

	// 消息ID
	ID string `json:"id"`

	// 消息时间
	Timestamp time.Time `json:"timestamp"`

	// 消息数据
	Data map[string]interface{} `json:"data"`
}

type SubscriptionOptions struct {
	// 事件类型
	Type EventType

	// 事件源
	Source string

	// 事件处理器
	Handler EventHandler

	// 事件过滤器
	Filter EventFilter

	// 是否同步处理
	Synchronous bool

	// 订阅ID
	ID string
}

type WebSocketCommunication struct {
	// contains filtered or unexported fields
}

type WebSocketOptions struct {
	// 地址
	Address string

	// 是否为服务器
	IsServer bool

	// 日志记录器
	Logger hclog.Logger

	// 事件总线
	EventBus EventBus

	// 路由注册函数
	RouteRegistrar func(*mux.Router)

	// 服务器选项
	ServerOptions *http.Server

	// 超时时间
	Timeout time.Duration

	// 心跳间隔
	HeartbeatInterval time.Duration
}