freepsgraph

package

Go to main page

Versions in this module

v1

v1.3.0

Mar 26, 2024

Changes in this version

+ func SplitTag(tag string) (string, string)

+ type FreepsAlertHook interface

+ OnResetSystemAlert func(ctx *base.Context, name string, category string) error

+ OnSystemAlert func(ctx *base.Context, name string, category string, severity int, err error, ...) error

+ type FreepsExecutionHook interface

+ OnExecute func(ctx *base.Context, graphName string, mainArgs map[string]string, ...) error

+ OnExecuteOperation func(ctx *base.Context, input *base.OperatorIO, opOutput *base.OperatorIO, ...) error

+ OnExecutionFinished func(ctx *base.Context, graphName string, mainArgs map[string]string, ...) error

+ type FreepsGraphChangedHook interface

+ OnGraphChanged func(ctx *base.Context, addedGraphName []string, removedGraphName []string) error

+ type FreepsHookWrapper struct

+ func NewFreepsHookWrapper(hookImpl interface{}) *FreepsHookWrapper

+ func (h *FreepsHookWrapper) GetName() string

+ func (h *FreepsHookWrapper) OnExecute(ctx *base.Context, graphName string, mainArgs map[string]string, ...) error

+ func (h *FreepsHookWrapper) OnExecuteOperation(ctx *base.Context, input *base.OperatorIO, opOutput *base.OperatorIO, ...) error

+ func (h *FreepsHookWrapper) OnExecutionFinished(ctx *base.Context, graphName string, mainArgs map[string]string, ...) error

+ func (h *FreepsHookWrapper) OnGraphChanged(ctx *base.Context, addedGraphName []string, removedGraphName []string) error

+ func (h *FreepsHookWrapper) OnResetSystemAlert(ctx *base.Context, name string, category string) error

+ func (h *FreepsHookWrapper) OnSystemAlert(ctx *base.Context, name string, category string, severity int, err error, ...) error

type Graph

+ func (g *Graph) GetCompleteDesc() *GraphDesc

+ func (g *Graph) GetGraphID() string

type GraphDesc

+ DisplayName string

+ GraphID string

+ func (gd *GraphDesc) AddTags(tags ...string)

+ func (gd *GraphDesc) GetCompleteDesc(graphID string, ge *GraphEngine) (*GraphDesc, error)

+ func (gd *GraphDesc) HasAllTags(expectedTags []string) bool

+ func (gd *GraphDesc) HasAtLeastOneTag(expectedTags []string) bool

+ func (gd *GraphDesc) HasAtLeastOneTagPerGroup(tagGroups ...[]string) bool

+ func (gd *GraphDesc) RemoveTag(tag string)

+ func (gd *GraphDesc) RenameOperation(oldName string, newName string)

type GraphEngine

+ func (ge *GraphEngine) AddGraph(ctx *base.Context, graphID string, gd GraphDesc, overwrite bool) error

+ func (ge *GraphEngine) AddOperators(ops []base.FreepsBaseOperator)

+ func (ge *GraphEngine) ExecuteAdHocGraph(ctx *base.Context, fullName string, gd GraphDesc, mainArgs map[string]string, ...) *base.OperatorIO

+ func (ge *GraphEngine) ExecuteGraphByTagsExtended(ctx *base.Context, tagGroups [][]string, args map[string]string, ...) *base.OperatorIO

+ func (ge *GraphEngine) GetCompleteGraphDesc(graphID string) (*GraphDesc, error)

+ func (ge *GraphEngine) GetGraphDescByTag(tags []string) map[string]GraphDesc

+ func (ge *GraphEngine) GetGraphDescByTagExtended(tagGroups ...[]string) map[string]GraphDesc

+ func (ge *GraphEngine) GetGraphDir() string

+ func (ge *GraphEngine) GetTagMap() map[string][]string

+ func (ge *GraphEngine) GetTagValues(keytag string) []string

+ func (ge *GraphEngine) ResetSystemAlert(ctx *base.Context, name string, category string)

+ func (ge *GraphEngine) SetSystemAlert(ctx *base.Context, name string, category string, severity int, err error, ...)

+ func (ge *GraphEngine) StartListening(ctx *base.Context)

+ func (ge *GraphEngine) TriggerGraphChangedHooks(ctx *base.Context, addedGraphNames []string, removedGraphNames []string)

+ func (ge *GraphEngine) TriggerOnExecuteOperationHooks(ctx *base.Context, input *base.OperatorIO, output *base.OperatorIO, ...)

