kafka

Documentation

Index

• type KafkaOperateLogProvider
  • func NewKafkaOperateLogProvider() *KafkaOperateLogProvider
  • func (k *KafkaOperateLogProvider) Run(ctx context.Context)

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接口保存