Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FieldDeleteConsumer ¶
type FieldDeleteConsumer struct {
// contains filtered or unexported fields
}
FieldDeleteConsumer 字段删除事件消费者
func NewFieldDeleteConsumer ¶
func NewFieldDeleteConsumer(consumer mq.Consumer, svc resourceservice.Service) *FieldDeleteConsumer
NewFieldDeleteConsumer 构造字段删除消费者
func (*FieldDeleteConsumer) Consume ¶
func (c *FieldDeleteConsumer) Consume(ctx context.Context) error
Consume 提取事件消息并反序列化
func (*FieldDeleteConsumer) Process ¶
func (c *FieldDeleteConsumer) Process(ctx context.Context, evt domain.FieldDelete) error
Process 处理级联删除事件逻辑
func (*FieldDeleteConsumer) Start ¶
func (c *FieldDeleteConsumer) Start(ctx context.Context)
Start 启动后台消费协程
type FieldSecureAttrChangeConsumer ¶
type FieldSecureAttrChangeConsumer struct {
// contains filtered or unexported fields
}
func NewFieldSecureAttrChangeConsumer ¶
func NewFieldSecureAttrChangeConsumer(consumer mq.Consumer, svc resourceservice.EncryptedSvc, limit int64, crypto cryptox.Crypto) *FieldSecureAttrChangeConsumer
func (*FieldSecureAttrChangeConsumer) Consume ¶
func (c *FieldSecureAttrChangeConsumer) Consume(ctx context.Context) error
func (*FieldSecureAttrChangeConsumer) Process ¶
func (c *FieldSecureAttrChangeConsumer) Process(ctx context.Context, evt domain.FieldSecureAttrChange) error
func (*FieldSecureAttrChangeConsumer) Start ¶
func (c *FieldSecureAttrChangeConsumer) Start(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.