telemetry

Documentation

Index

• func NewTelemetry() (t2 *Telemetry, t1 ITelemetry)
• type Device
• type ITelemetry
• type Node
• type Telemetry
  • func (t *Telemetry) Broadcast(param interface{})
  • func (t *Telemetry) BroadcastOne(param interface{})
  • func (s *Telemetry) Subscribe(command string, f ITelemetry)
  • func (s *Telemetry) UnSubscribe(command string)
• type WorkflowScenario

Functions

func NewTelemetry

func NewTelemetry() (t2 *Telemetry, t1 ITelemetry)

Types

type Device

type Device struct {
	Id          int64
	ElementName string
}

type ITelemetry

type ITelemetry interface {
	Broadcast(interface{})
	BroadcastOne(interface{})
}

type Node

type Node struct{}

type Telemetry

type Telemetry struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Telemetry) Broadcast

func (t *Telemetry) Broadcast(param interface{})

func (*Telemetry) BroadcastOne

func (t *Telemetry) BroadcastOne(param interface{})

func (*Telemetry) Subscribe

func (s *Telemetry) Subscribe(command string, f ITelemetry)

func (*Telemetry) UnSubscribe

func (s *Telemetry) UnSubscribe(command string)

type WorkflowScenario

type WorkflowScenario struct {
	WorkflowId int64
	ScenarioId int64
}