mq

Documentation

Index

• Constants
• Variables
• func CreateNetworkReceiverFlow(ctx *runtime.Context, mq mqueue.MessageQueueIFace) *runtime.Flow
• func CreateNetworkSenderFlow(ctx *runtime.Context, mq mqueue.MessageQueueIFace) *runtime.Flow
• func NewGPIOState() interface{}
• func NewLamp() runtime.NodeIFace
• func NewNetworkPushListener() runtime.NodeIFace
• func NewPushEvent() interface{}
• func NewSimplePushListener() runtime.NodeIFace
• type GPIOState
• type Interval
• type Lamp
  • func (lmp *Lamp) Get(message runtime.MessageIFace) runtime.MessageIFace
  • func (lmp *Lamp) Init()
  • func (lmp *Lamp) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (lmp *Lamp) Set(message runtime.MessageIFace)
  • func (lmp *Lamp) SetOutputGPIO(gpioNum int)
• type LogicHandlerFunc
• type MockedMQ
  • func (mmq *MockedMQ) Close()
  • func (mmq *MockedMQ) Connect(url string)
  • func (mmq *MockedMQ) GetConfig() mqueue.QueueConfig
  • func (mmq *MockedMQ) Receive(stopCond mqueue.StopCondFunc, recvCBFunc mqueue.RecvCallbackFunc)
  • func (mmq *MockedMQ) Send(data []byte)
  • func (mmq *MockedMQ) SetConfig(config mqueue.QueueConfig)
  • func (mmq *MockedMQ) UseTopic(topic string)
• type NetworkPushListener
  • func (npl *NetworkPushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (npl *NetworkPushListener) Init()
• type PushEvent
• type PushListener
  • func (pl *PushListener) Get(message runtime.MessageIFace) runtime.MessageIFace
  • func (pl *PushListener) Init()
  • func (pl *PushListener) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (pl *PushListener) Set(message runtime.MessageIFace)
  • func (pl *PushListener) SetActivationInterval(actIntInMS Interval)
  • func (pl *PushListener) SetLogicHandler(handlerFunc LogicHandlerFunc)
• type SimplePushListener
  • func (spl *SimplePushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (spl *SimplePushListener) Init()

Constants

const POLL_INTERVAL = 10 * time.Millisecond

Variables

var CONFIG_PATH = "../../conf.json"

var DefaultLogger = utils.NewBasicLogger(utils.LoggerConfig{Level: utils.DebugLevel}, "")

Functions

func CreateNetworkReceiverFlow

func CreateNetworkReceiverFlow(ctx *runtime.Context, mq mqueue.MessageQueueIFace) *runtime.Flow

func CreateNetworkSenderFlow

func CreateNetworkSenderFlow(ctx *runtime.Context, mq mqueue.MessageQueueIFace) *runtime.Flow

func NewGPIOState

func NewGPIOState() interface{}

func NewLamp

func NewLamp() runtime.NodeIFace

func NewNetworkPushListener

func NewNetworkPushListener() runtime.NodeIFace

func NewPushEvent

func NewPushEvent() interface{}

func NewSimplePushListener

func NewSimplePushListener() runtime.NodeIFace

Types

type GPIOState

type GPIOState struct {
	State bool
}

type Interval

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

type Lamp

type Lamp struct {
	nodes.BasicNode

	State bool
	// contains filtered or unexported fields
}

func (*Lamp) Get

func (lmp *Lamp) Get(message runtime.MessageIFace) runtime.MessageIFace

func (*Lamp) Init

func (lmp *Lamp) Init()

func (*Lamp) Run

func (lmp *Lamp) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*Lamp) Set

func (lmp *Lamp) Set(message runtime.MessageIFace)

func (*Lamp) SetOutputGPIO

func (lmp *Lamp) SetOutputGPIO(gpioNum int)

type LogicHandlerFunc

type LogicHandlerFunc func(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

type MockedMQ

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

func (*MockedMQ) Close

func (mmq *MockedMQ) Close()

func (*MockedMQ) Connect

func (mmq *MockedMQ) Connect(url string)

func (*MockedMQ) GetConfig

func (mmq *MockedMQ) GetConfig() mqueue.QueueConfig

func (*MockedMQ) Receive

func (mmq *MockedMQ) Receive(stopCond mqueue.StopCondFunc, recvCBFunc mqueue.RecvCallbackFunc)

func (*MockedMQ) Send

func (mmq *MockedMQ) Send(data []byte)

func (*MockedMQ) SetConfig

func (mmq *MockedMQ) SetConfig(config mqueue.QueueConfig)

func (*MockedMQ) UseTopic

func (mmq *MockedMQ) UseTopic(topic string)

type NetworkPushListener

type NetworkPushListener struct {
	PushListener
}

func (*NetworkPushListener) CallLogic

func (npl *NetworkPushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*NetworkPushListener) Init

func (npl *NetworkPushListener) Init()

type PushEvent

type PushEvent struct {
	PushInter int32
}

type PushListener

type PushListener struct {
	nodes.BasicNode
	// contains filtered or unexported fields
}

func (*PushListener) Get

func (pl *PushListener) Get(message runtime.MessageIFace) runtime.MessageIFace

func (*PushListener) Init

func (pl *PushListener) Init()

func (*PushListener) Run

func (pl *PushListener) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*PushListener) Set

func (pl *PushListener) Set(message runtime.MessageIFace)

func (*PushListener) SetActivationInterval

func (pl *PushListener) SetActivationInterval(actIntInMS Interval)

func (*PushListener) SetLogicHandler

func (pl *PushListener) SetLogicHandler(handlerFunc LogicHandlerFunc)

type SimplePushListener

type SimplePushListener struct {
	PushListener
}

func (*SimplePushListener) CallLogic

func (spl *SimplePushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*SimplePushListener) Init

func (spl *SimplePushListener) Init()