Versions in this module Expand all Collapse all v1 v1.0.0 Apr 5, 2022 Changes in this version + var AvailableArchitectures = []SystemArchitecture + var ErrAgentResponseTimeout = errors.New("agent did not respond within timeout limit") + var ErrCommandIDNotFound = errors.New("command ID not found") + var ErrRunNotFound = errors.New("run not found") + var ErrWrongMessageType = errors.New("received wrong message type") + func ConfigureCommitForDefaultTests(hash string) + func ConfigureLaunchTemplatesForDefaultTests(templateIDSmall, templateIDLarge string) + func CreateArchive(sourceFolder, targetPath string) error + func CreateArchiveToStream(sourceFolder string, target io.Writer) error + func DataDir() string + func RandomID(len int) (string, error) + func RandomIDBytes(len int) ([]byte, error) + func ReadErrChan(c chan error) error + func S3customResolver() aws.EndpointResolver + func TarExtract(path string) error + func TarExtractFlat(path string, flat bool, createNoDir bool) error + func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool + type AgentSystemInfo struct + AWS bool + Architecture string + AvailableDiskSpace int64 + AvailableMemory int64 + EC2InstanceID string + HostName string + NumCPU int + OperatingSystem string + PrivateIPs []net.IP + PublicIP net.IP + TotalMemory int64 + func (a AgentSystemInfo) ToString() string + type BlockLatencyResult struct + Average float64 + Max float64 + Min float64 + StdDev float64 + type ExecutedCommand struct + AgentID int32 + CommandID string + Completed time.Time + Description string + Environment []string + ExitCode int + InternalError string + Params []string + Stderr string + Stdout string + type File struct + Contents []byte + FilePath string + type MatrixResult struct + Config *TestRunNormalizedConfig + MaxCompletedDate time.Time + MinCompletedDate time.Time + ResultAvg *TestResult + ResultCount int + ResultDetails []*TestResult + Results []*TestResult + type PacketMetadata struct + Length uint16 + SourceIP [4]byte + SourcePort uint16 + TargetIP [4]byte + TargetPort uint16 + Timestamp uint16 + func ReadPacketMetadata(r io.Reader) (*PacketMetadata, error) + func (p *PacketMetadata) String() string + func (p *PacketMetadata) WriteTo(w io.Writer) error + type S3Download struct + Retries int + SourceBucket string + SourcePath string + SourceRegion string + TargetPath string + type S3Upload struct + Retries int + SourcePath string + TargetBucket string + TargetPath string + TargetRegion string + type SystemArchitecture struct + DefaultTest *TestRun + ID string + Name string + Roles []SystemArchitectureRole + type SystemArchitectureRole struct + Role SystemRole + ShortTitle string + Title string + type SystemRole string + const SystemRoleArchiver + const SystemRoleAtomizerCliWatchtower + const SystemRoleCoordinator + const SystemRoleRaftAtomizer + const SystemRoleSentinel + const SystemRoleSentinelTwoPhase + const SystemRoleShard + const SystemRoleShardTwoPhase + const SystemRoleTwoPhaseGen + const SystemRoleWatchtower + type TestResult struct + BlockLatencies map[string]BlockLatencyResult + LatencyAvg float64 + LatencyMax float64 + LatencyMin float64 + LatencyPercentiles []TestResultPercentile + LatencyStd float64 + ThroughputAvg float64 + ThroughputAvg2 float64 + ThroughputAvgs map[string]float64 + ThroughputMax float64 + ThroughputMin float64 + ThroughputPercentiles []TestResultPercentile + ThroughputStd float64 + type TestResultPercentile struct + Bucket float64 + Value float64 + type TestRun struct + AWSInstancesStopped bool + AgentDataAtEnd []TestRunAgentData + AgentDataAtStart []TestRunAgentData + Architecture string + ArchiverLogLevel string + AtomizerLogLevel string + BatchDelay int + BatchSize int + CommitHash string + Completed time.Time + ControllerCommit string + CoordinatorLogLevel string + Created time.Time + CreatedByThumbprint string + Debug bool + DeliberateFailures []string + Details string + DontRunBefore time.Time + ElectionTimeoutLower int + ElectionTimeoutUpper int + ExecutedCommands []*ExecutedCommand + FixedTxRate float64 + Heartbeat int + ID string + InvalidTxRate float64 + KeepTimedOutAgents bool + LoadGenInputCount int + LoadGenOutputCount int + LoadGenThreads int + LogBuffer string + MaxRetries int + Params []string + PendingResultDownloads []S3Download + PerfSampleRate int + PerformanceDataAvailable bool + PreseedCount int64 + PreseedShards bool + Priority int + RaftMaxBatch int + RecordNetworkTraffic bool + Repeat int + Result *TestResult + RetryOnFailure bool + RetrySpawnChan chan bool + Roles []*TestRunRole + RunPerf bool + STXOCacheDepth int + SampleCount int + SeederHash string + SentinelLogLevel string + ShardLogLevel string + ShardReplicationFactor int + SkipCleanUp bool + SnapshotDistance int + Started time.Time + Status TestRunStatus + Sweep string + SweepID string + SweepOneAtATime bool + SweepParameter string + SweepParameterIncrement float64 + SweepParameterStart float64 + SweepParameterStop float64 + SweepRoleRuns int + SweepRoles []*TestRunRole + SweepTimeMinutes int + SweepTimeRuns int + TargetBlockInterval int + TerminateChan chan bool + TrimSamplesAtStart int + TrimZeroesAtEnd bool + TrimZeroesAtStart bool + WatchtowerBlockCacheSize int + WatchtowerErrorCacheSize int + WatchtowerLogLevel string + WindowSize int + func ExpandSweepRun(originalTr *TestRun, sweepID string) []*TestRun + func FindMissingSweepRuns(trs []*TestRun, sweepID string) []*TestRun + func (tr *TestRun) AddExecutedCommand(cmd *ExecutedCommand) + func (tr *TestRun) FullLog() string + func (tr *TestRun) LogFilePath() string + func (tr *TestRun) LogTail() string + func (tr *TestRun) NormalizedConfig() *TestRunNormalizedConfig + func (tr *TestRun) NormalizedConfigWithAgentData(agentData bool) *TestRunNormalizedConfig + func (tr *TestRun) ReadLogTail() + func (tr *TestRun) WriteLog(line string) + type TestRunAgentData struct + AgentID int32 + AgentVersion string + AwsRegion string + PingRTT float64 + SystemInfo AgentSystemInfo + type TestRunNormalizedConfig struct + Architecture string + AtomizerCPU int + AtomizerCount int + AtomizerRAM int + BatchDelay int + BatchSize int + ClientCPU int + ClientCount int + ClientRAM int + CommitHash string + ControllerCommitHash string + CoordinatorCPU int + CoordinatorCount int + CoordinatorRAM int + DayUTC int + ElectionTimeoutLower int + ElectionTimeoutUpper int + FixedTxRate float64 + Heartbeat int + HourUTC int + InvalidTxRate float64 + LoadGenInputCount int + LoadGenOutputCount int + MonthUTC int + MultiRegion bool + PreseedCount int64 + PreseedShards bool + RaftMaxBatch int + STXOCacheDepth int + SentinelCPU int + SentinelCount int + SentinelRAM int + ShardCPU int + ShardCount int + ShardRAM int + ShardReplicationFactor int + SnapshotDistance int + TargetBlockInterval int + WatchtowerCPU int + WatchtowerCount int + WatchtowerRAM int + WindowSize int + func (trc *TestRunNormalizedConfig) Hash() []byte + type TestRunRole struct + AgentID int32 + AwsAgentInstanceId string + AwsLaunchTemplateID string + Fail bool + Failure *TestRunRoleFailure + Index int + Role SystemRole + type TestRunRoleFailure struct + After int + Failed bool + type TestRunStatus string + const TestRunStatusAborted + const TestRunStatusCanceled + const TestRunStatusCompleted + const TestRunStatusFailed + const TestRunStatusInterrupted + const TestRunStatusQueued + const TestRunStatusRunning + const TestRunStatusUnknown
Go to main page