messaging

Documentation

Index

• type Consumer
  • func NewConsumer(ctx context.Context, conf configuration.Consumption, logger logging.Logger, ...) (Consumer, error)
• type Emitter
  • func NewEmitter(ctx context.Context, conf configuration.Emission, logger logging.Logger) (Emitter, error)

Types

type Consumer

type Consumer interface {
	Run(ctx context.Context) error
}

Consumer is an abstraction for consumming messages for messaging pipeline.

func NewConsumer

func NewConsumer(ctx context.Context, conf configuration.Consumption,
	logger logging.Logger,
	handler func(*bus.Message) (reply interface{}, err error)) (Consumer, error)

NewConsumer returns a valid event consumer.

type Emitter

type Emitter interface {
	Emit(ctx context.Context, payload interface{}) error
}

Emitter sends message through messaging pipeline.

func NewEmitter

func NewEmitter(ctx context.Context, conf configuration.Emission,
	logger logging.Logger) (Emitter, error)

NewEmitter creates a valid emitter thrrough nsq.