type GraphEngineConfig

+ AlertDuration time.Duration

+ type GraphEngineHook interface

+ GetName func() string

type GraphOperationDesc

+ UseMainArgs bool

type OpEval

+ func (m *OpEval) Split(argsmap map[string]string, input *base.OperatorIO) *base.OperatorIO

+ func (o *OpEval) GetHook() interface{}

+ func (o *OpEval) StartListening(ctx *base.Context)

type OpGraph

+ func (o *OpGraph) GetHook() interface{}

+ func (o *OpGraph) StartListening(*base.Context)

type OpGraphByTag

+ func (o *OpGraphByTag) GetHook() interface{}

+ func (o *OpGraphByTag) StartListening(*base.Context)

type OpSystem — linux/amd64, windows/amd64

+ func (o *OpSystem) GetHook() interface{}

+ func (o *OpSystem) StartListening(ctx *base.Context)

+ func (o *OpSystem) Stats(ctx *base.Context, fn string, args map[string]string, input *base.OperatorIO) *base.OperatorIO

v1.2.1

Jan 11, 2023

v1.2.0

Jan 11, 2023

Changes in this version

+ var DefaultOwmConfig = OpenWeatherMapConfig

type FreepsHook

+ GetName func() string

+ OnExecutionFinished func(ctx *utils.Context, graphName string, mainArgs map[string]string, ...) error

type FreepsOperator

+ GetName func() string

+ Shutdown func(*utils.Context)

type GraphEngine

+ func (ge *GraphEngine) AddHook(h FreepsHook)

+ func (ge *GraphEngine) AddOperator(op FreepsOperator)

+ func (ge *GraphEngine) DeleteGraph(graphName string) error

+ func (ge *GraphEngine) ExecuteGraphByTags(ctx *utils.Context, tags []string) *OperatorIO

+ func (ge *GraphEngine) LoadEmbeddedGraphs() error

+ func (ge *GraphEngine) TriggerOnExecuteHooks(ctx *utils.Context, graphName string, mainArgs map[string]string, ...)

+ func (ge *GraphEngine) TriggerOnExecutionFinishedHooks(ctx *utils.Context, graphName string, mainArgs map[string]string, ...)

type OpCurl

+ func (o *OpCurl) GetName() string

+ func (o *OpCurl) Shutdown(ctx *utils.Context)

type OpEval

+ func (o *OpEval) GetName() string

+ func (o *OpEval) Shutdown(ctx *utils.Context)

type OpFritz

+ func (o *OpFritz) GetName() string

+ func (o *OpFritz) Shutdown(ctx *utils.Context)

type OpGraph

+ func (o *OpGraph) GetName() string

+ func (o *OpGraph) Shutdown(*utils.Context)

+ type OpGraphByTag struct

+ func (o *OpGraphByTag) Execute(ctx *utils.Context, fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpGraphByTag) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpGraphByTag) GetFunctions() []string

+ func (o *OpGraphByTag) GetName() string

+ func (o *OpGraphByTag) GetPossibleArgs(fn string) []string

+ func (o *OpGraphByTag) Shutdown(*utils.Context)

type OpSystem

+ func (o *OpSystem) GetName() string

+ func (o *OpSystem) Shutdown(ctx *utils.Context)

type OpTime

+ func (o *OpTime) GetName() string

+ func (o *OpTime) Shutdown(ctx *utils.Context)

type OpUI

+ func (o *OpUI) GetName() string

+ func (o *OpUI) Shutdown(ctx *utils.Context)

+ type OpWeather struct

+ func NewWeatherOp(cr *utils.ConfigReader) *OpWeather

+ func (o OpWeather) Execute(ctx *utils.Context, function string, vars map[string]string, ...) *OperatorIO

+ func (o OpWeather) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o OpWeather) GetFunctions() []string

+ func (o OpWeather) GetName() string

+ func (o OpWeather) GetPossibleArgs(fn string) []string

+ func (o OpWeather) Shutdown(ctx *utils.Context)

+ type OpenWeatherMapConfig struct

+ APIKey string

+ Lang string

+ Location string

+ Units string

v1.1.0

Dec 10, 2022

Changes in this version

+ type FreepsHook interface

+ OnExecute func(ctx *utils.Context, graphName string, mainArgs map[string]string, ...) error

+ Shutdown func() error

+ type FreepsPostgressConfig struct

+ ConnStr string

