eventbus

Documentation

Index

• type EventBus
  • func (*EventBus) Forward(target provider.Target, data interface{}) (response interface{}, err error)
  • func (eb *EventBus) GoToTarget(data map[string]interface{}, stop chan struct{}) (interface{}, error)
  • func (eb *EventBus) Name() string
  • func (eb *EventBus) RegisterListener(handle listener.Handle) error
  • func (eb *EventBus) UnregisterListener()

Types

type EventBus

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

func (*EventBus) Forward

func (*EventBus) Forward(target provider.Target, data interface{}) (response interface{}, err error)

func (*EventBus) GoToTarget

func (eb *EventBus) GoToTarget(data map[string]interface{}, stop chan struct{}) (interface{}, error)

func (*EventBus) Name

func (eb *EventBus) Name() string

func (*EventBus) RegisterListener

func (eb *EventBus) RegisterListener(handle listener.Handle) error

func (*EventBus) UnregisterListener

func (eb *EventBus) UnregisterListener()