2022-06-14 17:19:43 +08:00
|
|
|
package message
|
2022-06-15 14:56:43 +08:00
|
|
|
|
2022-08-14 03:05:30 +08:00
|
|
|
type Message struct {
|
|
|
|
|
Type string `json:"type"`
|
|
|
|
|
Content interface{} `json:"content"`
|
|
|
|
|
}
|
|
|
|
|
|
2022-07-01 16:08:08 +08:00
|
|
|
type Messenger interface {
|
2022-08-14 03:05:30 +08:00
|
|
|
Send(Message) error
|
2022-07-01 16:53:01 +08:00
|
|
|
Receive() (string, error)
|
2022-08-14 03:05:30 +08:00
|
|
|
WaitSend(Message, int) error
|
2022-07-01 16:53:01 +08:00
|
|
|
WaitReceive(int) (string, error)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func GetMessenger() Messenger {
|
2022-08-14 03:05:30 +08:00
|
|
|
return HttpInstance
|
2022-06-15 14:56:43 +08:00
|
|
|
}
|
