libWorker

package

Go to main page

Versions in this module

v0

v0.2.8

Feb 1, 2023

v0.2.7

Jan 31, 2023

v0.2.6

Jan 31, 2023

v0.2.5

Jan 31, 2023

v0.2.4

Jan 31, 2023

v0.2.3

Jan 31, 2023

v0.2.2

Jan 31, 2023

v0.2.1

Jan 31, 2023

v0.2.0

Jan 31, 2023

Changes in this version

type BaseGlobalState

+ Conn func() *websocket.Conn

+ ConnReadMutex func() *sync.Mutex

+ ConnWriteMutex func() *sync.Mutex

+ GetRunAbortFunc func() context.CancelFunc

+ SetRunAbortFunc func(cancelFunc context.CancelFunc)

type WorkerInfo

+ Conn *websocket.Conn

v0.1.20

Jan 21, 2023

v0.1.19

Jan 21, 2023

v0.1.18

Jan 21, 2023

v0.1.17

Jan 21, 2023

v0.1.16

Jan 21, 2023

v0.1.15

Jan 21, 2023

v0.1.14

Jan 21, 2023

v0.1.4

Jan 21, 2023

Changes in this version

type BaseGlobalState

+ FuncModeEnabled func() bool

v0.1.3

Jan 11, 2023

v0.1.2

Jan 11, 2023

v0.1.1

Jan 11, 2023

Changes in this version

type BaseGlobalState

+ FuncModeInfo func() *lib.FuncModeInfo

+ MessageQueue func() MessageQueue

+ type MessageQueue struct

+ Mutex sync.Mutex

+ NewQueueCount chan int

+ QueueCount int

v0.1.0

Dec 10, 2022

Changes in this version

+ const DefaultScenarioName

+ const GroupSeparator

+ const MaxRetriesGetPlannedVU

+ const MaxTimeToWaitForPlannedVU

+ var DefaultSummaryTrendStats = []string

+ var ErrNameContainsGroupSeparator = errors.New("group and check names may not contain '::'")

+ var SupportedTLSCipherSuites = map[string]uint16

+ var SupportedTLSCipherSuitesToString = map[uint16]string

+ var SupportedTLSVersions = map[string]TLSVersion

+ var SupportedTLSVersionsToString = map[TLSVersion]string

+ func ConcatErrors(errors []error, separator string) string

+ func DispatchMessage(gs BaseGlobalState, message string, messageType string)

+ func GetEndOffset(steps []ExecutionStep) (lastStepOffset time.Duration, isFinal bool)

+ func GetMaxPlannedVUs(steps []ExecutionStep) (result uint64)

+ func GetMaxPossibleVUs(steps []ExecutionStep) (result uint64)

+ func HandleError(gs BaseGlobalState, err error)

+ func HandleStringError(gs BaseGlobalState, errString string)

+ func Max(a, b int64) int64

+ func Min(a, b int64) int64

+ func RegisterExecutorConfigType(configType string, constructor ExecutorConfigConstructor)

+ func StrictJSONUnmarshal(data []byte, v interface{}) error

+ func UpdateStatus(gs BaseGlobalState, status string)

+ func WithExecutionState(ctx context.Context, s *ExecutionState) context.Context

+ func WithScenarioState(ctx context.Context, s *ScenarioState) context.Context

+ type ActiveVU interface

+ RunOnce func() error

+ type BaseGlobalState interface

+ ChildJobId func() string

+ Client func() *redis.Client

+ Ctx func() context.Context

+ GetWorkerStatus func() string

+ JobId func() string

+ SetWorkerStatus func(status string)

+ WorkerId func() string

+ type Check struct

+ Fails int64

+ Group *Group

+ ID string

+ Name string

+ Passes int64

+ Path string

+ func NewCheck(name string, group *Group) (*Check, error)

+ type Collection struct

+ Name string

+ Variables map[string]string

+ type CompatibilityMode uint8

+ const CompatibilityModeBase

+ const CompatibilityModeExtended

+ func CompatibilityModeString(s string) (CompatibilityMode, error)

+ func CompatibilityModeValues() []CompatibilityMode

+ func ValidateCompatibilityMode(val string) (cm CompatibilityMode, err error)

+ func (i CompatibilityMode) IsACompatibilityMode() bool

+ func (i CompatibilityMode) String() string

+ type DialContexter interface

+ DialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ type Environment struct

+ Name string

+ Variables map[string]string

+ type ExecutionScheduler interface

+ GetExecutors func() []Executor

+ GetRunner func() Runner

+ GetState func() *ExecutionState

+ Init func(ctx context.Context, samplesOut chan<- workerMetrics.SampleContainer, ...) error

