evt

Documentation

Index

• Variables
• type EventHandler
  • func NewEventHandler() *EventHandler
  • func (e *EventHandler) Close()
  • func (e *EventHandler) Flush(timeoutMs int)
  • func (e *EventHandler) Produce(topic string, key string, value []byte)

Variables

var Topics map[domain.Status]string = map[domain.Status]string{
	domain.Unconfirmed: "orders__unconfirmed",
	domain.InProgress:  "orders__in_progress",
	domain.Ready:       "orders__ready",
	domain.InTransit:   "orders__in_transit",
	domain.Delivered:   "orders__delivered",
}

Types

type EventHandler

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

func NewEventHandler

func NewEventHandler() *EventHandler

func (*EventHandler) Close

func (e *EventHandler) Close()

func (*EventHandler) Flush

func (e *EventHandler) Flush(timeoutMs int)

func (*EventHandler) Produce

func (e *EventHandler) Produce(topic string, key string, value []byte)