agent

package
v0.0.0-...-b72cba7 Latest Latest
Warning

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

Go to latest
Published: Aug 15, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

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