+ Run func(globalCtx, runCtx context.Context, ...) error

+ SetPaused func(paused bool) error

+ type ExecutionSegment struct

+ func NewExecutionSegment(from, to *big.Rat) (*ExecutionSegment, error)

+ func NewExecutionSegmentFromString(toStr string) (result *ExecutionSegment, err error)

+ func (es *ExecutionSegment) CopyScaleRat(value *big.Rat) *big.Rat

+ func (es *ExecutionSegment) Equal(other *ExecutionSegment) bool

+ func (es *ExecutionSegment) FloatLength() float64

+ func (es *ExecutionSegment) InPlaceScaleRat(value *big.Rat) *big.Rat

+ func (es *ExecutionSegment) MarshalText() ([]byte, error)

+ func (es *ExecutionSegment) Scale(value int64) int64

+ func (es *ExecutionSegment) Split(numParts int64) ([]*ExecutionSegment, error)

+ func (es *ExecutionSegment) String() string

+ func (es *ExecutionSegment) SubSegment(child *ExecutionSegment) *ExecutionSegment

+ func (es *ExecutionSegment) UnmarshalText(text []byte) (err error)

+ type ExecutionSegmentSequence []*ExecutionSegment

+ func GetFilledExecutionSegmentSequence(sequence *ExecutionSegmentSequence, fallback *ExecutionSegment) (result ExecutionSegmentSequence)

+ func NewExecutionSegmentSequence(segments ...*ExecutionSegment) (ExecutionSegmentSequence, error)

+ func NewExecutionSegmentSequenceFromString(strSeq string) (ExecutionSegmentSequence, error)

+ func (ess *ExecutionSegmentSequence) UnmarshalText(text []byte) (err error)

+ func (ess ExecutionSegmentSequence) FindSegmentPosition(segment *ExecutionSegment) (int, error)

+ func (ess ExecutionSegmentSequence) IsFull() bool

+ func (ess ExecutionSegmentSequence) LCD() int64

+ func (ess ExecutionSegmentSequence) MarshalText() ([]byte, error)

+ func (ess ExecutionSegmentSequence) String() string

+ type ExecutionSegmentSequenceWrapper struct

+ func NewExecutionSegmentSequenceWrapper(ess ExecutionSegmentSequence) *ExecutionSegmentSequenceWrapper

+ func (essw *ExecutionSegmentSequenceWrapper) GetNewExecutionSegmentSequenceFromValue(value int64, trackedIndex int) (newSequence *ExecutionSegmentSequenceWrapper, newIndex int, err error)

+ func (essw *ExecutionSegmentSequenceWrapper) GetStripedOffsets(segmentIndex int) (int64, []int64, int64)

+ func (essw *ExecutionSegmentSequenceWrapper) GetTuple(segmentIndex int) *ExecutionTuple

+ func (essw *ExecutionSegmentSequenceWrapper) LCD() int64

+ func (essw *ExecutionSegmentSequenceWrapper) ScaleInt64(segmentIndex int, value int64) int64

+ type ExecutionState struct

+ ExecutionTuple *ExecutionTuple

+ Test *TestRunState

+ func GetExecutionState(ctx context.Context) *ExecutionState

+ func NewExecutionState(testRunState *TestRunState, et *ExecutionTuple, ...) *ExecutionState

+ func (es *ExecutionState) AddFullIterations(count uint64) uint64

+ func (es *ExecutionState) AddInitializedVU(vu InitializedVU)

+ func (es *ExecutionState) AddInterruptedIterations(count uint64) uint64

+ func (es *ExecutionState) GetCurrentExecutionStatus() ExecutionStatus

+ func (es *ExecutionState) GetCurrentTestRunDuration() time.Duration

+ func (es *ExecutionState) GetCurrentlyActiveVUsCount() int64

+ func (es *ExecutionState) GetFullIterationCount() uint64

+ func (es *ExecutionState) GetInitializedVUsCount() int64

+ func (es *ExecutionState) GetPartialIterationCount() uint64

+ func (es *ExecutionState) GetPlannedVU(logger *logrus.Entry, modifyActiveVUCount bool) (InitializedVU, error)

+ func (es *ExecutionState) GetUniqueVUIdentifiers() (uint64, uint64)

+ func (es *ExecutionState) GetUnplannedVU(ctx context.Context, logger *logrus.Entry, workerInfo *WorkerInfo) (InitializedVU, error)

+ func (es *ExecutionState) HasEnded() bool

+ func (es *ExecutionState) HasStarted() bool

