workerclient

package module

Go to main page

Versions in this module

v0

v0.0.4

Sep 28, 2025

Changes in this version

+ const InnerVarWorkerConcurrency

type CaseBaseInfo

+ TotalMaxConcurrency uint64

+ WorkerConcurrency uint64

type CaseRunnerInfo

+ WorkerConcurrency uint64

v0.0.3

Sep 28, 2025

Changes in this version

+ type CaseParams struct

+ CaseRunnerInfo CaseRunnerInfo

+ CoroutineParams map[string]string

+ GlobalParams map[string]string

type TestStep

+ func (ts *TestStep) GetStepIndex() string

v0.0.2

Sep 28, 2025

v0.0.1

Sep 24, 2025

Changes in this version

+ const InnerVarExecutorIndex

+ const InnerVarGoroutineId

+ const InnerVarName

+ const InnerVarWorkerIndex

+ const InnerVarWorkerSize

+ const InnerVarWorkerTotal

+ func UnserializeTDigest(nodes []TDNode) *tdigest.TDigest

+ type CallMonitor struct

+ BeginTime uint64

+ FailCount uint64

+ LastTime uint64

+ MaxRt uint64

+ MinRt uint64

+ SuccCount uint64

+ TotalCount uint64

+ TotalRt uint64

+ type CallTimeMapKey struct

+ CaseName string

+ IsWholeCase bool

+ MetricName string

+ StatusCode int

+ StepName string

+ Success bool

+ TaskId string

+ Ts int

+ WorkerName string

+ type CallTimeMetric struct

+ Key CallTimeMapKey

+ Value []TDNode

+ type CaseBaseInfo struct

+ DurationMinutes uint64

+ GlobalParams map[string]string

+ MaxConcurrencyCount uint64

+ Name string

+ RampingSeconds uint64

+ TaskId string

+ WorkName string

+ WorkerSize uint64

+ type CaseGenFunc func(caseRunnerInfo CaseRunnerInfo) *TestCase

+ type CaseParmas struct

+ CaseRunnerInfo CaseRunnerInfo

+ CoroutineParams map[string]string

+ GlobalParams map[string]string

+ RuntimeParams map[string]string

+ type CaseRunner struct

+ ActiveConcurrencyCount int64

+ CoordinatorApi string

+ GlobalParams map[string]string

+ Info CaseRunnerInfo

+ IsRunning bool

+ MetricsChan chan ([]*CallTimeMetric)

+ Output *Output

+ TestCase *TestCase

+ func (cr *CaseRunner) HandleOuput()

+ func (cr *CaseRunner) Run()

+ func (cr *CaseRunner) SendMetrics()

+ func (cr *CaseRunner) SetGlobalParams(globalParams map[string]string)

+ func (cr *CaseRunner) StopRunChannel()

+ type CaseRunnerInfo struct

+ DurationMinutes uint64

+ MaxConcurrencyInThisWoker uint64

+ RampingSeconds uint64

+ WorkerIndex uint64

+ WorkerName string

+ WorkerSize uint64

+ WorkerTotal uint64

+ type CaseSummary struct

+ CallMonitors map[string]*CallMonitor

+ LastConcurrencyCount uint64

+ type HTTPClient struct

+ func NewHTTPClient(timeout time.Duration) *HTTPClient

+ func (c *HTTPClient) PostJSON(url string, requestBody interface{}, responseBody interface{}) error

+ type IResultV1 interface

+ GetBeginTime func() int64

+ GetEndTime func() int64

+ GetFailureMessage func() string

+ GetMethod func() string

+ GetName func() string

+ GetReceivedBytes func() int

+ GetRequestBody func() string

+ GetRequestHeader func() map[string]string

+ GetResponseBody func() string

+ GetResponseCode func() int

+ GetResponseHeader func() map[string]string

+ GetSentBytes func() int

+ GetSubResults func() []interface{}

+ GetUrl func() string

+ IsSuccess func() bool

+ type Output struct

+ ResChans chan IResultV1

+ type ResponseBody struct

+ Code int

+ Data interface{}

+ Msg string

+ type Result struct

+ BeginTime int64

+ EndTime int64

+ FailureMessage string

+ Method string

+ Name string

+ ReceivedBytes int

+ RequestBody string

