bus

Documentation

Index

• Constants
• type Bus
  • func New(n int) *Bus
  • func (b *Bus) DumpState() [][]string
  • func (b *Bus) Register(queues []string) (chan Event, int, error)
  • func (b *Bus) Send(event, typ string, thing interface{}, queues ...string)
  • func (b *Bus) SendError(err error, queues ...string)
  • func (b *Bus) SendEvent(queues []string, ev Event)
  • func (b *Bus) Unregister(idx int) error
• type Event

Constants

const (
	ErrorEvent            = "error"
	UnlockCoreEvent       = "unlock-core"
	CreateObjectEvent     = "create-object"
	UpdateObjectEvent     = "update-object"
	DeleteObjectEvent     = "delete-object"
	TaskStatusUpdateEvent = "task-status-update"
	TaskLogUpdateEvent    = "task-log-update"
	TenantInviteEvent     = "tenant-invite"
	TenantBanishEvent     = "tenant-banish"
)

Types

type Bus

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

func New

func New(n int) *Bus

func (*Bus) DumpState

func (b *Bus) DumpState() [][]string

func (*Bus) Register

func (b *Bus) Register(queues []string) (chan Event, int, error)

func (*Bus) Send

func (b *Bus) Send(event, typ string, thing interface{}, queues ...string)

func (*Bus) SendError

func (b *Bus) SendError(err error, queues ...string)

func (*Bus) SendEvent

func (b *Bus) SendEvent(queues []string, ev Event)

func (*Bus) Unregister

func (b *Bus) Unregister(idx int) error

type Event

type Event struct {
	Event string      `json:"event"`
	Queue string      `json:"queue"`
	Type  string      `json:"type,omitempty"`
	Data  interface{} `json:"data"`
}