utils

Documentation

Index

• type DataChannel
• type DataChannelSlice
• type DataEvent
• type EventBus
  • func (eb *EventBus) Publish(topic string, data interface{})
  • func (eb *EventBus) PublishToChannel(channel DataChannel, topic string, data interface{})
  • func (eb *EventBus) Subscribe(topic string, ch DataChannel)
• type PublishSubscriber

Types

type DataChannel

type DataChannel chan DataEvent

DataChannel is a channel which can accept an DataEvent

type DataChannelSlice

type DataChannelSlice []DataChannel

DataChannelSlice is a slice of DataChannels

type DataEvent

type DataEvent struct {
	Data  interface{}
	Topic string
}

type EventBus

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

EventBus stores the information about subscribers interested for a particular topic

func (*EventBus) Publish

func (eb *EventBus) Publish(topic string, data interface{})

func (*EventBus) PublishToChannel

func (eb *EventBus) PublishToChannel(channel DataChannel, topic string, data interface{})

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe(topic string, ch DataChannel)

type PublishSubscriber

type PublishSubscriber interface {
	Publish(topic string, data interface{})
	PublishToChannel(channel DataChannel, topic string, data interface{})
	Subscribe(topic string, ch DataChannel)
}