type GraphDesc

+ func (gd *GraphDesc) HasTags(expectedTags []string) bool

type GraphEngine

+ func (ge *GraphEngine) GetGraphInfo(graphName string) (GraphInfo, bool)

+ func (ge *GraphEngine) GetGraphInfoByTag(tags []string) map[string]GraphInfo

+ func (ge *GraphEngine) GetTags() map[string]string

+ func (ge *GraphEngine) Shutdown()

+ type GraphInfo struct

+ Desc GraphDesc

+ ExecutionCounter int64

+ LastExecutionTime time.Time

+ type HookPostgres struct

+ func NewPostgressHook(cr *utils.ConfigReader) (*HookPostgres, error)

+ func (h *HookPostgres) OnExecute(ctx *utils.Context, graphName string, mainArgs map[string]string, ...) error

+ func (h *HookPostgres) Shutdown() error

+ type OpPostgres struct

+ func NewPostgresOp() *OpPostgres

+ func (o *OpPostgres) Execute(ctx *utils.Context, function string, vars map[string]string, ...) *OperatorIO

+ func (o *OpPostgres) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpPostgres) GetFunctions() []string

+ func (o *OpPostgres) GetPossibleArgs(fn string) []string

type OperatorIO

+ func (io *OperatorIO) GetStatusCode() int

type StoreNamespace

+ func (s *StoreNamespace) CompareAndSwap(key string, expected string, newValue *OperatorIO) *OperatorIO

+ func (s *StoreNamespace) GetValueBeforeExpiration(key string, maxAge time.Duration) *OperatorIO

+ func (s *StoreNamespace) OverwriteValueIfOlder(key string, io *OperatorIO, maxAge time.Duration) *OperatorIO

v1.0.0

Nov 28, 2022

Changes in this version

+ const ROOT_SYMBOL

+ var DefaultGraphEngineConfig = GraphEngineConfig

+ var DefaultTelegramConfig = TelegramConfig

+ func CaptureRaspiStill(cameraParams map[string]string) (bytes []byte, err error)

+ type CollectedError struct

+ Error string

+ GraphName string

+ Input *OperatorIO

+ Operation *GraphOperationDesc

+ Time time.Time

+ type CollectedErrors struct

+ func NewCollectedErrors(maxLen int) *CollectedErrors

+ func (ce *CollectedErrors) AddError(input *OperatorIO, err *OperatorIO, graphName string, od *GraphOperationDesc)

+ func (ce *CollectedErrors) GetErrorsForGraph(since time.Time, graphName string) []*CollectedError

+ func (ce *CollectedErrors) GetErrorsSince(d time.Duration) []*CollectedError

+ type DedupArgs struct

+ Retention string

+ type EditConfigData struct

+ ConfigText string

+ Output string

+ type EvalArgs struct

+ Operand interface{}

+ Operation string

+ Output string

+ ValueName string

+ ValueType string

+ type FieldWithType struct

+ FieldType string

+ FieldValue string

+ type FreepsOperator interface

+ Execute func(fn string, mainArgs map[string]string, mainInput *OperatorIO) *OperatorIO

+ GetArgSuggestions func(fn string, arg string, otherArgs map[string]string) map[string]string

+ GetFunctions func() []string

+ GetPossibleArgs func(fn string) []string

+ type Graph struct

+ func NewGraph(name string, graphDesc *GraphDesc, ge *GraphEngine) (*Graph, error)

+ func (g *Graph) ToDot(gd *GraphDesc) string

+ type GraphDesc struct

+ Operations []GraphOperationDesc

+ OutputFrom string

+ Source string

+ Tags []string

+ type GraphEngine struct

+ func NewGraphEngine(cr *utils.ConfigReader, cancel context.CancelFunc) *GraphEngine

+ func (ge *GraphEngine) AddExternalGraph(graphName string, gd *GraphDesc, fileName string) error

+ func (ge *GraphEngine) AddExternalGraphs(graphs map[string]GraphDesc, fileName string) error

+ func (ge *GraphEngine) AddTemporaryGraph(graphName string, gd *GraphDesc) error

+ func (ge *GraphEngine) CheckGraph(graphName string) *OperatorIO

+ func (ge *GraphEngine) DeleteTemporaryGraph(graphName string)

+ func (ge *GraphEngine) ExecuteGraph(graphName string, mainArgs map[string]string, mainInput *OperatorIO) *OperatorIO