+ func (es *ExecutionState) InitializeNewVU(ctx context.Context, logger *logrus.Entry, workerInfo *WorkerInfo) (InitializedVU, error)

+ func (es *ExecutionState) IsPaused() bool

+ func (es *ExecutionState) MarkEnded()

+ func (es *ExecutionState) MarkStarted()

+ func (es *ExecutionState) ModCurrentlyActiveVUsCount(mod int64) int64

+ func (es *ExecutionState) ModInitializedVUsCount(mod int64) int64

+ func (es *ExecutionState) Pause() error

+ func (es *ExecutionState) Resume() error

+ func (es *ExecutionState) ResumeNotify() <-chan struct{}

+ func (es *ExecutionState) ReturnVU(vu InitializedVU, wasActive bool)

+ func (es *ExecutionState) SetExecutionStatus(newStatus ExecutionStatus) (oldStatus ExecutionStatus)

+ func (es *ExecutionState) SetInitVUFunc(initVUFunc InitVUFunc)

+ type ExecutionStatus uint32

+ const ExecutionStatusCreated

+ const ExecutionStatusEnded

+ const ExecutionStatusInitDone

+ const ExecutionStatusInitExecutors

+ const ExecutionStatusInitVUs

+ const ExecutionStatusInterrupted

+ const ExecutionStatusPausedBeforeRun

+ const ExecutionStatusRunning

+ const ExecutionStatusSetup

+ const ExecutionStatusStarted

+ const ExecutionStatusTeardown

+ func ExecutionStatusString(s string) (ExecutionStatus, error)

+ func ExecutionStatusValues() []ExecutionStatus

+ func (i ExecutionStatus) IsAExecutionStatus() bool

+ func (i ExecutionStatus) String() string

+ type ExecutionStep struct

+ MaxUnplannedVUs uint64

+ PlannedVUs uint64

+ TimeOffset time.Duration

+ type ExecutionTuple struct

+ Segment *ExecutionSegment

+ SegmentIndex int

+ Sequence *ExecutionSegmentSequenceWrapper

+ func NewExecutionTuple(segment *ExecutionSegment, sequence *ExecutionSegmentSequence) (*ExecutionTuple, error)

+ func (et *ExecutionTuple) GetNewExecutionTupleFromValue(value int64) (*ExecutionTuple, error)

+ func (et *ExecutionTuple) GetStripedOffsets() (int64, []int64, int64)

+ func (et *ExecutionTuple) ScaleInt64(value int64) int64

+ func (et *ExecutionTuple) String() string

+ type Executor interface

+ GetConfig func() ExecutorConfig

+ GetLogger func() *logrus.Entry

+ GetProgress func() *pb.ProgressBar

+ Init func(ctx context.Context) error

+ Run func(ctx context.Context, engineOut chan<- workerMetrics.SampleContainer, ...) error

+ type ExecutorConfig interface

+ GetDescription func(*ExecutionTuple) string

+ GetEnv func() map[string]string

+ GetExec func() string

+ GetExecutionRequirements func(*ExecutionTuple) []ExecutionStep

+ GetGracefulStop func() time.Duration

+ GetMaxExecutorVUs func() int64

+ GetName func() string

+ GetStartTime func() time.Duration

+ GetTags func() map[string]string

+ GetType func() string

+ HasWork func(*ExecutionTuple) bool

+ IsDistributable func() bool

+ NewExecutor func(*ExecutionState, *logrus.Entry) (Executor, error)

+ ScaleOptions func(subFraction float64) ExecutorConfig

+ Validate func() []error

+ func GetParsedExecutorConfig(name, configType string, rawJSON []byte) (result ExecutorConfig, err error)

+ type ExecutorConfigConstructor func(name string, rawJSON []byte) (ExecutorConfig, error)

+ type Group struct

+ Checks map[string]*Check

+ Groups map[string]*Group

+ ID string

+ Name string

+ OrderedChecks []*Check

+ OrderedGroups []*Group

+ Parent *Group

+ Path string

+ func NewGroup(name string, parent *Group) (*Group, error)

+ func (g *Group) Check(name string) (*Check, error)

+ func (g *Group) Group(name string) (*Group, error)

+ type HostAddress net.TCPAddr

+ func NewHostAddress(ip net.IP, portString string) (*HostAddress, error)

+ func (h *HostAddress) MarshalText() ([]byte, error)

+ func (h *HostAddress) String() string

+ func (h *HostAddress) UnmarshalText(text []byte) error

+ type IPNet struct

+ func ParseCIDR(s string) (*IPNet, error)

+ func (ipnet *IPNet) MarshalText() ([]byte, error)

+ func (ipnet *IPNet) UnmarshalText(b []byte) error

