utils

Documentation

Index

• func AddLog(state running.State, name string, start, end time.Time, msg string, err error)
• func RegisterNodes(e *running.Engine, nodes ...running.Node) error
• type PropsHelper
  • func ProxyProps(props running.Props) PropsHelper
  • func (helper PropsHelper) GetBool(key string) (value bool)
  • func (helper PropsHelper) GetBytes(key string) (value []byte)
  • func (helper PropsHelper) GetFloat(key string) (value float64)
  • func (helper PropsHelper) GetInt(key string) (value int)
  • func (helper PropsHelper) GetRaw(key string) (value interface{})
  • func (helper PropsHelper) GetString(key string) (value string)
  • func (helper PropsHelper) Sub(subKey string) PropsHelper
  • func (helper PropsHelper) SubGetBool(sub, key string) (value bool)
  • func (helper PropsHelper) SubGetBytes(sub, key string) (value []byte)
  • func (helper PropsHelper) SubGetFloat(sub, key string) (value float64)
  • func (helper PropsHelper) SubGetInt(sub, key string) (value int)
  • func (helper PropsHelper) SubGetRaw(sub, key string) (value interface{})
  • func (helper PropsHelper) SubGetString(sub, key string) (value string)
• type RunLog
• type RunSummary
  • func GetRunSummary(state running.State) RunSummary
• type StatesHelper
  • func ProxyState(state running.State) StatesHelper
  • func (helper StatesHelper) GetBool(key string) (value bool)
  • func (helper StatesHelper) GetBytes(key string) (value []byte)
  • func (helper StatesHelper) GetFloat(key string) (value float64)
  • func (helper StatesHelper) GetInt(key string) (value int)
  • func (helper StatesHelper) GetString(key string) (value string)
• type Uninitialized

Functions

func AddLog

func AddLog(state running.State, name string, start, end time.Time, msg string, err error)

func RegisterNodes

func RegisterNodes(e *running.Engine, nodes ...running.Node) error

RegisterNodes auto register node builder, field with running tag will be set tag `running:"name"` to get node name tag `running:"prop:key"` to get prop value of the key

Types

type PropsHelper

type PropsHelper struct {
	SubKey string

	Props running.Props
}

func ProxyProps

func ProxyProps(props running.Props) PropsHelper

func (PropsHelper) GetBool

func (helper PropsHelper) GetBool(key string) (value bool)

func (PropsHelper) GetBytes

func (helper PropsHelper) GetBytes(key string) (value []byte)

func (PropsHelper) GetFloat

func (helper PropsHelper) GetFloat(key string) (value float64)

func (PropsHelper) GetInt

func (helper PropsHelper) GetInt(key string) (value int)

func (PropsHelper) GetRaw

func (helper PropsHelper) GetRaw(key string) (value interface{})

func (PropsHelper) GetString

func (helper PropsHelper) GetString(key string) (value string)

func (PropsHelper) Sub

func (helper PropsHelper) Sub(subKey string) PropsHelper

func (PropsHelper) SubGetBool

func (helper PropsHelper) SubGetBool(sub, key string) (value bool)

func (PropsHelper) SubGetBytes

func (helper PropsHelper) SubGetBytes(sub, key string) (value []byte)

func (PropsHelper) SubGetFloat

func (helper PropsHelper) SubGetFloat(sub, key string) (value float64)

func (PropsHelper) SubGetInt

func (helper PropsHelper) SubGetInt(sub, key string) (value int)

func (PropsHelper) SubGetRaw

func (helper PropsHelper) SubGetRaw(sub, key string) (value interface{})

func (PropsHelper) SubGetString

func (helper PropsHelper) SubGetString(sub, key string) (value string)

type RunLog

type RunLog struct {
	Start, End time.Time

	Msg string

	Err error
}

type RunSummary

type RunSummary struct {
	Count int

	Cost time.Duration

	Logs map[string][]RunLog
}

func GetRunSummary

func GetRunSummary(state running.State) RunSummary

type StatesHelper

type StatesHelper struct {
	State running.State
}

func ProxyState

func ProxyState(state running.State) StatesHelper

func (StatesHelper) GetBool

func (helper StatesHelper) GetBool(key string) (value bool)

func (StatesHelper) GetBytes

func (helper StatesHelper) GetBytes(key string) (value []byte)

func (StatesHelper) GetFloat

func (helper StatesHelper) GetFloat(key string) (value float64)

func (StatesHelper) GetInt

func (helper StatesHelper) GetInt(key string) (value int)

func (StatesHelper) GetString

func (helper StatesHelper) GetString(key string) (value string)

type Uninitialized

type Uninitialized interface {
	Init() error
}