Documentation
¶
Index ¶
- type AuditServiceImpl
- func (i *AuditServiceImpl) Init() error
- func (i *AuditServiceImpl) Name() string
- func (i *AuditServiceImpl) Priority() int
- func (i *AuditServiceImpl) QueryEvent(ctx context.Context, in *audit.QueryAuditLogRequest) (*types.Set[*audit.AuditLog], error)
- func (c *AuditServiceImpl) RunSaveEventConsumer(ctx context.Context) error
- func (i *AuditServiceImpl) SaveEvent(ctx context.Context, in *audit.AuditLog) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuditServiceImpl ¶
type AuditServiceImpl struct {
// 继承模版
ioc.ObjectImpl
// 当前这个消费者 配置的topic
AuditTopic string `toml:"topic" json:"topic" yaml:"topic" env:"TOPIC"`
// contains filtered or unexported fields
}
业务具体实现
func (*AuditServiceImpl) Priority ¶
func (i *AuditServiceImpl) Priority() int
func (*AuditServiceImpl) QueryEvent ¶
func (i *AuditServiceImpl) QueryEvent(ctx context.Context, in *audit.QueryAuditLogRequest) (*types.Set[*audit.AuditLog], error)
查询
func (*AuditServiceImpl) RunSaveEventConsumer ¶
func (c *AuditServiceImpl) RunSaveEventConsumer(ctx context.Context) error
读取消息，处理消息
Source Files
Click to show internal directories.
Click to hide internal directories.