controller

Documentation

Index

• type AuduitLogSaveConroller
  • func NewAuduitLogSaveConroller(brokerAddress []string, groupId, topic string) *AuduitLogSaveConroller
  • func (c *AuduitLogSaveConroller) Run(ctx context.Context)
  • func (c *AuduitLogSaveConroller) Stop() error

Types

type AuduitLogSaveConroller

type AuduitLogSaveConroller struct {
	// contains filtered or unexported fields
}

审计日志保存

func NewAuduitLogSaveConroller

func NewAuduitLogSaveConroller(
	brokerAddress []string,
	groupId,
	topic string,
) *AuduitLogSaveConroller

func (*AuduitLogSaveConroller) Run

func (c *AuduitLogSaveConroller) Run(ctx context.Context)

需要读取Kafka里面的审计日志 消费kafka里面的audit log

func (*AuduitLogSaveConroller) Stop

func (c *AuduitLogSaveConroller) Stop() error