sys_message_consume.go
892 字节
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package domain
// SysMessageConsume
type SysMessageConsume struct {
// 消息ID
Id int64 `json:"id"`
// 主题
Topic string `json:"topic"`
// 分区信息
Partition int `json:"partition"`
// 消息偏移序号
Offset int64 `json:"offset"`
// 键值
Key string `json:"key"`
// 消息内容
Value string `json:"value"`
// 消息时间
MsgTime int64 `json:"msgTime"`
// 创建时间
CreateAt int64 `json:"createAt"`
// 状态
Status int64 `json:"status"`
}
type SysMessageConsumeRepository interface {
Save(dm *SysMessageConsume) (*SysMessageConsume, error)
Remove(dm *SysMessageConsume) (*SysMessageConsume, error)
FindOne(queryOptions map[string]interface{}) (*SysMessageConsume, error)
Find(queryOptions map[string]interface{}) (int64, []*SysMessageConsume, error)
}
func (m *SysMessageConsume) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}