+ type InitVUFunc func(context.Context, *logrus.Entry, *WorkerInfo) (InitializedVU, error)

+ type InitializedVU interface

+ Activate func(*VUActivationParams) ActiveVU

+ GetID func() uint64

+ type KeyValueItem struct

+ Key string

+ Value string

+ type LiveUpdatableExecutor interface

+ UpdateConfig func(ctx context.Context, newConfig interface{}) error

+ type MarkMessage struct

+ Mark string

+ Message map[string]interface{}

+ type Message struct

+ ChildJobId string

+ JobId string

+ Message string

+ MessageType string

+ Time time.Time

+ WorkerId string

+ type MultiSlotLimiter struct

+ func NewMultiSlotLimiter(slots int) *MultiSlotLimiter

+ func (l *MultiSlotLimiter) Slot(s string) SlotLimiter

+ type Options struct

+ Batch null.Int

+ BatchPerHost null.Int

+ BlacklistIPs []*IPNet

+ BlockedHostnames types.NullHostnameTrie

+ DNS types.DNSConfig

+ DiscardResponseBodies null.Bool

+ Duration types.NullDuration

+ ExecutionMode types.NullExecutionMode

+ ExecutionSegment *ExecutionSegment

+ ExecutionSegmentSequence *ExecutionSegmentSequence

+ External map[string]json.RawMessage

+ HTTPDebug null.String

+ Hosts map[string]*HostAddress

+ InsecureSkipTLSVerify null.Bool

+ Iterations null.Int

+ LoadDistribution types.NullLoadDistribution

+ MaxPossibleVUs null.Int

+ MaxRedirects null.Int

+ MetricSamplesBufferSize null.Int

+ MinIterationDuration types.NullDuration

+ NoConnectionReuse null.Bool

+ NoCookiesReset null.Bool

+ NoSetup null.Bool

+ NoTeardown null.Bool

+ NoVUConnectionReuse null.Bool

+ OutputConfig types.NullOutputConfig

+ Paused null.Bool

+ RPS null.Int

+ RunTags map[string]string

+ Scenarios ScenarioConfigs

+ SetupTimeout types.NullDuration

+ Stages []Stage

+ SummaryTimeUnit null.String

+ SummaryTrendStats []string

+ SystemTags *workerMetrics.SystemTagSet

+ TLSAuth []*TLSAuth

+ TLSCipherSuites *TLSCipherSuites

+ TLSVersion *TLSVersions

+ TeardownTimeout types.NullDuration

+ Thresholds map[string]workerMetrics.Thresholds

+ Throw null.Bool

+ UserAgent null.String

+ VUs null.Int

+ func (o Options) Apply(opts Options) Options

+ func (o Options) Clone() Options

+ func (o Options) ForEachSpecified(structTag string, callback func(key string, value interface{}))

+ func (o Options) Validate() []error

+ type PausableExecutor interface

+ SetPaused func(bool) error

+ type RunStatus int

+ const RunStatusAbortedLimit

+ const RunStatusAbortedScriptError

+ const RunStatusAbortedSystem

+ const RunStatusAbortedThreshold

+ const RunStatusAbortedUser

+ const RunStatusCreated

+ const RunStatusFinished

+ const RunStatusInitializing

+ const RunStatusQueued

+ const RunStatusRunning

+ const RunStatusTimedOut

+ const RunStatusValidated

+ type Runner interface

+ GetDefaultGroup func() *Group

+ GetOptions func() Options

+ GetSetupData func() []byte

+ IsExecutable func(string) bool

+ NewVU func(idLocal, idGlobal uint64, out chan<- workerMetrics.SampleContainer, ...) (InitializedVU, error)

+ RetrieveMetricsJSON func(context.Context, *Summary) ([]byte, error)

+ SetOptions func(opts Options) error

+ SetSetupData func([]byte)

+ Setup func(ctx context.Context, out chan<- workerMetrics.SampleContainer, ...) error

+ Teardown func(ctx context.Context, out chan<- workerMetrics.SampleContainer, ...) error

+ type RuntimeOptions struct

+ CompatibilityMode null.String

+ Env map[string]string

+ IncludeSystemEnvVars null.Bool

+ KeyWriter null.String

+ NoThresholds null.Bool

+ SummaryExport null.String

+ TestType null.String

+ type ScenarioConfigs map[string]ExecutorConfig

+ func (scs *ScenarioConfigs) UnmarshalJSON(data []byte) error

+ func (scs ScenarioConfigs) GetFullExecutionRequirements(et *ExecutionTuple) []ExecutionStep

