core

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2020 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Started ...
	Started = Status("started")
	// InProcess ...
	InProcess = Status("in process")
	// Ended ...
	Ended = Status("ended")
	// Done ...
	Done = Status("done")
	// Error ...
	Error = Status("error")
)

Variables

This section is empty.

Functions

func NewCron 

func NewCron() (cron *cr.Cron)

NewCron ...

Types

type Action 

type Action struct {
	Device *m.Device
	Node   *Node

	ScriptEngine *scripts.Engine
	// contains filtered or unexported fields
}

Action ...

func NewAction 

func NewAction(device *m.Device,
	deviceAction *m.DeviceAction,
	node *Node,
	flow *Flow,
	scriptService *scripts.ScriptService,
	mqtt *mqtt.Mqtt,
	adaptors *adaptors.Adaptors,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) (action *Action, err error)

NewAction ...

func (*Action) Do 

func (a *Action) Do() (res string, err error)

Do ...

func (*Action) GetDevice 

func (a *Action) GetDevice() *m.Device

GetDevice ...

type ActionBind 

type ActionBind struct {
	Id          int64
	Name        string
	Description string
	// contains filtered or unexported fields
}

Javascript Binding

Action 

.Id
.Name
.Description
.Device()

func NewActionBind added in v0.2.0 

func NewActionBind(id int64, name, desc string, action *Action) *ActionBind

NewActionBind ...

func (*ActionBind) Device 

func (a *ActionBind) Device() *DeviceBind

Device ...

type ActionPrototypes 

type ActionPrototypes interface {
	After(*Flow) error
	Run(*Flow) error
	Before(*Flow) error
	Type() string
}

ActionPrototypes ...

type Core 

type Core struct {
	sync.Mutex

	Map *Map
	// contains filtered or unexported fields
}

Core ...

func NewCore 

func NewCore(adaptors *adaptors.Adaptors,
	scripts *scripts.ScriptService,
	graceful *graceful_service.GracefulService,
	cron *cr.Cron,
	mqtt *mqtt.Mqtt,
	streamService *stream.StreamService,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt,
	metric *metrics.MetricManager) (core *Core, err error)

NewCore ...

func (*Core) AddFlow 

func (c *Core) AddFlow(flow *m.Flow) (err error)

AddFlow ...

func (*Core) AddNode 

func (c *Core) AddNode(node *m.Node) (n *Node, err error)

AddNode ...

func (*Core) AddWorkflow 

func (b *Core) AddWorkflow(workflow *m.Workflow) (err error)

добавление рабочего процесс

func (*Core) DeleteWorkflow 

func (c *Core) DeleteWorkflow(workflow *m.Workflow) (err error)

нельзя удалить workflow, если присутствуют связанные сущности

func (*Core) DoAction added in v0.3.0 

func (c *Core) DoAction(deviceActionId int64) (result string, err error)

DoAction ...

func (*Core) DoWorker 

func (b *Core) DoWorker(worker *m.Worker) (err error)

DoWorker ...

func (*Core) GetFlow 

func (c *Core) GetFlow(id int64) (*Flow, error)

GetFlow ...

func (*Core) GetNodeById 

func (c *Core) GetNodeById(nodeId int64) *Node

GetNodeById ...

func (*Core) GetNodes 

func (b *Core) GetNodes() (nodes map[int64]*Node)

GetNodes ...

func (*Core) GetWorkflow 

func (b *Core) GetWorkflow(workflowId int64) (workflow *Workflow, err error)

GetWorkflow ...

func (*Core) InitWorkflows 

func (b *Core) InitWorkflows() (err error)

инициализация всего рабочего процесса, с запуском дочерни подпроцессов

func (*Core) ReloadNode 

func (c *Core) ReloadNode(node *m.Node) (err error)

ReloadNode ...

func (*Core) RemoveFlow 

func (c *Core) RemoveFlow(flow *m.Flow) error

RemoveFlow ...

func (*Core) RemoveNode 

func (b *Core) RemoveNode(node *m.Node) (err error)

RemoveNode ...

func (*Core) RemoveWorker 

func (b *Core) RemoveWorker(worker *m.Worker) (err error)

RemoveWorker ...

func (*Core) Run 

func (c *Core) Run() (err error)

