runner

Documentation

Index

• Variables
• func RunDesktopStrategy(ctx context.Context, cfg agentConfig.Config, ui consoleUI.ConsoleUI, ...) error
• func StartCollector(ctx context.Context, config config.Config, traceCache collector.TraceCache) error
• type Runner
  • func NewRunner(configurator config.Configurator, resources *resourcemanager.Registry, ...) *Runner
  • func (s *Runner) Run(ctx context.Context, cfg config.Config, flags agentConfig.Flags) error
  • func (s *Runner) StartAgent(ctx context.Context, endpoint, agentApiKey, uiEndpoint string) error
• type Session
  • func StartSession(ctx context.Context, cfg config.Config) (*Session, error)
  • func (s *Session) Close()
  • func (s *Session) WaitUntilDisconnected()

Variables

var ErrOtlpServerStart = errors.New("OTLP server start error")

Functions

func RunDesktopStrategy

func RunDesktopStrategy(ctx context.Context, cfg agentConfig.Config, ui consoleUI.ConsoleUI, uiEndpoint string) error

func StartCollector

func StartCollector(ctx context.Context, config config.Config, traceCache collector.TraceCache) error

Types

type Runner

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

func NewRunner

func NewRunner(configurator config.Configurator, resources *resourcemanager.Registry, ui ui.ConsoleUI) *Runner

func (*Runner) Run

func (s *Runner) Run(ctx context.Context, cfg config.Config, flags agentConfig.Flags) error

func (*Runner) StartAgent

func (s *Runner) StartAgent(ctx context.Context, endpoint, agentApiKey, uiEndpoint string) error

type Session

type Session struct {
	Token string
	// contains filtered or unexported fields
}

func StartSession

func StartSession(ctx context.Context, cfg config.Config) (*Session, error)

Start the agent session with given configuration

func (*Session) Close

func (s *Session) Close()

func (*Session) WaitUntilDisconnected

func (s *Session) WaitUntilDisconnected()