transport

type GetConversationMembers func(appID, conversationId string) ([]string, error) // 获取会话成员

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

type Message struct {
	From           string          `json:"from,omitempty"`            //发送者ID
	To             string          `json:"to,omitempty"`              //接收者ID
	Event          exchange.Event  `json:"event,omitempty"`           //事件类型
	Data           exchange.Fields `json:"data,required"`             //消息内容
	MsgID          string          `json:"msg_id,required"`           //消息ID
	SendAt         int64           `json:"send_at,required"`          //发送时间
	ConversationID string          `json:"conversation_id,omitempty"` //会话ID
}

type Transport struct {
	AppID string // 应用ID
	Tag   string // 连接标签
	Key   string // 连接标识  = makeTransportKey(AppID:Tag)
	// contains filtered or unexported fields
}