+ func (ge *GraphEngine) ExecuteOperatorByName(logger log.FieldLogger, opName string, fn string, mainArgs map[string]string, ...) *OperatorIO

+ func (ge *GraphEngine) GetAllGraphDesc() map[string]*GraphDesc

+ func (ge *GraphEngine) GetGraphDesc(graphName string) (*GraphDesc, bool)

+ func (ge *GraphEngine) GetOperator(opName string) FreepsOperator

+ func (ge *GraphEngine) GetOperators() []string

+ func (ge *GraphEngine) HasOperator(opName string) bool

+ func (ge *GraphEngine) ReadConfig() GraphEngineConfig

+ func (ge *GraphEngine) ReloadRequested() bool

+ type GraphEngineConfig struct

+ Graphs map[string]GraphDesc

+ GraphsFromFile []string

+ GraphsFromURL []string

+ type GraphOperationDesc struct

+ Arguments map[string]string

+ ArgumentsFrom string

+ ExecuteOnFailOf string

+ Function string

+ IgnoreMainArgs bool

+ InputFrom string

+ Name string

+ Operator string

+ func (gop *GraphOperationDesc) ToQuicklink() string

+ type InMemoryStore struct

+ func (s *InMemoryStore) GetNamespace(ns string) *StoreNamespace

+ func (s *InMemoryStore) GetNamespaces() []string

+ type JsonArgs struct

+ Fields map[string]interface{}

+ FieldsWithType map[string]FieldWithType

+ Measurement string

+ Tags map[string]string

+ type MessageAndTime struct

+ type OpCurl struct

+ func (o *OpCurl) Execute(function string, vars map[string]string, mainInput *OperatorIO) *OperatorIO

+ func (o *OpCurl) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpCurl) GetFunctions() []string

+ func (o *OpCurl) GetPossibleArgs(fn string) []string

+ type OpEval struct

+ func (m *OpEval) Eval(vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpEval) EvalFloat(vInterface interface{}, op string, v2Interface interface{}) (bool, error)

+ func (m *OpEval) EvalInt(vInterface interface{}, op string, v2Interface interface{}) (bool, error)

+ func (m *OpEval) EvalString(vInterface interface{}, op string, v2Interface interface{}) (bool, error)

+ func (m *OpEval) Execute(fn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpEval) Flatten(vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpEval) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (m *OpEval) GetFunctions() []string

+ func (m *OpEval) GetPossibleArgs(fn string) []string

+ func (m *OpEval) Regexp(args map[string]string, input *OperatorIO) *OperatorIO

+ type OpFlux struct

+ func NewFluxMod(cr *utils.ConfigReader) *OpFlux

+ func (o *OpFlux) Execute(fn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpFlux) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpFlux) GetFunctions() []string

+ func (o *OpFlux) GetPossibleArgs(fn string) []string

+ type OpFritz struct

+ func NewOpFritz(cr *utils.ConfigReader) *OpFritz

+ func (m *OpFritz) Execute(mixedCaseFn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpFritz) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (m *OpFritz) GetDeviceByAIN(AIN string) (*freepslib.AvmDevice, error)

+ func (m *OpFritz) GetDevices() map[string]string

+ func (m *OpFritz) GetFunctions() []string

+ func (m *OpFritz) GetPossibleArgs(fn string) []string

+ func (m *OpFritz) GetTemplates() map[string]string

+ type OpGraph struct

+ func (o *OpGraph) Execute(fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpGraph) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpGraph) GetFunctions() []string

+ func (o *OpGraph) GetPossibleArgs(fn string) []string

+ type OpMQTT struct

+ func NewMQTTOp(cr *utils.ConfigReader) *OpMQTT

+ func (o *OpMQTT) Execute(fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpMQTT) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpMQTT) GetFunctions() []string

+ func (o *OpMQTT) GetPossibleArgs(fn string) []string

+ type OpMutt struct

+ func (o *OpMutt) Execute(fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpMutt) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpMutt) GetFunctions() []string

+ func (o *OpMutt) GetPossibleArgs(fn string) []string

+ type OpRaspistill struct

+ func (m *OpRaspistill) Execute(fn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpRaspistill) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (m *OpRaspistill) GetFunctions() []string

+ func (m *OpRaspistill) GetPossibleArgs(fn string) []string

+ type OpStore struct

+ func NewOpStore() *OpStore

+ func (o *OpStore) Execute(fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpStore) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpStore) GetFunctions() []string

+ func (o *OpStore) GetPossibleArgs(fn string) []string

