subscriber

Documentation

Index

• func SaveNotifyHistories(request *apistructs.CreateNotifyHistoryRequest, ...)
• type Subscriber

Functions

func SaveNotifyHistories

func SaveNotifyHistories(request *apistructs.CreateNotifyHistoryRequest, messenger pb.NotifyServiceServer)

Types

type Subscriber

type Subscriber interface {
	// 各个实现自己解析 dest
	// 返回 []error , 是因为发送消息的目的可能是多个
	// dest: marshaled string
	// content: marshaled string
	Publish(dest string, content string, time int64, m *types.Message) []error
	Status() interface{}
	Name() string
}