events

Documentation

Index

• type Event
• type EventType
  • func (et EventType) String() string
• type RabbitMQConsumer
  • func NewRabbitMQConsumer(config config.RabbitMQ, log logger.Logger) (*RabbitMQConsumer, error)
  • func (c *RabbitMQConsumer) Close() error
  • func (c *RabbitMQConsumer) Consume() (<-chan Event, error)
• type RabbitMQProducer
  • func NewRabbitMQProducer(config config.RabbitMQ, log logger.Logger) (*RabbitMQProducer, error)
  • func (p *RabbitMQProducer) Close(ctx context.Context) error
  • func (p *RabbitMQProducer) Produce(ctx context.Context, event Event) error

Types

type Event

type Event struct {
	Type EventType         `json:"type"`
	Data map[string]string `json:"data"`
}

type EventType

type EventType int

const (
	MapTaskCreated EventType = iota
	ReduceTaskCreated
)

func (EventType) String

func (et EventType) String() string

type RabbitMQConsumer

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

func NewRabbitMQConsumer

func NewRabbitMQConsumer(config config.RabbitMQ, log logger.Logger) (*RabbitMQConsumer, error)

func (*RabbitMQConsumer) Close

func (c *RabbitMQConsumer) Close() error

func (*RabbitMQConsumer) Consume

func (c *RabbitMQConsumer) Consume() (<-chan Event, error)

type RabbitMQProducer

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

func NewRabbitMQProducer

func NewRabbitMQProducer(config config.RabbitMQ, log logger.Logger) (*RabbitMQProducer, error)

func (*RabbitMQProducer) Close

func (p *RabbitMQProducer) Close(ctx context.Context) error

func (*RabbitMQProducer) Produce

func (p *RabbitMQProducer) Produce(ctx context.Context, event Event) error