+ type OpSystem struct

+ func NewSytemOp(ge *GraphEngine, cancel context.CancelFunc) *OpSystem

+ func (o *OpSystem) Execute(fn string, args map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpSystem) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpSystem) GetFunctions() []string

+ func (o *OpSystem) GetPossibleArgs(fn string) []string

+ type OpTelegram struct

+ func NewTelegramBot(cr *utils.ConfigReader) *OpTelegram

+ func (m *OpTelegram) Execute(fn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (m *OpTelegram) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (m *OpTelegram) GetFunctions() []string

+ func (m *OpTelegram) GetPossibleArgs(fn string) []string

+ type OpTemplate struct

+ func NewTemplateOperator(ge *GraphEngine, cr *utils.ConfigReader) *OpTemplate

+ func (o *OpTemplate) Execute(fn string, mainArgs map[string]string, mainInput *OperatorIO) *OperatorIO

+ func (o *OpTemplate) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpTemplate) GetFunctions() []string

+ func (o *OpTemplate) GetPossibleArgs(fn string) []string

+ type OpTime struct

+ func (o *OpTime) Execute(function string, vars map[string]string, mainInput *OperatorIO) *OperatorIO

+ func (o *OpTime) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpTime) GetFunctions() []string

+ func (o *OpTime) GetPossibleArgs(fn string) []string

+ type OpUI struct

+ func NewHTMLUI(cr *utils.ConfigReader, graphEngine *GraphEngine) *OpUI

+ func (o *OpUI) Execute(fn string, vars map[string]string, input *OperatorIO) *OperatorIO

+ func (o *OpUI) GetArgSuggestions(fn string, arg string, otherArgs map[string]string) map[string]string

+ func (o *OpUI) GetFunctions() []string

+ func (o *OpUI) GetPossibleArgs(fn string) []string

+ type OperatorIO struct

+ ContentType string

+ HTTPCode uint32

+ Output interface{}

+ OutputType OutputT

+ func MakeByteOutput(output []byte) *OperatorIO

+ func MakeByteOutputWithContentType(output []byte, contentType string) *OperatorIO

+ func MakeEmptyOutput() *OperatorIO

+ func MakeObjectOutput(output interface{}) *OperatorIO

+ func MakeOutputError(code uint32, msg string, a ...interface{}) *OperatorIO

+ func MakePlainOutput(msg string, a ...interface{}) *OperatorIO

+ func (io *OperatorIO) GetArgsMap() (map[string]string, error)

+ func (io *OperatorIO) GetBytes() ([]byte, error)

+ func (io *OperatorIO) GetError() error

+ func (io *OperatorIO) GetString() string

+ func (io *OperatorIO) IsEmpty() bool

+ func (io *OperatorIO) IsError() bool

+ func (io *OperatorIO) IsPlain() bool

+ func (io *OperatorIO) ParseFormData() (url.Values, error)

+ func (io *OperatorIO) ParseJSON(obj interface{}) error

+ func (oio *OperatorIO) Log(logger logrus.FieldLogger)

+ func (oio *OperatorIO) ToString() string

+ func (oio *OperatorIO) WriteTo(bwriter io.Writer) (int, error)

+ type OutputT string

+ const Byte

+ const Empty

+ const Error

+ const Object

+ const PlainText

+ type ShowGraphsData struct

+ GraphJSON string

+ Graphs []string

+ Output string

+ type StoreNamespace struct

+ func (s *StoreNamespace) DeleteValue(key string)

+ func (s *StoreNamespace) GetAllValues() map[string]*OperatorIO

+ func (s *StoreNamespace) GetKeys() []string

+ func (s *StoreNamespace) GetValue(key string) *OperatorIO

+ func (s *StoreNamespace) SetValue(key string, io *OperatorIO)

+ type SunriseOutput struct

+ Begin time.Time

+ End time.Time

+ Latitude float64

+ Longitude float64

+ Phase string

+ Since time.Duration

+ Until time.Duration

+ type TelegramConfig struct

+ AllowedUsers []string

+ DebugMessages bool

+ Token string

+ type TemplateData struct

+ ArgSuggestions map[string]map[string]string

+ Args map[string]string

+ Error string

+ FnSuggestions map[string]bool

+ GraphDesc *GraphDesc

+ GraphJSON string

+ GraphName string

+ InputFromSuggestions []string

+ Numop int

+ OpSuggestions map[string]bool

+ Output string

+ Quicklink string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL