api

Documentation

Index

• func StartAPI(collection *mongo.Collection, eventBus *EventBus)
• type EventBus
  • func NewEventBus() *EventBus
  • func (eb *EventBus) Close()
  • func (eb *EventBus) Publish(event string)
  • func (eb *EventBus) Subscribe() <-chan string

Functions

func StartAPI

func StartAPI(collection *mongo.Collection, eventBus *EventBus)

Types

type EventBus

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

func NewEventBus

func NewEventBus() *EventBus

Create event bus

func (*EventBus) Close

func (eb *EventBus) Close()

Close connection

func (*EventBus) Publish

func (eb *EventBus) Publish(event string)

Publish message to event bus

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe() <-chan string

Subscribe to event bus