+ func (scs ScenarioConfigs) GetSortedConfigs() []ExecutorConfig

+ func (scs ScenarioConfigs) Validate() (errors []error)

+ type ScenarioState struct

+ Executor string

+ Name string

+ ProgressFn func() (float64, []string)

+ StartTime time.Time

+ func GetScenarioState(ctx context.Context) *ScenarioState

+ type SegmentedIndex struct

+ func NewSegmentedIndex(et *ExecutionTuple) *SegmentedIndex

+ func (s *SegmentedIndex) GoTo(value int64) (int64, int64)

+ func (s *SegmentedIndex) Next() (int64, int64)

+ func (s *SegmentedIndex) Prev() (int64, int64)

+ type SlotLimiter chan struct

+ func NewSlotLimiter(slots int) SlotLimiter

+ func (sl SlotLimiter) Begin()

+ func (sl SlotLimiter) End()

+ type Stage StageFields

+ func (s *Stage) UnmarshalJSON(b []byte) error

+ func (s *Stage) UnmarshalText(b []byte) error

+ func (s Stage) MarshalJSON() ([]byte, error)

+ type StageFields struct

+ Duration types.NullDuration

+ Target null.Int

+ type State struct

+ BPool *bpool.BufferPool

+ BuiltinMetrics *workerMetrics.BuiltinMetrics

+ CookieJar *cookiejar.Jar

+ Dialer DialContexter

+ GetScenarioGlobalVUIter func() uint64

+ GetScenarioLocalVUIter func() uint64

+ GetScenarioVUIter func() uint64

+ Group *Group

+ Iteration int64

+ Logger *logrus.Logger

+ Options Options

+ RPSLimit *rate.Limiter

+ Samples chan<- workerMetrics.SampleContainer

+ TLSConfig *tls.Config

+ Tags *TagMap

+ Transport http.RoundTripper

+ VUID uint64

+ VUIDGlobal uint64

+ func (s *State) CloneTags() map[string]string

+ type Summary struct

+ Metrics map[string]*workerMetrics.Metric

+ RootGroup *Group

+ TestRunDuration time.Duration

+ UIState UIState

+ type TLSAuth struct

+ func (c *TLSAuth) Certificate() (*tls.Certificate, error)

+ func (c *TLSAuth) UnmarshalJSON(data []byte) error

+ type TLSAuthFields struct

+ Cert string

+ Domains []string

+ Key string

+ Password null.String

+ type TLSCipherSuites []uint16

+ func (s *TLSCipherSuites) MarshalJSON() ([]byte, error)

+ func (s *TLSCipherSuites) UnmarshalJSON(data []byte) error

+ type TLSVersion int

+ func (v *TLSVersion) UnmarshalJSON(data []byte) error

+ func (v TLSVersion) MarshalJSON() ([]byte, error)

+ type TLSVersions TLSVersionsFields

+ func (v *TLSVersions) UnmarshalJSON(data []byte) error

+ type TLSVersionsFields struct

+ Max TLSVersion

+ Min TLSVersion

+ type TagMap struct

+ func NewTagMap(m map[string]string) *TagMap

+ func (tg *TagMap) Clone() map[string]string

+ func (tg *TagMap) Delete(k string)

+ func (tg *TagMap) Get(k string) (string, bool)

+ func (tg *TagMap) Len() int

+ func (tg *TagMap) Set(k, v string)

+ type TestPreInitState struct

+ BuiltinMetrics *workerMetrics.BuiltinMetrics

+ KeyLogger io.Writer

+ Logger *logrus.Logger

+ Registry *workerMetrics.Registry

+ RuntimeOptions RuntimeOptions

+ type TestRunState struct

+ Options Options

+ Runner Runner

+ type UIState struct

+ IsStdErrTTY bool

+ IsStdOutTTY bool

+ type VUActivationParams struct

+ DeactivateCallback func(InitializedVU)

+ Env map[string]string

+ Exec string

+ GetNextIterationCounters func() (uint64, uint64)

+ RunContext context.Context

+ Scenario string

+ Tags map[string]string

+ type WorkerInfo struct

+ ChildJobId string

+ Client *redis.Client

+ Collection *Collection

+ CreditsManager *lib.CreditsManager

+ Ctx context.Context

+ Environment *Environment

+ FinalRequest map[string]interface{}

+ Gs *BaseGlobalState

+ JobId string

+ OrchestratorId string

+ ScopeId string

+ Standalone bool

+ SubFraction float64

+ UnderlyingRequest map[string]interface{}

+ VerifiedDomains []string

+ WorkerId string

+ WorkerOptions Options

+ type WorkerState struct

+ Status string

+ WorkerId string

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