subsystem

Documentation

Index

• type Binding
  • func NewBinding(bus *servicebus.ServiceBus, logger *logger.Logger, bindings *binding.Bindings) (*Binding, error)
  • func (b *Binding) Close()
  • func (b *Binding) Start() error
• type Call
  • func NewCall(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, ...) (*Call, error)
  • func (c *Call) Start() error
• type CallbackMessage
• type Event
  • func NewEvent(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger) (*Event, error)
  • func (e *Event) RegisterListener(eventName string, callback func(...interface{}), counter int)
  • func (e *Event) Start() error
• type Log
  • func NewLog(bus *servicebus.ServiceBus, logger *logger.Logger) (*Log, error)
  • func (l *Log) Close()
  • func (l *Log) Start() error
• type Menu
  • func NewMenu(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, ...) (*Menu, error)
  • func (m *Menu) Start() error
• type Runtime
  • func NewRuntime(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, ...) (*Runtime, error)
  • func (r *Runtime) Start() error
• type URL
  • func NewURL(bus *servicebus.ServiceBus, logger *logger.Logger, ...) (*URL, error)
  • func (u *URL) Close()
  • func (u *URL) Start() error

Types

type Binding

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

Binding is the Binding subsystem. It manages all service bus messages starting with "binding".

func NewBinding

func NewBinding(bus *servicebus.ServiceBus, logger *logger.Logger, bindings *binding.Bindings) (*Binding, error)

NewBinding creates a new binding subsystem. Uses the given bindings db for reference.

func (*Binding) Close

func (b *Binding) Close()

func (*Binding) Start

func (b *Binding) Start() error

Start the subsystem

type Call

type Call struct {

	// bindings DB
	DB *binding.DB
	// contains filtered or unexported fields
}

Call is the Call subsystem. It manages all service bus messages starting with "call".

func NewCall

func NewCall(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, DB *binding.DB) (*Call, error)

NewCall creates a new call subsystem

func (*Call) Start

func (c *Call) Start() error

Start the subsystem

type CallbackMessage

type CallbackMessage struct {
	Result     interface{} `json:"result"`
	Err        string      `json:"error"`
	CallbackID string      `json:"callbackid"`
}

CallbackMessage defines a message that contains the result of a call

type Event

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

Event is the Eventing subsystem. It manages all service bus messages starting with "event".

func NewEvent

func NewEvent(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger) (*Event, error)

NewEvent creates a new log subsystem

func (*Event) RegisterListener

func (e *Event) RegisterListener(eventName string, callback func(...interface{}), counter int)

RegisterListener provides a means of subscribing to events of type "eventName"

func (*Event) Start

func (e *Event) Start() error

Start the subsystem

type Log

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

Log is the Logging subsystem. It handles messages with topics starting with "log:"

func NewLog

func NewLog(bus *servicebus.ServiceBus, logger *logger.Logger) (*Log, error)

NewLog creates a new log subsystem

func (*Log) Close

func (l *Log) Close()

func (*Log) Start

func (l *Log) Start() error

Start the subsystem

type Menu

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

Menu is the subsystem that handles the operation of menus. It manages all service bus messages starting with "menu".

func NewMenu

func NewMenu(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, menuManager *menumanager.Manager) (*Menu, error)

NewMenu creates a new menu subsystem

func (*Menu) Start

func (m *Menu) Start() error

Start the subsystem

type Runtime

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

Runtime is the Runtime subsystem. It handles messages with topics starting with "runtime:"

func NewRuntime

func NewRuntime(ctx context.Context, bus *servicebus.ServiceBus, logger *logger.Logger, startupCallback func(context.Context)) (*Runtime, error)

NewRuntime creates a new runtime subsystem

func (*Runtime) Start

func (r *Runtime) Start() error

Start the subsystem

type URL

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

URL is the URL Handler subsystem. It handles messages with topics starting with "url:"

func NewURL

func NewURL(bus *servicebus.ServiceBus, logger *logger.Logger, handlers map[string]func(string)) (*URL, error)

NewURL creates a new log subsystem

func (*URL) Close

func (u *URL) Close()

func (*URL) Start

func (u *URL) Start() error

Start the subsystem