runtime

Documentation

Index

• Constants
• Variables
• func NewCountValue() interface{}
• func NewCounter() runtime.NodeIFace
• func NewDelay() runtime.NodeIFace
• func NewGPIOState() interface{}
• func NewLamp() runtime.NodeIFace
• func NewMultioutPushListener() runtime.NodeIFace
• func NewPushEvent() interface{}
• func NewRouter() runtime.NodeIFace
• func NewSimplePushListener() runtime.NodeIFace
• func NewStatefulLamp() runtime.NodeIFace
• func NewTestResponse() interface{}
• func TestMain(m *testing.M)
• type CountValue
• type Counter
  • func (cnt *Counter) CountUp(param runtime.FuncParams) runtime.MessageIFace
  • func (cnt *Counter) Get(message runtime.MessageIFace) runtime.MessageIFace
  • func (cnt *Counter) Init()
  • func (cnt *Counter) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (cnt *Counter) Set(message runtime.MessageIFace)
  • func (cnt *Counter) SetMaxCount(maxCount int)
• type Delay
  • func (d *Delay) Init()
  • func (d *Delay) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
• 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 MultioutPushListener
  • func (mopl *MultioutPushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (mopl *MultioutPushListener) 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 Router
  • func (rtr *Router) Init()
  • func (rtr *Router) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
• type SimplePushListener
  • func (spl *SimplePushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
  • func (spl *SimplePushListener) Init()
• type StatefulLamp
  • func (sflmp *StatefulLamp) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace
• type TestResponse

Constants

const MAX_WORKERS = 100

const POOL_SIZE = 50

const WORKERS_TO_BE_READY = 50

Variables

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

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

Functions

func NewCountValue

func NewCountValue() interface{}

func NewCounter

func NewCounter() runtime.NodeIFace

func NewDelay

func NewDelay() runtime.NodeIFace

func NewGPIOState

func NewGPIOState() interface{}

func NewLamp

func NewLamp() runtime.NodeIFace

func NewMultioutPushListener

func NewMultioutPushListener() runtime.NodeIFace

func NewPushEvent

func NewPushEvent() interface{}

func NewRouter

func NewRouter() runtime.NodeIFace

func NewSimplePushListener

func NewSimplePushListener() runtime.NodeIFace

func NewStatefulLamp

func NewStatefulLamp() runtime.NodeIFace

func NewTestResponse

func NewTestResponse() interface{}

func TestMain

func TestMain(m *testing.M)

Types

type CountValue

type CountValue struct {
	Count int
}

type Counter

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

func (*Counter) CountUp

func (cnt *Counter) CountUp(param runtime.FuncParams) runtime.MessageIFace

func (*Counter) Get

func (cnt *Counter) Get(message runtime.MessageIFace) runtime.MessageIFace

func (*Counter) Init

func (cnt *Counter) Init()

func (*Counter) Run

func (cnt *Counter) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*Counter) Set

func (cnt *Counter) Set(message runtime.MessageIFace)

func (*Counter) SetMaxCount

func (cnt *Counter) SetMaxCount(maxCount int)

type Delay

type Delay struct {
	nodes.BasicNode
}

func (*Delay) Init

func (d *Delay) Init()

func (*Delay) Run

func (d *Delay) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

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 MultioutPushListener

type MultioutPushListener struct {
	PushListener
}

func (*MultioutPushListener) CallLogic

func (mopl *MultioutPushListener) CallLogic(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

func (*MultioutPushListener) Init

func (mopl *MultioutPushListener) 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 Router

type Router struct {
	nodes.BasicNode
}

func (*Router) Init

func (rtr *Router) Init()

func (*Router) Run

func (rtr *Router) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

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()

type StatefulLamp

type StatefulLamp struct {
	Lamp
}

func (*StatefulLamp) Run

func (sflmp *StatefulLamp) Run(runner *runtime.Runner, message runtime.MessageIFace) runtime.MessageIFace

type TestResponse

type TestResponse struct {
	WasSuccess bool
}