Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DirtyConsumer ¶
type DirtyConsumer struct { }
func NewDirtyConsumer ¶
func NewDirtyConsumer() *DirtyConsumer
func (*DirtyConsumer) Consume ¶
func (c *DirtyConsumer) Consume(ormService *datalayer.ORM, events []beeorm.Event) error
func (*DirtyConsumer) GetGroupName ¶
func (c *DirtyConsumer) GetGroupName(suffix *string) string
func (*DirtyConsumer) GetQueueName ¶
func (c *DirtyConsumer) GetQueueName() string
Click to show internal directories.
Click to hide internal directories.