controller

May 27, 2025

Changes in this version

type ControllerImpl

+ func (c *ControllerImpl) GetCollectorStatuses() map[string]ds.CollectorStatus

May 16, 2025

Changes in this version

+ const LogBatchSize

+ const TransportPeerBufferSize

+ const WriteDeadline

+ var TransportDroppedPackets int64

+ var TransportPacketsQueued int64

+ type Transport struct

+ func MakeTransport(cfg *config.Config) *Transport

+ func (t *Transport) AddConn(conn *comm.ConnWrap)

+ func (t *Transport) CloseAllConns()

+ func (t *Transport) HasConnections() bool

+ func (t *Transport) SendPacket(pk *ds.PacketType, force bool) (bool, error)

Apr 24, 2025

Changes in this version

type ControllerImpl

+ func (c *ControllerImpl) WriteInitMessage(connected bool, connWrap *comm.ConnWrap, permErr error, transErr error)

Apr 13, 2025

Changes in this version

+ const MaxInternalLog

type ControllerImpl

+ InternalLogBuf *utilds.CirBuf[string]

+ func (c *ControllerImpl) ILog(format string, args ...any)

+ func (c *ControllerImpl) InitialStart()

Apr 10, 2025

Changes in this version

+ const ConnPollTime

+ type ControllerImpl struct

+ AppInfo ds.AppInfo

+ Collectors map[string]collector.Collector

+ Lock sync.Mutex

+ OutrigConnected bool

+ OutrigForceDisabled bool

+ TransportErrors int64

+ TransportPacketsSent int64

+ func MakeController(config ds.Config) (*ControllerImpl, error)

+ func (c *ControllerImpl) Connect() bool

+ func (c *ControllerImpl) Disable(disconnect bool)

+ func (c *ControllerImpl) Disconnect()

+ func (c *ControllerImpl) Enable()

+ func (c *ControllerImpl) GetAppRunId() string

+ func (c *ControllerImpl) GetConfig() ds.Config

+ func (c *ControllerImpl) IsConnected() bool

+ func (c *ControllerImpl) IsForceDisabled() bool

+ func (c *ControllerImpl) SendPacket(pk *ds.PacketType) (bool, error)

+ func (c *ControllerImpl) Shutdown()