Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaOperateLogProvider ¶
type KafkaOperateLogProvider struct {
// contains filtered or unexported fields
}
由kafka来提供操作日志数据 1. 读取 操作日志发送的topic里面的数据 2. 调用save接口进行保存 运行起来后,一直跑在后台, 有点类似于一个agent 可以理解为一个常驻在后台进行独立任务处理的goroutine
func NewKafkaOperateLogProvider ¶
func NewKafkaOperateLogProvider() *KafkaOperateLogProvider
func (*KafkaOperateLogProvider) Run ¶
func (k *KafkaOperateLogProvider) Run(ctx context.Context)
1. 读取 操作日志发送的topic里面的数据 2. 调用save接口保存
Source Files
Click to show internal directories.
Click to hide internal directories.