emitter

Documentation

Index

• type EventEmitter
  • func NewInternalQueueEmitter(cfg *configuration.Configuration) EventEmitter
  • func NewKafkaEmitter(cfg *configuration.KafkaProducerConfig) EventEmitter
• type InternalQueueEventEmitter
  • func (i *InternalQueueEventEmitter) Send(ctx context.Context, e event.Event) error
• type KafkaEmitter
  • func (k *KafkaEmitter) Send(ctx context.Context, event event.Event) error

Types

type EventEmitter

type EventEmitter interface {
	Send(ctx context.Context, event event.Event) error
}

func NewInternalQueueEmitter

func NewInternalQueueEmitter(cfg *configuration.Configuration) EventEmitter

func NewKafkaEmitter

func NewKafkaEmitter(cfg *configuration.KafkaProducerConfig) EventEmitter

type InternalQueueEventEmitter

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

func (*InternalQueueEventEmitter) Send

func (i *InternalQueueEventEmitter) Send(ctx context.Context, e event.Event) error

type KafkaEmitter

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

func (*KafkaEmitter) Send

func (k *KafkaEmitter) Send(ctx context.Context, event event.Event) error