agents

type AgentRunningContext struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type CommandHandler interface {
	CreateContext(ctx context.Context, agentType telemetry_edge.AgentType, cmdName string, workingDir string, arg ...string) *AgentRunningContext
	// StartAgentCommand will start the given command and optionally block until a specific phrase
	// is observed as given by the waitFor argument.
	// It will also setup "forwarding" of the command's stdout/err to logrus
	StartAgentCommand(runningContext *AgentRunningContext, agentType telemetry_edge.AgentType, waitFor string, waitForDuration time.Duration) error
	// WaitOnAgentCommand should be ran as a goroutine to watch for the agent process to end prematurely.
	// It will take care of restarting the agent via the SpecificAgentRunner's EnsureRunningState function.
	WaitOnAgentCommand(ctx context.Context, agentRunner SpecificAgentRunner, runningContext *AgentRunningContext)
	Signal(runningContext *AgentRunningContext, signal syscall.Signal) error
	Stop(runningContext *AgentRunningContext)
	// RunToCompletion combines the behavior (or equivalent thereof) of exec.Command with cmd.Output
	RunToCompletion(ctx context.Context, cmdName string, workingDir string, arg ...string) ([]byte, error)
}

type Conversion int

type FilebeatRunner struct {
	// contains filtered or unexported fields
}

type OracleRunner struct {
	// contains filtered or unexported fields
}

type PackagesAgentRunner struct {
	// contains filtered or unexported fields
}

type Router interface {
	// Start ensures that when the ctx is done, then the managed SpecificAgentRunner instances will be stopped
	Start(ctx context.Context)
	ProcessInstall(install *telemetry_edge.EnvoyInstructionInstall)
	ProcessConfigure(configure *telemetry_edge.EnvoyInstructionConfigure)
	ProcessTestMonitor(testMonitor *telemetry_edge.EnvoyInstructionTestMonitor) *telemetry_edge.TestMonitorResults
}

type SpecificAgentRunner interface {
	// Load gets called after viper's configuration has been populated and before any other use.
	Load(agentBasePath string) error
	SetCommandHandler(handler CommandHandler)
	// EnsureRunningState is called after installation of an agent and after each call to ProcessConfig.
	// In the latter case, applyConfigs will be passed as true to indicate the runner should take
	// actions to reload configuration into an agent, if running.
	// It must ensure the agent process is running if configs and executable are available
	// It must also ensure that that the process is stopped if no configuration remains
	EnsureRunningState(ctx context.Context, applyConfigs bool)
	// PostInstall is invoked after installation of a new agent version and allows the
	// specific agent runner a chance to tweak capabilities assigned to the executable
	PostInstall(agentVersionPath string) error
	PurgeConfig() error
	ProcessConfig(configure *telemetry_edge.EnvoyInstructionConfigure) error
	ProcessTestMonitor(correlationId string, content string, timeout time.Duration) (*telemetry_edge.TestMonitorResults, error)
	// Stop should stop the agent's process, if running
	Stop()
}

type StandardAgentsRouter struct {
	DataPath string
	// contains filtered or unexported fields
}

type StandardCommandHandler struct{}

type TelegrafRunner struct {
	// contains filtered or unexported fields
}

type TelegrafTestConfigRunner interface {
	StartTestConfigServer(configToml []byte, configServerErrors chan error, listener net.Listener) io.Closer
	RunCommand(hostPort string, exePath string, basePath string, timeout time.Duration) ([]byte, error)
}

type TelegrafTestConfigRunnerBuilder func(testConfigServerId string, testConfigServerToken string) TelegrafTestConfigRunner