evt

package

v0.0.0-...-bb3b8f6 Latest Latest Go to latest Published: Sep 13, 2022 License: MIT Imports: 7 Imported by: 0

Documentation ¶

Index ¶

Variables
type EventHandler
- func NewEventHandler() *EventHandler
type OrderListener
- func NewOrderListener() *OrderListener
- func (l *OrderListener) Listen()
- func (l *OrderListener) NotifyVendor(o domain.OrderModel)

Constants ¶

This section is empty.

Variables ¶

View Source

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",
}

Functions ¶

This section is empty.

Types ¶

type EventHandler ¶

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

func NewEventHandler ¶

func NewEventHandler() *EventHandler

func (*EventHandler) CloseConsumer ¶

func (e *EventHandler) CloseConsumer()

func (*EventHandler) CloseProducer ¶

func (e *EventHandler) CloseProducer()

func (*EventHandler) Consume ¶

func (e *EventHandler) Consume(topics []string, callback func(kafka.Message))

func (*EventHandler) Flush ¶

func (e *EventHandler) Flush(timeoutMs int)

func (*EventHandler) Produce ¶

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

type OrderListener ¶

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

func NewOrderListener ¶

func NewOrderListener() *OrderListener

func (*OrderListener) Listen ¶

func (l *OrderListener) Listen()

func (*OrderListener) NotifyVendor ¶

func (l *OrderListener) NotifyVendor(o domain.OrderModel)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL