controller

package
v0.4.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2025 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
const ConnPollTime = 1 * time.Second
View Source
const MaxInternalLog = 100

Variables

This section is empty.

Functions

This section is empty.

Types

type ControllerImpl

type ControllerImpl struct {
	Lock sync.Mutex // lock for this struct

	AppInfo              ds.AppInfo                     // combined application information
	TransportPacketsSent int64                          // count of packets sent
	OutrigForceDisabled  bool                           // whether outrig is force disabled
	Collectors           map[string]collector.Collector // map of collectors by name
	InternalLogBuf       *utilds.CirBuf[string]         // internal log for debugging
	// contains filtered or unexported fields
}

func MakeController

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

this is idempotent

func (*ControllerImpl) Disable

func (c *ControllerImpl) Disable(disconnect bool)

func (*ControllerImpl) Enable

func (c *ControllerImpl) Enable()

func (*ControllerImpl) GetAppRunId

func (c *ControllerImpl) GetAppRunId() string

func (*ControllerImpl) GetConfig

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

func (*ControllerImpl) ILog added in v0.1.9

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

func (*ControllerImpl) InitialStart added in v0.1.9

func (c *ControllerImpl) InitialStart()

func (*ControllerImpl) IsForceDisabled

func (c *ControllerImpl) IsForceDisabled() bool

func (*ControllerImpl) SendPacket

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

func (*ControllerImpl) Shutdown

func (c *ControllerImpl) Shutdown()

func (*ControllerImpl) WriteInitMessage added in v0.2.2

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

Jump to

Keyboard shortcuts

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