core

package

Go to main page

Versions in this module

v0

v0.2.4

Mar 30, 2023

v0.2.2

May 20, 2020

Changes in this version

+ const DefaultTimeOut

type ControllerConfig

+ Worker int

v0.2.0

Apr 7, 2020

Changes in this version

+ const AgentStatusOffline

+ const AgentStatusOnError

+ const AgentStatusOnline

+ const AgentStatusRegistred

+ const AgentStatusStarting

+ const AgentStatusUnRegistred

+ const AgentStatusWaitingForConf

+ const AuthPath

+ const HeaderDcc

+ var WaitAuth = time.Second * 5

type Agent

+ func (a *Agent) InitAgent() (err error)

+ func (a *Agent) InitRemoteMeta()

+ func (a *Agent) LoadDeMultiplexer(demux *map[string][]string) error

+ func (a *Agent) Poller()

+ func (a *Agent) ProcessTask(task utils.Task) (err error)

+ func (a *Agent) RemoteInit() error

+ func (a *Agent) SendCapabilities() (err error)

+ func (a *Agent) Start() error

type Auth

+ func NewAuth(uuid string, password string, baseURL string) *Auth

type Controller

+ PendingTask int

+ func (c *Controller) GetConfiguration() (config []byte, err error)

+ func (c *Controller) GetMeta(metaName string) (meta utils.Metas, err error)

+ func (c *Controller) GetTasks(limit int) (task []utils.Task, err error)

+ func (c *Controller) SendCapabilities(tasks map[string]*utils.TaskDescription) (err error)

+ func (c *Controller) SendMeta(meta utils.Metas) (err error)

+ func (c *Controller) SendSchema(sourceName string, schema map[string]map[string]*sources.Column) (err error)

+ func (c *Controller) SendSourcesCapabilities(sourceName string, tasks map[string]*utils.TaskDescription) (err error)

+ func (c *Controller) UpdateTasks(task utils.Task) (err error)

type ControllerConfig

+ BaseURL string

+ PollerTicker string

+ type DeMultiplexer struct

+ func NewDemultiplexer(ins []chan interface{}, out chan interface{}) (demux *DeMultiplexer)

+ type Schema struct

+ Key string

+ Values map[string]*sources.Column

v0.1.1

Mar 3, 2019

v0.1.0

Dec 16, 2018

v0.0.1

Jun 28, 2018

Changes in this version

+ func Run(config *viper.Viper, s chan error) (err error)

+ type Agent struct

+ func (a *Agent) ControllerStart() error

+ func (a *Agent) DispatchAgent(agentMsg *control.Agent) error

+ func (a *Agent) DispatchSink(payload *rpc.Message, sinkName string)

+ func (a *Agent) DispatchSource(payload *rpc.Message, sourceName string)

+ func (a *Agent) GetConfig() error

+ func (a *Agent) GetSchemas() *control.Agent

+ func (a *Agent) GetSourceAvailableAction(sourceName string, srcCtrl *control.Source)

+ func (a *Agent) HandleMessage(async chan *rpc.Message)

+ func (a *Agent) HealthCheck() (alive bool)

+ func (a *Agent) InitConfig() (err error)

+ func (a *Agent) LoadMultiplexer(multiplexer *map[string][]string) error

+ func (a *Agent) LoadSink(sinkName string, sinkType string, eventChan chan *events.LookatchEvent) (err error)

+ func (a *Agent) LoadSinks() (err error)

+ func (a *Agent) LoadSource(sourceName string, sourceType string, eventChan chan *events.LookatchEvent) (err error)

+ func (a *Agent) LoadSources(multiplexer *map[string][]string) (err error)

+ func (a *Agent) SendAgentAvailableAction(agentCtrl *control.Agent) error

+ func (a *Agent) SendAgentStatus(agentCtrl *control.Agent) error

+ func (a *Agent) SendAvailableAction(agentCtrl *control.Agent) (err error)

+ func (a *Agent) SendEncapsMessage(msg interface{}, typeMessage string) (err error)

+ func (a *Agent) SendMeta(agentCtrl *control.Agent) error

+ func (a *Agent) SendSchema(agentCtrl *control.Agent) error

+ func (a *Agent) SendSourceAvailableAction(agentCtrl *control.Agent) error

+ func (a *Agent) SendSourceStatus(agentCtrl *control.Agent) error

+ func (a *Agent) SendStatus(agentCtrl *control.Agent) (err error)

+ func (a *Agent) UpdateConfig(agentCtrl *control.Agent) (err error)

+ type Auth struct

+ func (a *Auth) GetToken() (token string, err error)

+ type Controller struct

+ Status string

+ func NewControllerClient(conf *viper.Viper, auth *Auth) *Controller

+ func (c *Controller) RecvMessage(async chan *rpc.Message)

+ func (c *Controller) StartChannel()

+ type ControllerConfig struct

+ Address string

+ Port int

+ Secure bool

+ type Multiplexer struct

+ func NewMultiplexer(in chan *events.LookatchEvent, outs []chan *events.LookatchEvent) (multiplexer *Multiplexer)

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