agent

Documentation

Index

• func StartDDAgent(agentAddress, endpointAddress string, expectedSpansCount, threads, repeat int) (context.CancelFunc, chan struct{}, error)
• func StartJgAgent(agentAddress, endpointAddress string, expectedSpansCount, threads, repeat int) (context.CancelFunc, chan struct{}, error)
• type Agent
• type Amplifier
• type AmplifierFunc
  • func (ampf AmplifierFunc) ThreadRoutine(ID int, ctx context.Context, endpoint string, repeat int, trace any, ...) error
• type DDAgent
  • func (ddagt *DDAgent) Start(addr string)
• type GeneralAmplifier
  • func NewGeneralAmplifier(name string, threads, repeat int, handler AmplifierFunc) *GeneralAmplifier
  • func (gamp *GeneralAmplifier) Close()
  • func (gamp *GeneralAmplifier) StartThreads(ctx context.Context, endpoint string, in chan any) (finish chan struct{}, err error)
  • func (gamp *GeneralAmplifier) ThreadRoutine(ID int, ctx context.Context, endpoint string, repeat int, trace any, ...) error
• type JgAgent
  • func (jga *JgAgent) Start(addr string)

Functions

func StartDDAgent

func StartDDAgent(agentAddress, endpointAddress string, expectedSpansCount, threads, repeat int) (context.CancelFunc, chan struct{}, error)

func StartJgAgent

func StartJgAgent(agentAddress, endpointAddress string, expectedSpansCount, threads, repeat int) (context.CancelFunc, chan struct{}, error)

Types

type Agent

type Agent interface{}

type Amplifier

type Amplifier interface {
	ThreadRoutine(ID int, ctx context.Context, endpoint string, repeat int, trace any, threadDown chan int) error
}

type AmplifierFunc

type AmplifierFunc func(ID int, ctx context.Context, endpoint string, repeat int, trace any, threadDown chan int) error

func (AmplifierFunc) ThreadRoutine

func (ampf AmplifierFunc) ThreadRoutine(ID int, ctx context.Context, endpoint string, repeat int, trace any, threadDown chan int) error

type DDAgent

type DDAgent struct {
	http.ServeMux
}

func (*DDAgent) Start

func (ddagt *DDAgent) Start(addr string)

type GeneralAmplifier

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

func NewGeneralAmplifier

func NewGeneralAmplifier(name string, threads, repeat int, handler AmplifierFunc) *GeneralAmplifier

func (*GeneralAmplifier) Close

func (gamp *GeneralAmplifier) Close()

func (*GeneralAmplifier) StartThreads

func (gamp *GeneralAmplifier) StartThreads(ctx context.Context, endpoint string, in chan any) (finish chan struct{}, err error)

func (*GeneralAmplifier) ThreadRoutine

func (gamp *GeneralAmplifier) ThreadRoutine(ID int, ctx context.Context, endpoint string, repeat int, trace any, threadDown chan int) error

type JgAgent

type JgAgent struct {
	http.ServeMux
}

func (*JgAgent) Start

func (jga *JgAgent) Start(addr string)