eventbus

Documentation

Index

• Constants
• type Bus
  • func NewEventBus() *Bus
  • func (b *Bus) Notify(event Event)
  • func (b *Bus) Subscribe(events ...string) *Subscription
• type Event
  • func FoundUnexistingSymbol(symbol string) Event
  • func GenerateEvent(eventName string, payload interface{}) Event
• type EventHandler
• type Subscription
  • func (s *Subscription) Close()
  • func (s *Subscription) Handler(ctx context.Context, handler EventHandler)

Constants

const (
	EventCoinsPricesFetched    = "coins_prices_fetched"
	EventFoundUnexistingSymbol = "found_unexisting_symbol"
	SendNotification           = "send_notification"
	SaveBalance                = "save_balance"
)

Types

type Bus

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

func NewEventBus

func NewEventBus() *Bus

func (*Bus) Notify

func (b *Bus) Notify(event Event)

func (*Bus) Subscribe

func (b *Bus) Subscribe(events ...string) *Subscription

type Event

type Event struct {
	Name    string
	Payload interface{}
}

func FoundUnexistingSymbol

func FoundUnexistingSymbol(symbol string) Event

func GenerateEvent

func GenerateEvent(eventName string, payload interface{}) Event

type EventHandler

type EventHandler func(context.Context, Event)

type Subscription

type Subscription struct {
	EventsCh         chan Event
	EventsSubscribed map[string]bool
	// contains filtered or unexported fields
}

func (*Subscription) Close

func (s *Subscription) Close()

func (*Subscription) Handler

func (s *Subscription) Handler(ctx context.Context, handler EventHandler)

If events is not provided, will be all events for this subscription