atsf4g_go_robot_case

Apr 14, 2026

Changes in this version

+ var ProgressBarRunning atomic.Int32

+ var StopCh chan struct

+ var StopedCh chan struct

+ func CloseProgressBar()

+ func ParseSetFlags(sets []string) map[string]string

+ func ShowProgressBar()

+ func SubstituteVariables(content string, vars map[string]string) string

type TaskActionCase

+ func (t *TaskActionCase) InitUserOnRunning(u user.User) error

+ func (t *TaskActionCase) IsTakenActionGuard() bool

Apr 13, 2026

Changes in this version

type CaseFileLine

+ BackgroundRunning bool

type Params

+ func ParseLine(cmd []string) (Params, error)

Apr 13, 2026

Changes in this version

+ func AutoCompleteControlName(_ string) []string

+ func IsControlLine(firstArg string) bool

+ func RegisterControl(name string, fn ControlFunc, dispatchMode ControlDispatchMode)

+ func RunCaseFileStandAlone(caseFile string, repeatedTime int32) error

+ func RunControlInner(ctx context.Context, params ControlParams) error

type AgentTask

+ ControlParams ControlParams

+ type CaseFileLine struct

+ Background bool

+ Control ControlParams

+ IsControl bool

+ Stress Params

+ func ParseCaseFileContent(content string, mode CaseFileMode) ([]CaseFileLine, error)

+ type CaseFileMode int

+ const CaseFileModeDistributed

+ const CaseFileModeStandalone

+ type ControlAction struct

+ DispatchMode ControlDispatchMode

+ Fn ControlFunc

+ func GetControlAction(name string) *ControlAction

+ type ControlDispatchMode int

+ const ControlDispatchAll

+ const ControlDispatchRandom

+ type ControlFunc func(ctx context.Context, args []string) error

+ type ControlParams struct

+ Args []string

+ Background bool

+ CaseIndex int

+ ErrorBreak bool

+ Name string

+ func ParseControlLine(args []string) (ControlParams, error)

type Params

+ func ParseDistributedLine(cmd []string) (Params, error)

+ func ParseStandaloneLine(cmd []string) (Params, error)

Apr 10, 2026

Changes in this version

type TaskActionCase

+ DispatchedAt time.Time

Apr 7, 2026

Changes in this version

+ func RunCaseInner(ctx context.Context, params Params, tracer report.Tracer, ...) string

+ type Params struct

+ CaseIndex int

+ CaseName string

+ ErrorBreak bool

+ ExtraArgs []string

+ OpenIDEnd int64

+ OpenIDPrefix string

+ OpenIDStart int64

+ RunTime int64

+ TargetQPS float64

+ UserBatchCount int64

+ func (p *Params) UserCount() int64

type QPSController

+ func (q *QPSController) Stop()

type TaskActionCase

+ NeedLog bool

+ TracerEntry report.TracingEntry

+ UserHolder *user.UserHolder

Mar 26, 2026

Changes in this version

type AgentTask

+ EnableLog bool

Mar 24, 2026

Changes in this version

+ func CmdRunCaseStress(_ base.TaskActionImpl, cmd []string) string

+ func RunCase(_ base.TaskActionImpl, cmd []string, caseIndex int32, beginTime time.Time) string

+ func RunCaseStress(params StressParams, tracer report.Tracer, pressure report.PressureController) string

+ func RunCaseStressWithContext(ctx context.Context, params StressParams, tracer report.Tracer, ...) string

+ type AgentTask struct

+ CaseIndex int

+ Params StressParams

+ ReportID string

+ TaskKey string

+ TaskType string

+ type AgentTaskResult struct

+ Error string

+ TaskKey string

+ Tracings int

+ type QPSController struct

+ func NewQPSController(targetQPS float64) *QPSController

+ func (q *QPSController) Acquire()

+ func (q *QPSController) CurrentQPS() float64

+ func (q *QPSController) SetQPS(qps float64)

+ type StressParams struct

+ BatchCount int64

+ CaseName string

+ ErrorBreak bool

+ ExtraArgs []string

+ OpenIDEnd int64

+ OpenIDPrefix string

+ OpenIDStart int64

+ RunTime int64

+ TargetQPS float64

+ func ParseStressLine(cmd []string) (StressParams, string)

+ func (p *StressParams) UserCount() int64

Mar 17, 2026

Changes in this version

+ func CmdRunCaseFile(_ base.TaskActionImpl, cmd []string, caseIndex int32, beginTime time.Time) string

Mar 11, 2026

Changes in this version

+ var CaseActionActor sync.Map

+ var FailedCount atomic.Int64

+ var ProgressBarCurrentCount atomic.Int64

+ var ProgressBarTotalCount int64

+ var RefreshFunc *time.Timer

+ var TotalFailedCount atomic.Int64

+ func AddProgressBarCount()

+ func AutoCompleteCaseName(string) []string

+ func ClearProgressBar()

+ func CmdRunCase(_ base.TaskActionImpl, cmd []string) string

+ func InitProgressBar(totalCount int64)

+ func RefreshProgressBar()

+ func RegisterCase(name string, fn CaseFunc, timeout time.Duration)

+ func RunCaseFile(caseFile string) error

+ func RunCaseWait(pendingCase []chan string) error

+ type CaseAction struct

+ type CaseFunc func(*TaskActionCase, string, []string) error

+ type TaskActionCase struct

+ Args []string

+ Fn CaseFunc

+ OpenId string

+ func (t *TaskActionCase) AfterYield()

+ func (t *TaskActionCase) BeforeYield()

+ func (t *TaskActionCase) HookRun() error

+ func (t *TaskActionCase) Log(format string, a ...any)