Run ...

func (*Core) Shutdown 

func (b *Core) Shutdown()

Shutdown ...

func (*Core) Stop 

func (b *Core) Stop() (err error)

Stop ...

func (*Core) UpdateFlow 

func (c *Core) UpdateFlow(flow *m.Flow) error

UpdateFlow ...

func (*Core) UpdateFlowFromDevice 

func (b *Core) UpdateFlowFromDevice(device *m.Device) (err error)

UpdateFlowFromDevice ...

func (*Core) UpdateWorker 

func (b *Core) UpdateWorker(_worker *m.Worker) (err error)

UpdateWorker ...

func (*Core) UpdateWorkflow 

func (c *Core) UpdateWorkflow(workflow *m.Workflow) (err error)

UpdateWorkflow ...

func (*Core) UpdateWorkflowScenario 

func (c *Core) UpdateWorkflowScenario(workflowId int64) (err error)

UpdateWorkflowScenario ...

type Device 

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

Device ...

func NewDevice added in v0.2.0 

func NewDevice(dev *m.Device, node *Node, mqtt *mqtt.Mqtt,
	adaptors *adaptors.Adaptors, zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) *Device

NewDevice ...

func (Device) ModBus added in v0.0.19 

func (d Device) ModBus(f string, address, count uint16, command []uint16) (result DevModBusResponse)

ModBus ...

func (Device) Mqtt added in v0.2.0 

func (d Device) Mqtt(path string, payload []byte) (result DevMqttResponse)

Mqtt ...

func (Device) RunCommand 

func (d Device) RunCommand(name string, args []string) (result DevCommandResponse)

run command

func (Device) SmartBus 

func (d Device) SmartBus(command []byte) (result DevSmartBusResponse)

SmartBus ...

func (Device) Zigbee2mqtt added in v0.2.0 

func (d Device) Zigbee2mqtt(path string, payload []byte) (result DevZigbee2mqttResponse)

Zigbee2mqtt ...

type DeviceBind 

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

Javascript Binding

Device 

.GetName()
.GetModel()
.GetDescription()
.RunCommand(command []string)
.SmartBus(command []byte)
.ModBus(func string, address, count int64, command []byte)
.Zigbee2mqtt(path, payload)
.Mqtt(path, payload)
.Send(params interface)

func NewDeviceBind added in v0.2.0 

func NewDeviceBind(model *m.Device, node *Node, mqtt *mqtt.Mqtt, adaptors *adaptors.Adaptors, zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) *DeviceBind

NewDeviceBind ...

func (*DeviceBind) GetDescription 

func (d *DeviceBind) GetDescription() string

GetDescription ...

func (*DeviceBind) GetModel 

func (d *DeviceBind) GetModel() *m.Device

GetModel ...

func (*DeviceBind) GetName 

func (d *DeviceBind) GetName() string

GetName ...

func (*DeviceBind) ModBus 

func (d *DeviceBind) ModBus(f string, address, count uint16, command []uint16) (result DevModBusResponse)

ModBus ...

func (*DeviceBind) Mqtt added in v0.2.0 

func (d *DeviceBind) Mqtt(path string, payload []byte) (result DevMqttResponse)

Mqtt ...

func (*DeviceBind) RunCommand 

func (d *DeviceBind) RunCommand(name string, args []string) (result DevCommandResponse)

RunCommand ...

func (*DeviceBind) Send added in v0.2.0 

func (d *DeviceBind) Send(payload interface{}) (result interface{})

Send ...

func (*DeviceBind) SmartBus 

func (d *DeviceBind) SmartBus(command []byte) (result DevSmartBusResponse)

SmartBus ...

func (*DeviceBind) Zigbee2mqtt added in v0.2.0 

func (d *DeviceBind) Zigbee2mqtt(path string, payload []byte) (result DevZigbee2mqttResponse)

Zigbee2mqtt ...

type Flow 

type Flow struct {
	Storage
	Model *m.Flow

	Connections  []*m.Connection
	FlowElements []*FlowElement

	Node *Node

	sync.Mutex

	Workers map[int64]*Worker
	// contains filtered or unexported fields
}

Flow ...

func NewFlow 

