chik

Oct 3, 2023

Changes in this version

type StatusHolder

+ func (s *StatusHolder) Get() interface{}

Jan 29, 2022

Changes in this version

+ func StartRemote(controller *Controller, conn net.Conn, readTimeout time.Duration) (context.Context, context.CancelFunc)

type Controller

+ func (c *Controller) Unsub(subscription chan interface{})

Dec 13, 2021

Changes in this version

type BaseHandler

+ func (s *BaseHandler) HandleChannelEvent(event interface{}, controller *Controller)

type Handler

+ HandleChannelEvent func(event interface{}, controller *Controller)

+ type Interrupts struct

+ Event <-chan interface{}

+ Timer Timer

type Timer

+ func NewStartupActionTimer() Timer

May 13, 2021

Changes in this version

+ type BaseHandler struct

+ func (s *BaseHandler) Dependencies() []string

+ func (s *BaseHandler) HandleMessage(message *Message, controller *Controller) error

+ func (s *BaseHandler) HandleTimerEvent(tick time.Time, controller *Controller)

+ func (s *BaseHandler) Setup(controller *Controller) (Timer, error)

+ func (s *BaseHandler) String() string

+ func (s *BaseHandler) Teardown()

+ func (s *BaseHandler) Topics() []types.CommandType

Jun 9, 2020

Changes in this version

type Handler

+ Dependencies func() []string

+ HandleMessage func(message *Message, controller *Controller) error

+ HandleTimerEvent func(tick time.Time, controller *Controller)

+ Setup func(controller *Controller) Timer

+ Teardown func()

+ Topics func() []types.CommandType

+ type Timer struct

+ func NewEmptyTimer() Timer

+ func NewTimer(interval time.Duration, triggerAtStart bool) Timer

Apr 17, 2019

Changes in this version

+ const BufferSize

+ const IncomingMessage

+ const MaxIdleTime

+ const OutgoingMessage

+ const WriteTimeout

+ var LoopbackID = uuid.Nil

+ func Equal(v1, v2 *Message) bool

+ type Controller struct

+ ID uuid.UUID

+ func NewController() *Controller

+ func (c *Controller) Connect(connection net.Conn) <-chan bool

+ func (c *Controller) Disconnect()

+ func (c *Controller) Pub(command *types.Command, receiverID uuid.UUID)

+ func (c *Controller) PubMessage(message *Message, topics ...string)

+ func (c *Controller) Reply(request *Message, replyType types.CommandType, replyContent interface{})

+ func (c *Controller) Shutdown()

+ func (c *Controller) Start(h Handler)

+ func (c *Controller) Sub(topics ...string) chan interface{}

+ func (c *Controller) SubOnce(topics ...string) chan interface{}

+ type Handler interface

+ Run func(controller *Controller)

+ type Message struct

+ func NewMessage(receiver uuid.UUID, command *types.Command) *Message

+ func ParseMessage(reader io.Reader) (*Message, error)

+ func (m *Message) Bytes() []byte

+ func (m *Message) Command() *types.Command

+ func (m *Message) ReceiverUUID() (uuid.UUID, error)

+ func (m *Message) SenderUUID() uuid.UUID

+ func (m Message) String() string

+ type Remote struct

+ Closed chan bool

+ func (r *Remote) Terminate()

+ type StatusHolder struct

+ func NewStatusHolder(moduleName string) *StatusHolder

+ func (s *StatusHolder) Edit(controller *Controller, editFunction func(interface{}) interface{})

+ func (s *StatusHolder) Set(status interface{}, controller *Controller)