runner

Documentation

Index

• Variables
• 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) RunDesktopStrategy(ctx context.Context, cfg agentConfig.Config, uiEndpoint string) error
  • func (s *Runner) RunVerboseStrategy(ctx context.Context, cfg agentConfig.Config) error
  • func (s *Runner) StartAgent(ctx context.Context, endpoint, agentApiKey, uiEndpoint string) error
• type Session
  • func StartSession(ctx context.Context, cfg config.Config, observer event.Observer, ...) (*Session, error)
  • func (s *Session) Close()
  • func (s *Session) WaitUntilDisconnected()

Variables

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

Functions

func StartCollector

func StartCollector(ctx context.Context, config config.Config, traceCache collector.TraceCache, observer event.Observer, logger *zap.Logger) 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) RunDesktopStrategy

func (s *Runner) RunDesktopStrategy(ctx context.Context, cfg agentConfig.Config, uiEndpoint string) error

func (*Runner) RunVerboseStrategy

func (s *Runner) RunVerboseStrategy(ctx context.Context, cfg agentConfig.Config) 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, observer event.Observer, logger *zap.Logger) (*Session, error)

Start the agent session with given configuration

func (*Session) Close

func (s *Session) Close()

func (*Session) WaitUntilDisconnected

func (s *Session) WaitUntilDisconnected()