Versions in this module Expand all Collapse all v0 v0.2.4 Mar 30, 2023 Changes in this version + func IsNumDot(s string) bool v0.2.2 May 20, 2020 Changes in this version + func InSlice(slice []string, val string) bool v0.2.0 Apr 7, 2020 Changes in this version + const AgentRestart + const AgentStart + const AgentStop + const SinkRestart + const SinkStart + const SinkStop + const SourceMeta + const SourceQuery + const SourceRestart + const SourceStart + const SourceStop + const TaskDone + const TaskOnError + const TaskPending + const TaskRunning + func DecryptString(cryptoText string, keyString string) (plainTextString string, err error) + func EncryptBytes(plainText []byte, keyString string) ([]byte, error) + func EncryptString(plainText string, keyString string) (string, error) + func EscapeCtrl(ctrl []byte) (esc []byte) + func IsStandalone(v *viper.Viper) bool + type Filter struct + Filter map[string]interface{} + FilterPolicy string + func (f *Filter) IsFilteredColumn(database string, table string, column string) bool + func (f *Filter) IsFilteredDatabase(database string) bool + func (f *Filter) IsFilteredTable(database string, table string) bool + type Meta struct + Name string + Timestamp int64 + Value interface{} + func NewMeta(name string, value interface{}) Meta + type Metas struct + Agent map[string]Meta + Sinks map[string]map[string]Meta + Sources map[string]map[string]Meta + func NewMetas() (meta Metas) + func (m *Metas) SetMetaSinks(sinkName string, meta Meta) + func (m *Metas) SetMetaSources(sourceName string, meta Meta) + type ParametersDescription struct + Description string + Name string + Required bool + Type string + type Task struct + CreatedAt int64 + Description string + EndDate int64 + ErrorDetails string + ID string + Parameters map[string]interface{} + StartDate int64 + Status string + Target string + TaskType string + type TaskDescription struct + Description string + Parameters []*ParametersDescription + func DeclareNewTaskDescription(class interface{}, description string) (task *TaskDescription)