func NewFlow(model *m.Flow,
	workflow *Workflow,
	adaptors *adaptors.Adaptors,
	scripts *scripts.ScriptService,
	cron *cr.Cron,
	core *Core,
	mqtt *mqtt.Mqtt,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) (flow *Flow, err error)

NewFlow ...

func (*Flow) AddWorker 

func (f *Flow) AddWorker(model *m.Worker) (err error)

AddWorker ...

func (*Flow) GetMessage added in v0.0.25 

func (f *Flow) GetMessage() *Message

GetMessage ...

func (*Flow) InitWorkers 

func (f *Flow) InitWorkers() (err error)

InitWorkers ...

func (*Flow) NewMessage 

func (f *Flow) NewMessage(ctx context.Context) (err error)

NewMessage ...

func (*Flow) NewScript 

func (f *Flow) NewScript(s ...*m.Script) (engine *scripts.Engine, err error)

NewScript ...

func (*Flow) Remove 

func (f *Flow) Remove()

Remove ...

func (*Flow) RemoveWorker 

func (f *Flow) RemoveWorker(worker *m.Worker) (err error)

RemoveWorker ...

func (*Flow) SetMessage added in v0.0.25 

func (f *Flow) SetMessage(msg *Message)

SetMessage ...

func (*Flow) UpdateWorker 

func (f *Flow) UpdateWorker(worker *m.Worker) (err error)

UpdateWorker ...

type FlowBind 

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

Javascript Binding

Flow 

.GetName()
.GetDescription()
.SetVar(string, interface)
.GetVar(string)
.Node()

func (*FlowBind) GetDescription 

func (f *FlowBind) GetDescription() string

GetDescription ...

func (*FlowBind) GetName 

func (f *FlowBind) GetName() string

GetName ...

func (*FlowBind) GetVar 

func (f *FlowBind) GetVar(key string) interface{}

GetVar ...

func (*FlowBind) Node 

func (f *FlowBind) Node() *NodeBind

Node ...

func (*FlowBind) SetVar 

func (f *FlowBind) SetVar(key string, value interface{})

SetVar ...

type FlowElement 

type FlowElement struct {
	Model        *m.FlowElement
	Flow         *Flow
	Workflow     *Workflow
	ScriptEngine *scripts.Engine
	Prototype    ActionPrototypes

	Action *Action
	// contains filtered or unexported fields
}

FlowElement ...

func NewFlowElement 

func NewFlowElement(model *m.FlowElement,
	flow *Flow,
	workflow *Workflow,
	adaptors *adaptors.Adaptors) (flowElement *FlowElement, err error)

NewFlowElement ...

func (*FlowElement) After 

func (f *FlowElement) After() error

After ...

func (*FlowElement) Before 

func (f *FlowElement) Before(ctx context.Context) (newCtx context.Context, err error)

Before ...

func (*FlowElement) GetStatus 

func (f *FlowElement) GetStatus() (status Status)

GetStatus ...

func (*FlowElement) Run 

func (f *FlowElement) Run(ctx context.Context) (newCtx context.Context, b bool, err error)

run internal process 

type FlowLink struct{}

ActionPrototypes

func (*FlowLink) After 

func (m *FlowLink) After(flow *Flow) (err error)

After ...

func (*FlowLink) Before 

func (m *FlowLink) Before(flow *Flow) (err error)

Before ...

func (*FlowLink) Run 

func (m *FlowLink) Run(flow *Flow) (err error)

Run ...

func (*FlowLink) Type 

func (m *FlowLink) Type() string

Type ...

type Gateway 

type Gateway struct{}

ActionPrototypes

func (*Gateway) After 

func (m *Gateway) After(flow *Flow) (err error)

After ...

func (*Gateway) Before 

func (m *Gateway) Before(flow *Flow) (err error)

Before ...

func (*Gateway) Run 

func (m *Gateway) Run(flow *Flow) (err error)

Run ...

func (*Gateway) Type 

func (m *Gateway) Type() string

Type ...

type Map 

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

Map ...

func NewMap added in v0.1.2 

func NewMap(metric *metrics.MetricManager,
	adaptors *adaptors.Adaptors) *Map

NewMap ...

func (*Map) GetElement 

func (b *Map) GetElement(elementName string) (element *MapElement, err error)

