Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetNotificationData ¶
func GetNotificationData(e *ctdf.Event) ctdf.EventNotificationData
func RegisterCLI ¶
func RegisterCLI() *cli.Command
Types ¶
type EventsBatchConsumer ¶
type EventsBatchConsumer struct {
NotifyQueue rmq.Queue
}
func NewEventsBatchConsumer ¶
func NewEventsBatchConsumer() *EventsBatchConsumer
func (*EventsBatchConsumer) Consume ¶
func (c *EventsBatchConsumer) Consume(batch rmq.Deliveries)
Click to show internal directories.
Click to hide internal directories.