kafka

Documentation

Index

• type KafkaOpeateLogProvider
  • func NewKafkaOpeateLogProvider() *KafkaOpeateLogProvider
  • func (k *KafkaOpeateLogProvider) Run(ctx context.Context)

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接口进行保持