Documentation ¶
Index ¶
- func DeleteUserInfo(id int64) (err error)
- func GetBrokers() (dataList []interface{}, err error)
- func GetTopics() (dataList []interface{}, err error)
- func QueryAllUserInfo() (dataList []interface{}, err error)
- func SaveUserInfoById(m *UserInfo) (err error)
- type KafkaBroker
- type KafkaTopic
- type MessageBlock
- type TopicMessages
- type UserInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KafkaBroker ¶
type KafkaTopic ¶
type MessageBlock ¶
type TopicMessages ¶
type TopicMessages struct { Topic string Message []MessageBlock }
func GetTopicMessages ¶
func GetTopicMessages(topic string) (topicMessage TopicMessages, err error)
获取Topic消息
type UserInfo ¶
type UserInfo struct { Id int64 `orm:"auto"` UserName string `orm:"size(255)"` //登录名 Password string `orm:"size(255)"` //密码 Name string `orm:"size(255)"` //用户名 BirthDate string `orm:"size(255)"` //生日 Gender int8 //性别 Email string `orm:"size(255)"` //Email Phone string `orm:"size(255)"` //电话 Status int8 //状态 CreateTime time.Time //创建时间 UpdateTime time.Time //更新时间 }
Click to show internal directories.
Click to hide internal directories.