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