GetElement ...

func (*Map) NewMapElement 

func (b *Map) NewMapElement(elementName string, stateSystemName *string) (*MapElement, error)

NewMapElement ...

func (*Map) SetElementState 

func (b *Map) SetElementState(elementName, stateSystemName string)

SetElementState ...

type MapBind 

type MapBind struct {
	Map *Map
}

Javascript Binding

Map 

.SetElementState(elementName, newState)
.GetElement(elementName) -> MapElementBind

func (*MapBind) GetElement 

func (e *MapBind) GetElement(elementName string) (element *MapElementBind)

GetElement ...

func (*MapBind) SetElementState 

func (e *MapBind) SetElementState(elementName, newState string)

SetElementState ...

type MapElement 

type MapElement struct {
	Map     *Map
	Options interface{}
	State   *m.DeviceState
	// contains filtered or unexported fields
}

MapElement ...

func NewMapElement added in v0.2.0 

func NewMapElement(elementName string,
	systemName *string,
	_map *Map,
	adaptors *adaptors.Adaptors) (*MapElement, error)

NewMapElement ...

func (*MapElement) CustomHistory added in v0.2.0 

func (e *MapElement) CustomHistory(logLevel, t, desc string)

CustomHistory ...

func (*MapElement) GetOptions 

func (e *MapElement) GetOptions() interface{}

GetOptions ...

func (*MapElement) GetState 

func (e *MapElement) GetState() interface{}

GetState ...

func (*MapElement) SetOptions 

func (e *MapElement) SetOptions(options interface{})

SetOptions ...

func (*MapElement) SetState 

func (e *MapElement) SetState(systemName string)

SetState ...

type MapElementBind 

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

Javascript Binding

MapElement 

.SetState(name)
.GetState()
.SetOptions(options)
.GetOptions()
.Story(logLevel, type, description)

func (*MapElementBind) GetOptions 

func (e *MapElementBind) GetOptions() interface{}

GetOptions ...

func (*MapElementBind) GetState 

func (e *MapElementBind) GetState() interface{}

GetState ...

func (*MapElementBind) SetOptions 

func (e *MapElementBind) SetOptions(options interface{})

SetOptions ...

func (*MapElementBind) SetState 

func (e *MapElementBind) SetState(name string)

SetState ...

func (*MapElementBind) Story added in v0.2.0 

func (e *MapElementBind) Story(logLevel, t, desc string)

Story ...

type Message 

type Message struct {
	Error string

	Success   bool
	Direction bool
	Mqtt      bool
	// contains filtered or unexported fields
}

Message ...

func NewMessage 

func NewMessage() (m *Message)

NewMessage ...

func (*Message) Clear 

func (m *Message) Clear()

Clear ...

func (*Message) Copy 

func (m *Message) Copy() (msg *Message)

Copy ...

func (*Message) GetVar added in v0.0.21 

func (m *Message) GetVar(key string) (value interface{})

GetVar ...

func (*Message) Ok 

func (m *Message) Ok()

Ok ...

func (*Message) SetError 

func (m *Message) SetError(err string)

SetError ...

func (*Message) SetVar added in v0.0.21 

func (m *Message) SetVar(key string, value interface{})

SetVar ...

func (*Message) Setdir 

func (m *Message) Setdir(d bool)

Setdir ...

func (*Message) Update added in v0.0.25 

func (m *Message) Update(newMsg *Message)

Update ...

type MessageEmitter 

type MessageEmitter struct{}

ActionPrototypes

func (*MessageEmitter) After 

func (m *MessageEmitter) After(flow *Flow) (err error)

After ...

func (*MessageEmitter) Before 

func (m *MessageEmitter) Before(flow *Flow) (err error)

Before ...

func (*MessageEmitter) Run 

func (m *MessageEmitter) Run(flow *Flow) (err error)

Run ...

func (*MessageEmitter) Type 

func (m *MessageEmitter) Type() string

Type ...

type MessageHandler 

type MessageHandler struct{}

ActionPrototypes

func (*MessageHandler) After 

func (m *MessageHandler) After(flow *Flow) (err error)

After ...

func (*MessageHandler) Before 

func (m *MessageHandler) Before(flow *Flow) (err error)

Before ...

