pubsub

Documentation

Index

• type EventBus
  • func NewEventBus() EventBus
• type UnsubscribeFunc

Types

type EventBus

type EventBus interface {
	AddTopic(name string, src <-chan coretypes.ResultEvent) error
	RemoveTopic(name string)
	Subscribe(name string) (<-chan coretypes.ResultEvent, UnsubscribeFunc, error)
	Topics() []string
}

func NewEventBus

func NewEventBus() EventBus

type UnsubscribeFunc

type UnsubscribeFunc func()