+ RequestHeader map[string]string

+ ResponseBody string

+ ResponseCode int

+ ResponseHeader map[string]string

+ SentBytes int

+ SubIndex int

+ SubResults []interface{}

+ Success bool

+ Url string

+ func AcquireResult(name string) *Result

+ func (r *Result) AddSub(name string, useNamePrefix bool) *Result

+ func (r *Result) Begin()

+ func (r *Result) End()

+ func (r *Result) GetBeginTime() int64

+ func (r *Result) GetEndTime() int64

+ func (r *Result) GetFailureMessage() string

+ func (r *Result) GetMethod() string

+ func (r *Result) GetName() string

+ func (r *Result) GetReceivedBytes() int

+ func (r *Result) GetRequestBody() string

+ func (r *Result) GetRequestHeader() map[string]string

+ func (r *Result) GetResponseBody() string

+ func (r *Result) GetResponseCode() int

+ func (r *Result) GetResponseHeader() map[string]string

+ func (r *Result) GetSentBytes() int

+ func (r *Result) GetSubResults() []interface{}

+ func (r *Result) GetUrl() string

+ func (r *Result) IsSuccess() bool

+ type RpsQLimiter struct

+ Limter *ratelimiter.AttributeBasedLimiter

+ Lock sync.Mutex

+ QMap map[string]*queue.Queue

+ type RspWorkerPushStatus struct

+ ShouldRunCase bool

+ ShouldStopCase bool

+ TestCaseInfo *TestCaseInfo

+ Worker *Worker

+ type RspWorkerPushStatusBody struct

+ Code int

+ Data *RspWorkerPushStatus

+ Msg string

+ type TDNode struct

+ Count uint64

+ Mean float64

+ func SerializeTDigest(td *tdigest.TDigest) []TDNode

+ type TestCase struct

+ Name string

+ TearDown func(coroutineParams map[string]string)

+ Teststeps []*TestStep

+ func NewTestCase(caseName string) *TestCase

+ func (tc *TestCase) AddStep(ts *TestStep)

+ func (tc *TestCase) Run(globalParams, coroutineParams map[string]string, rpsQLimiter *RpsQLimiter, ...)

+ type TestCaseInfo struct

+ BaseInfo *CaseBaseInfo

+ BeginTime uint64

+ LastTime uint64

+ RuningWorkerIds []string

+ RunningWorkerCount uint64

+ Status string

+ Summary *CaseSummary

+ WorkerTotal uint64

+ type TestCaseSummary struct

+ ActiveConcurrencyCount int64

+ Name string

+ Status string

+ TaskId string

+ type TestStep struct

+ ContinueWhenFailed bool

+ ExecWhenFunc func(caseParmas *CaseParmas, reqPamrams map[string]string) (b bool)

+ GenReqParamsFunc func(caseParmas *CaseParmas) (p map[string]string)

+ PostFunc func(caseParmas *CaseParmas, reqPamrams map[string]string, res IResultV1)

+ PreFunc func(caseParmas *CaseParmas, reqPamrams map[string]string)

+ ReqPluginFunc func(reqPamrams map[string]string) (res interface{})

+ RpsLimitFunc func(caseRunnerInfo CaseRunnerInfo, globalParams map[string]string) (rps uint64)

+ SetRuntimeParamsFunc func(caseParmas *CaseParmas)

+ StepIndex string

+ StepName string

+ type Worker struct

+ BaseInfo *WorkerBaseInfo

+ LastAciveAt int64

+ type WorkerBaseInfo struct

+ ID string

+ Index int64

+ Name string

+ Status string

+ TestCases []*TestCaseSummary

+ type WorkerPushStatusParams struct

+ BaseInfo *WorkerBaseInfo

+ type WorkerRunner struct

+ CaseMaps map[string]*TestCase

+ CoordinatorApi string

+ RunningCaseRunner *CaseRunner

+ Worker *Worker

+ func NewWorkerRunner(workerName, coordinatorApi string) *WorkerRunner

+ func (rw *WorkerRunner) AddTestCase(tc *TestCase)

+ func (rw *WorkerRunner) PushStatus() (rwps *RspWorkerPushStatus)

+ func (rw *WorkerRunner) RealRun()

+ func (rw *WorkerRunner) Run()

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