internal

Documentation

Index

• Variables
• type EventArgs
• type EventBus
  • func (eb *EventBus) AddWatcher(eventName string) (Watcher, error)
  • func (eb *EventBus) Close() error
  • func (eb *EventBus) Init(options EventBusOptions) *EventBus
  • func (eb *EventBus) IsClosed() bool
  • func (eb *EventBus) Open() error
  • func (eb *EventBus) RemoveWatcher(eventName string, wrappedWatcher Watcher) error
• type EventBusOptions
• type Watcher
  • func (w Watcher) Event() <-chan struct{}

Variables

var ErrEventBusClosed error = errors.New("internal: event bus closed")

Types

type EventArgs

type EventArgs struct {
	WatchLoss bool
	Message   string
}

type EventBus

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

func (*EventBus) AddWatcher

func (eb *EventBus) AddWatcher(eventName string) (Watcher, error)

func (*EventBus) Close

func (eb *EventBus) Close() error

func (*EventBus) Init

func (eb *EventBus) Init(options EventBusOptions) *EventBus

func (*EventBus) IsClosed

func (eb *EventBus) IsClosed() bool

func (*EventBus) Open

func (eb *EventBus) Open() error

func (*EventBus) RemoveWatcher

func (eb *EventBus) RemoveWatcher(eventName string, wrappedWatcher Watcher) error

type EventBusOptions

type EventBusOptions struct {
	EventDirName string
	Go           func(func())
}

type Watcher

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

func (Watcher) Event

func (w Watcher) Event() <-chan struct{}