push

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

type IQueueReceiver interface {
	Init() error
	Recv(func([]byte)) error
	Stop()
}

type IQueueSender interface {
	Init() error
	Send(*PushMsg) error
	Stop()
}

type KafkaReceiver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type KafkaSender struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MsgBody struct {
	Type        int    `json:"type"`   //推送类型(个体, 同一个app, 全体)
	MsgSeq      uint64 `json:"msgSeq"` //消息序号, 用于ack和持久化
	UUID        string `json:"uuid"`
	Content     string `json:"content"`
	ExpireTime  uint32 `json:"expireTime"`
	OfflinePush bool   `json:"offlinePush"`
}

type PushMsg struct {
	Tag  string  `json:"tag"`
	Body MsgBody `json:"body"`
}