internal

Documentation

Index

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

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) ChannelNamePrefix

func (eb *EventBus) ChannelNamePrefix() string

func (*EventBus) Close

func (eb *EventBus) Close() error

func (*EventBus) Init

func (eb *EventBus) Init(pubSub *redis.PubSub, options EventBusOptions) *EventBus

func (*EventBus) IsClosed

func (eb *EventBus) IsClosed() bool

func (*EventBus) RemoveWatcher

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

type EventBusOptions

type EventBusOptions struct {
	ChannelNamePrefix            string
	MaxNumberOfIdleSubscriptions int
	IdleSubscriptionTimeout      time.Duration
	Go                           func(func())
}

type Watcher

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

func (Watcher) Event

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

func (Watcher) EventArgs

func (w Watcher) EventArgs() EventArgs