func (*MessageHandler) Run 

func (m *MessageHandler) Run(flow *Flow) (err error)

Run ...

func (*MessageHandler) Type 

func (m *MessageHandler) Type() string

Type ...

type Node 

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

Node ...

func NewNode 

func NewNode(model *m.Node,
	mqtt *mqtt.Mqtt,
	metric *metrics.MetricManager) *Node

NewNode ...

func (*Node) Connect 

func (n *Node) Connect() *Node

Connect ...

func (*Node) GetConnStatus added in v0.0.25 

func (n *Node) GetConnStatus() string

GetConnStatus ...

func (*Node) GetStat added in v0.0.25 

func (n *Node) GetStat() NodeStat

GetStat ...

func (*Node) IsConnected 

func (n *Node) IsConnected() bool

IsConnected ...

func (*Node) Model added in v0.2.0 

func (n *Node) Model() *m.Node

Model ...

func (*Node) MqttPublish added in v0.0.21 

func (n *Node) MqttPublish(topic string, msg interface{})

MqttPublish ...

func (*Node) Remove added in v0.0.25 

func (n *Node) Remove()

Remove ...

func (*Node) Send 

func (n *Node) Send(device *m.Device, command []byte) (result NodeResponse, err error)

Send ...

func (*Node) UpdateClientParams added in v0.0.25 

func (n *Node) UpdateClientParams(params *m.Node)

UpdateClientParams ...

type NodeBind 

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

Javascript Binding

Node 

.Name()
.Status()
.Stat()
.Description()
.IsConnected()

func (*NodeBind) Description 

func (n *NodeBind) Description() string

Description ...

func (*NodeBind) IsConnected 

func (n *NodeBind) IsConnected() bool

IsConnected ...

func (*NodeBind) Name 

func (n *NodeBind) Name() string

Name ...

func (*NodeBind) Stat 

func (n *NodeBind) Stat() NodeStat

Stat ...

func (*NodeBind) Status 

func (n *NodeBind) Status() string

Status ...

type NodeMessage 

type NodeMessage struct {
	DeviceId   int64             `json:"device_id"`
	DeviceType common.DeviceType `json:"device_type"`
	Properties json.RawMessage   `json:"properties"`
	Command    json.RawMessage   `json:"command"`
}

NodeMessage ...

type NodeResponse 

type NodeResponse struct {
	DeviceId   int64             `json:"device_id"`
	DeviceType common.DeviceType `json:"device_type"`
	Properties json.RawMessage   `json:"properties"`
	Response   json.RawMessage   `json:"response"`
	Status     string            `json:"status"`
	Time       float64           `json:"time"`
}

NodeResponse ...

type NodeStat added in v0.0.25 

type NodeStat struct {
	Status      NodeStatus `json:"status"`
	Thread      int        `json:"thread"`
	Rps         int64      `json:"rps"`
	Min         int64      `json:"min"`
	Max         int64      `json:"max"`
	StartedAt   time.Time  `json:"started_at"`
	LastPing    time.Time  `json:"last_ping"`
	ConnStatus  string     `json:"conn_status"`
	IsConnected bool       `json:"is_connected"`
}

NodeStat ...

type NodeStatModel 

type NodeStatModel struct {
	Status    NodeStatus `json:"status"`
	Thread    int        `json:"thread"`
	Rps       int64      `json:"rps"`
	Min       int64      `json:"min"`
	Max       int64      `json:"max"`
	StartedAt time.Time  `json:"started_at"`
}

NodeStatModel ...

type NodeStatus 

type NodeStatus string

NodeStatus ...

type Nodes 

type Nodes []*Node

Nodes ...

type Status 

type Status string

Status ...

type Storage 

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

Storage ...

func NewStorage added in v0.0.17 

func NewStorage() Storage

NewStorage ...

func (*Storage) GetVar 

func (s *Storage) GetVar(key string) (value interface{})

GetVar ...

func (*Storage) SetVar 

func (s *Storage) SetVar(key string, value interface{})

SetVar ...

type Task 

type Task struct{}

ActionPrototypes

func (*Task) After 

func (m *Task) After(flow *Flow) (err error)

After ...

func (*Task) Before 

func (m *Task) Before(flow *Flow) (err error)

Before ...

