Versions in this module Expand all Collapse all v1 v1.999.1-test-release Sep 13, 2024retracted v1.50.4 Dec 19, 2024 Changes in this version + var ErrMissingSegmentType = errors.New("Segment Type myst be set") type Segment + EndTime time.Time + StartTime time.Time + Type SegmentType + type SegmentType string + const SegmentType_Plain + const SegmentType_Steps v1.50.3 Nov 27, 2024 v1.50.2 Oct 28, 2024 Changes in this version type Stats + RunStarted atomic.Bool v1.50.1 Sep 20, 2024 v1.50.0 Sep 4, 2024 v1.49.0 Sep 3, 2024 v0 v0.4.10 Aug 28, 2024 v0.4.9 Aug 28, 2024 v0.4.8 Aug 28, 2024 Changes in this version + const CallGroupLabel + const DefaultCallResultBufLen + const DefaultCallTimeout + const DefaultGenName + const DefaultLimitsCPU + const DefaultLimitsMemory + const DefaultRateLimitUnitDuration + const DefaultRequestsCPU + const DefaultRequestsMemory + const DefaultSetupTimeout + const DefaultStatsPollInterval + const DefaultStepChangePrecision + const DefaultTeardownTimeout + const K8sStatePollInterval + const LogLevelEnvVar + var CPUIdleThresholdPercentage = 20 + var DefaultBuildScript []byte + var DefaultDockerIgnorefile []byte + var DefaultDockerfile []byte + var ErrCallTimeout = errors.New("generator request call timeout") + var ErrInvalidLabels = errors.New("invalid Loki labels, labels should be [a-z][A-Z][0-9] and _") + var ErrInvalidScheduleType = errors.New("schedule type must be either of wasp.RPS, wasp.VU, use package constants") + var ErrInvalidSegmentDuration = errors.New("SegmentDuration must be defined") + var ErrNoCfg = errors.New("config is nil") + var ErrNoGun = errors.New("rps load scheduleSegments selected but gun implementation is nil") + var ErrNoImpl = errors.New("either \"gun\" or \"vu\" implementation must provided") + var ErrNoJobs = errors.New(...) + var ErrNoNamespace = errors.New("namespace is empty") + var ErrNoSchedule = errors.New("no schedule segments were provided") + var ErrNoVU = errors.New("vu load scheduleSegments selected but vu implementation is nil") + var ErrSetup = errors.New("generator request setup error") + var ErrSetupTimeout = errors.New("generator request setup timeout") + var ErrStartFrom = errors.New("from must be > 0") + var ErrTeardown = errors.New("generator request teardown error") + var ErrTeardownTimeout = errors.New("generator request teardown timeout") + var MEMFreeThresholdPercentage = 0 + var ResourcesThresholdCheckInterval = 5 * time.Second + func CPUCheckLoop() + func CheckDashboardAlerts(grafanaClient *grafana.Client, from, to time.Time, dashboardUID string) ([]grafana.Annotation, error) + func ExecCmd(command string) error + func ExecCmdWithStreamFunc(command string, outputFunction func(string)) error + func GetLocalK8sDeps() (*kubernetes.Clientset, *rest.Config, error) + func GetLogger(t *testing.T, componentName string) zerolog.Logger + func LabelsMapToModel(m map[string]string) model.LabelSet + type AlertChecker struct + RequirementLabelKey string + T *testing.T + func NewAlertChecker(t *testing.T) *AlertChecker + func (m *AlertChecker) AnyAlerts(dashboardUUID, requirementLabelValue string) ([]grafana.AlertGroupsResponse, error) + type ClusterConfig struct + BuildCtxPath string + BuildScriptPath string + ChartPath string + DockerCmdExecPath string + DockerIgnoreFilePath string + DockerfilePath string + HelmDeployTimeoutSec string + HelmValues map[string]string + ImageTag string + KeepJobs bool + Namespace string + RegistryName string + RepoName string + UpdateImage bool + func (m *ClusterConfig) Defaults() error + func (m *ClusterConfig) Validate() (err error) + type ClusterProfile struct + Cancel context.CancelFunc + Ctx context.Context + func NewClusterProfile(cfg *ClusterConfig) (*ClusterProfile, error) + func (m *ClusterProfile) Run() error + type Config struct + CallResultBufLen int + CallTimeout time.Duration + FailOnErr bool + GenName string + Gun Gun + Labels map[string]string + LoadType ScheduleType + Logger zerolog.Logger + LokiConfig *LokiConfig + RateLimitUnitDuration time.Duration + SamplerConfig *SamplerConfig + Schedule []*Segment + SetupTimeout time.Duration + SharedData interface{} + StatsPollInterval time.Duration + T *testing.T + TeardownTimeout time.Duration + VU VirtualUser + func (lgc *Config) Validate() error + type Generator struct + Cfg *Config + Log zerolog.Logger + Responses *Responses + ResponsesChan chan *Response + ResponsesCtx context.Context + ResponsesWaitGroup *sync.WaitGroup + func NewGenerator(cfg *Config) (*Generator, error) + func (g *Generator) Errors() []string + func (g *Generator) GetData() *ResponseData + func (g *Generator) InputSharedData() interface{} + func (g *Generator) Pause() + func (g *Generator) Resume() + func (g *Generator) Run(wait bool) (interface{}, bool) + func (g *Generator) Stats() *Stats + func (g *Generator) StatsJSON() map[string]interface{} + func (g *Generator) Stop() (interface{}, bool) + func (g *Generator) Wait() (interface{}, bool) + type GrafanaOpts struct + AnnotateDashboardUID string + CheckDashboardAlertsAfterRun string + GrafanaToken string + GrafanaURL string + WaitBeforeAlertCheck time.Duration + type Gun interface + Call func(l *Generator) *Response + type HTTPMockServer struct + Sleep time.Duration + func NewHTTPMockServer(cfg *HTTPMockServerConfig) *HTTPMockServer + func (s *HTTPMockServer) Run() + func (s *HTTPMockServer) URL() string + type HTTPMockServerConfig struct + FirstAPIHTTPCode int + FirstAPILatency time.Duration + SecondAPIHTTPCode int + SecondAPILatency time.Duration + type K8sClient struct + ClientSet *kubernetes.Clientset + RESTConfig *rest.Config + func NewK8sClient() *K8sClient + func (m *K8sClient) TrackJobs(ctx context.Context, nsName, syncLabel string, jobNum int, keepJobs bool) error + type LokiClient struct + func NewLokiClient(extCfg *LokiConfig) (*LokiClient, error) + func (m *LokiClient) Handle(ls model.LabelSet, t time.Time, s string) error + func (m *LokiClient) HandleStruct(ls model.LabelSet, t time.Time, st interface{}) error + func (m *LokiClient) StopNow() + type LokiConfig struct + BackoffConfig backoff.Config + BasicAuth string + BatchSize int + BatchWait time.Duration + DropRateLimitedBatches bool + ExposePrometheusMetrics bool + Headers map[string]string + MaxErrors int + MaxLineSize int + MaxLineSizeTruncate bool + MaxStreams int + TenantID string + Timeout time.Duration + Token string + URL string + func DefaultLokiConfig() *LokiConfig + func NewEnvLokiConfig() *LokiConfig + func NewLokiConfig(endpoint *string, tenant *string, basicAuth *string, token *string) *LokiConfig + type LokiLogWrapper struct + MaxErrors int + func NewLokiLogWrapper(maxErrors int) *LokiLogWrapper + func (m *LokiLogWrapper) Log(kvars ...interface{}) error + func (m *LokiLogWrapper) SetClient(c *LokiClient) + type MockGun struct + Data []string + func NewMockGun(cfg *MockGunConfig) *MockGun + func (m *MockGun) Call(l *Generator) *Response + type MockGunConfig struct + CallSleep time.Duration + FailRatio int + InternalStop bool + TimeoutRatio int + type MockHTTPGun struct + Data []string + func NewHTTPMockGun(cfg *MockHTTPGunConfig) *MockHTTPGun + func (m *MockHTTPGun) Call(l *Generator) *Response + type MockHTTPGunConfig struct + TargetURL string + type MockVirtualUser struct + Data []string + func NewMockVU(cfg *MockVirtualUserConfig) *MockVirtualUser + func (m *MockVirtualUser) Call(l *Generator) + func (m *MockVirtualUser) Clone(_ *Generator) VirtualUser + func (m *MockVirtualUser) Setup(_ *Generator) error + func (m *MockVirtualUser) Teardown(_ *Generator) error + type MockVirtualUserConfig struct + CallSleep time.Duration + FailRatio int + SetupFailure bool + SetupSleep time.Duration + TeardownFailure bool + TeardownSleep time.Duration + TimeoutRatio int + type MockWSServer struct + Logf func(f string, v ...interface{}) + Sleep time.Duration + func (s MockWSServer) ServeHTTP(w http.ResponseWriter, r *http.Request) + type Profile struct + Generators []*Generator + ProfileID string + func NewProfile() *Profile + func (m *Profile) Add(g *Generator, err error) *Profile + func (m *Profile) Pause() + func (m *Profile) Resume() + func (m *Profile) Run(wait bool) (*Profile, error) + func (m *Profile) Wait() + func (m *Profile) WithGrafana(opts *GrafanaOpts) *Profile + type Response struct + Data interface{} + Duration time.Duration + Error string + Failed bool + FinishedAt *time.Time + Group string + Path string + StartedAt *time.Time + StatusCode string + Timeout bool + type ResponseData struct + FailResponses *SliceBuffer[*Response] + OKData *SliceBuffer[any] + OKResponses *SliceBuffer[*Response] + type Responses struct + func NewResponses(ch chan *Response) *Responses + func (m *Responses) Err(r *resty.Response, group string, err error) + func (m *Responses) OK(r *resty.Response, group string) + type Sampler struct + func NewSampler(cfg *SamplerConfig) *Sampler + func (m *Sampler) ShouldRecord(cr *Response, s *Stats) bool + type SamplerConfig struct + SuccessfulCallResultRecordRatio int + type ScheduleType string + const RPS + const VU + type Segment struct + Duration time.Duration + From int64 + func Combine(segs ...[]*Segment) []*Segment + func CombineAndRepeat(times int, segs ...[]*Segment) []*Segment + func Plain(from int64, duration time.Duration) []*Segment + func Steps(from, increase int64, steps int, duration time.Duration) []*Segment + func (ls *Segment) Validate() error + type SliceBuffer struct + Capacity int + Data []T + Idx int + func NewSliceBuffer[T any](cap int) *SliceBuffer[T] + func (m *SliceBuffer[T]) Append(s T) + type Stats struct + CallTimeout atomic.Int64 + CurrentRPS atomic.Int64 + CurrentSegment atomic.Int64 + CurrentTimeUnit int64 + CurrentVUs atomic.Int64 + Duration int64 + Failed atomic.Int64 + LastSegment atomic.Int64 + RunFailed atomic.Bool + RunPaused atomic.Bool + RunStopped atomic.Bool + SamplesRecorded atomic.Int64 + SamplesSkipped atomic.Int64 + Success atomic.Int64 + type VUControl struct + func NewVUControl() *VUControl + func (m *VUControl) Stop(_ *Generator) + func (m *VUControl) StopChan() chan struct{} + type VirtualUser interface + Call func(l *Generator) + Clone func(l *Generator) VirtualUser + Setup func(l *Generator) error + Stop func(l *Generator) + StopChan func() chan struct{} + Teardown func(l *Generator) error + type WSMockVU struct + Data []string + func NewWSMockVU(cfg *WSMockVUConfig) *WSMockVU + func (m *WSMockVU) Call(l *Generator) + func (m *WSMockVU) Clone(_ *Generator) VirtualUser + func (m *WSMockVU) Setup(l *Generator) error + func (m *WSMockVU) Teardown(_ *Generator) error + type WSMockVUConfig struct + TargetURl string
Go to main page