func (*Task) Run 

func (m *Task) Run(flow *Flow) (err error)

Run ...

func (*Task) Type 

func (m *Task) Type() string

Type ...

type Worker 

type Worker struct {
	Model *m.Worker

	CronTask *cr.Task
	// contains filtered or unexported fields
}

Worker ...

func NewWorker 

func NewWorker(model *m.Worker, flow *Flow, cron *cr.Cron) (worker *Worker)

NewWorker ...

func (*Worker) AddAction 

func (w *Worker) AddAction(action *Action)

AddAction ...

func (*Worker) Do 

func (w *Worker) Do()

Run worker script, and send result to flow as message struct

func (*Worker) Start added in v0.0.17 

func (w *Worker) Start()

Start ...

func (*Worker) Stop added in v0.0.17 

func (w *Worker) Stop()

Stop ...

type Workflow 

type Workflow struct {
	Storage
	sync.Mutex

	Flows map[int64]*Flow
	// contains filtered or unexported fields
}

Workflow ...

func NewWorkflow 

func NewWorkflow(model *m.Workflow,
	adaptors *adaptors.Adaptors,
	scripts *scripts.ScriptService,
	cron *cr.Cron,
	core *Core,
	mqtt *mqtt.Mqtt,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt,
	metric *metrics.MetricManager) (workflow *Workflow)

NewWorkflow ...

func (*Workflow) AddFlow 

func (wf *Workflow) AddFlow(flow *m.Flow) (err error)

Flow должен быть полный: с Connections с FlowElements с Cursor с Workers

func (*Workflow) DoWorker added in v0.0.25 

func (wf *Workflow) DoWorker(model *m.Worker) (err error)

DoWorker ...

func (*Workflow) GetFLow 

func (wf *Workflow) GetFLow(flowId int64) (flow *Flow, err error)

GetFLow ...

func (*Workflow) NewScript 

func (wf *Workflow) NewScript(model *m.Script) (engine *scripts.Engine, err error)

NewScript ...

func (*Workflow) RemoveFlow 

func (wf *Workflow) RemoveFlow(flow *m.Flow) (err error)

RemoveFlow ...

func (*Workflow) RemoveWorker added in v0.0.25 

func (wf *Workflow) RemoveWorker(_worker *m.Worker) (err error)

RemoveWorker ...

func (*Workflow) Restart 

func (wf *Workflow) Restart() (err error)

Restart ...

func (*Workflow) Run 

func (wf *Workflow) Run() (err error)

Run ...

func (*Workflow) SetScenario 

func (wf *Workflow) SetScenario(systemName string) (err error)

SetScenario ...

func (*Workflow) Stop 

func (wf *Workflow) Stop() (err error)

Stop ...

func (*Workflow) UpdateFlow 

func (wf *Workflow) UpdateFlow(flow *m.Flow) (err error)

UpdateFlow ...

func (*Workflow) UpdateScenario 

func (wf *Workflow) UpdateScenario() (err error)

UpdateScenario ...

func (*Workflow) UpdateWorker added in v0.0.25 

func (wf *Workflow) UpdateWorker(_worker *m.Worker) (err error)

UpdateWorker ...

type WorkflowBind 

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

Javascript Binding

Workflow 

.GetName()
.GetDescription()
.SetVar(string, interface)
.GetVar(string)
.GetScenario() string
.GetScenarioName() string
.SetScenario(string)

func (*WorkflowBind) GetDescription 

func (w *WorkflowBind) GetDescription() string

GetDescription ...

func (*WorkflowBind) GetName 

func (w *WorkflowBind) GetName() string

GetName ...

func (*WorkflowBind) GetScenario 

func (w *WorkflowBind) GetScenario() string

GetScenario ...

func (*WorkflowBind) GetScenarioName 

func (w *WorkflowBind) GetScenarioName() string

GetScenarioName ...

func (*WorkflowBind) GetVar 

func (w *WorkflowBind) GetVar(key string) interface{}

GetVar ...

func (*WorkflowBind) SetScenario 

func (w *WorkflowBind) SetScenario(system_name string)

SetScenario ...

func (*WorkflowBind) SetVar 

func (w *WorkflowBind) SetVar(key string, value interface{})

SetVar ...

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.