core

Aug 3, 2022

Changes in this version

type GitManager

+ DownloadFileByCommit func(ctx context.Context, gitProvider, repoSlug, commitID, filePath string, ...) (string, error)

type MessageType

+ const MsgYMLParsingRequest

+ const MsgYMLParsingResult

type SecretsManager

+ GetOauthToken func() *Oauth

+ type TASConfigDownloaderOutput struct

+ TASConfig interface{}

+ Version int

type TASConfigManager

+ GetTasConfigFilePath func(payload *Payload) (string, error)

+ type YMLParsingRequestMessage struct

+ BuildID string

+ CommitID string

+ Event EventType

+ GitProvider string

+ LicenseTier Tier

+ OrgID string

+ RepoSlug string

+ TasFileName string

+ type YMLParsingResultMessage struct

+ BuildID string

+ ErrorMsg string

+ OrgID string

+ YMLOutput TASConfigDownloaderOutput

Jul 20, 2022

Changes in this version

+ type BuildAbortMsg struct

+ BuildID string

type DockerRunner

+ KillContainerForBuildID func(buildID string) error

type MessageType

+ const MsgBuildAbort

type StatusType

+ const JobAborted

Jul 15, 2022

Changes in this version

type DockerRunner

+ CopyFileToContainer func(ctx context.Context, path, fileName, containerID string, content []byte) error

+ CreateVolume func(ctx context.Context, r *RunnerOptions) error

+ FindVolumes func(volumeName string) (bool, error)

+ RemoveOldVolumes func(ctx context.Context)

+ RemoveVolume func(ctx context.Context, volumeName string) error

type SecretsManager

+ GetGitSecretBytes func() ([]byte, error)

+ GetRepoSecretBytes func(repo string) ([]byte, error)

+ type VolumeDetails struct

+ CreatedAt time.Time

+ Driver string

+ Labels map[string]string

+ Mountpoint string

+ Name string

+ Options map[string]string

+ Scope string

+ Status map[string]interface{}

Jul 15, 2022

Changes in this version

+ type SASURLPurpose string

+ const PurposeCache

+ const PurposeExecutionLogs

+ const PurposePostRunLogs

+ const PurposePreRunLogs

+ const PurposeWorkspaceCache

Jul 8, 2022

Changes in this version

+ type Builder interface

+ GetDriver func(version int) (Driver, error)

+ type DiscoveyArgs struct

+ CWD string

+ Diff map[string]int

+ DiffExists bool

+ EnvMap map[string]string

+ FrameWork string

+ FrameWorkVersion int

+ Payload *Payload

+ SecretData map[string]string

+ SmartRun bool

+ TestConfigFile string

+ TestPattern []string

+ type Driver interface

+ RunDiscovery func(ctx context.Context, payload *Payload, taskPayload *TaskPayload, oauth *Oauth, ...) error

+ RunExecution func(ctx context.Context, payload *Payload, taskPayload *TaskPayload, oauth *Oauth, ...) error

+ type ListSubModuleService interface

+ Send func(ctx context.Context, buildID string, totalSubmodule int) error

+ type LogWriterStrategy interface

+ Write func(ctx context.Context, reader io.Reader) <-chan error

type Pipeline

+ Builder Builder

type TestDiscoveryService

+ SendResult func(ctx context.Context, testDiscoveryResult *DiscoveryResult) error

+ type TestExecutionArgs struct

+ CWD string

+ CoverageDir string

+ EnvMap map[string]string

+ FrameWork string

+ FrameWorkVersion int

+ LogWriterStrategy LogWriterStrategy

+ Payload *Payload

+ SecretData map[string]string

+ TestConfigFile string

+ TestPattern []string

Jun 28, 2022

Changes in this version

type TASConfig

+ FrameworkVersion int

Jun 22, 2022

Changes in this version

type BlockTestService

+ GetBlocklistYMLV1 func(tasConfig *TASConfig) []string

+ GetBlocklistYMLV2 func(submodule *SubModule) []string

type DiscoveryResult

+ SubModule string

type ExecutionManager

+ ExecuteUserCommandsV2 func(ctx context.Context, commandType CommandType, payload *Payload, runConfig *Run, ...) error

+ type MergeV2 struct

+ EnvMap map[string]string

+ PreRun *Run

+ SubModules []SubModule

+ type SubModule struct

+ Blocklist []string

+ ConfigFile string

+ Framework string

+ Name string

+ NodeVersion string

+ Parallelism int

+ Path string

+ Patterns []string

+ Postrun *Run

+ Prerun *Run

+ RunPrerunEveryTime bool

+ type SubModuleList struct

+ BuildID string

+ TotalSubModule int

type TASConfig

+ Version string

type TASConfigManager

+ GetVersion func(path string) (int, error)

+ LoadAndValidateV1 func(ctx context.Context, path string, eventType EventType, licenseTier Tier) (*TASConfig, error)

+ LoadAndValidateV2 func(ctx context.Context, path string, eventType EventType, licenseTier Tier) (*TASConfigV2, error)

+ type TASConfigV2 struct

+ Cache *Cache

+ ContainerImage string

+ CoverageThreshold *CoverageThreshold

+ NodeVersion string

+ Parallelism int

+ PostMerge *MergeV2

+ PreMerge *MergeV2

+ SkipCache bool

+ SmartRun bool

+ SplitMode SplitMode

+ Tier Tier

+ Version string

+ type TasVersion struct

+ Version string

type TestDiscoveryService

+ DiscoverV2 func(ctx context.Context, subModule *SubModule, payload *Payload, ...) error

+ UpdateSubmoduleList func(ctx context.Context, buildID string, totalSubmodule int) error

type TestExecutionService

+ RunV1 func(ctx context.Context, tasConfig *TASConfig, payload *Payload, ...) (results *ExecutionResults, err error)

+ RunV2 func(ctx context.Context, tasConfig *TASConfigV2, subModule *SubModule, ...) (*ExecutionResults, error)

Jun 15, 2022

Changes in this version

type LoginDetails

+ SynapseVersion string

Jun 8, 2022

Changes in this version

type JobInfo

+ Message string

Jun 2, 2022

Changes in this version

type Cache

+ Version string

May 6, 2022

Changes in this version

type TestPayload

+ FailureMessage string

Apr 29, 2022

Changes in this version

type CommandType

+ const RenameCloneFile

Apr 28, 2022

Changes in this version

type ExecutionResults

+ TaskType TaskType

type Payload

+ TaskType TaskType

type TestExecutionService

+ SendResults func(ctx context.Context, payload *ExecutionResults) (resp *TestReportResponsePayload, err error)

+ type TestReportResponsePayload struct

+ Remark string

+ TaskID string

+ TaskStatus Status

Apr 26, 2022

Changes in this version

type DiscoveryResult

+ ContainerImage string

Apr 26, 2022

Changes in this version

type DiscoveryResult

+ SplitMode SplitMode

type Pipeline

+ HTTPClient http.Client

+ type SplitMode string

+ const FileSplit

+ const TestSplit

type TASConfig

+ SplitMode SplitMode

Apr 18, 2022

Changes in this version

+ const Bitbucket

+ const FileAdded

+ const FileModified

+ const FileRemoved

+ const GitHub

+ const GitLab

+ var TierOpts = map[Tier]Specs

+ type AzureClient interface

+ Create func(ctx context.Context, path string, reader io.Reader, mimeType string) (string, error)

+ CreateUsingSASURL func(ctx context.Context, sasURL string, reader io.Reader, mimeType string) (string, error)

+ Exists func(ctx context.Context, path string) (bool, error)

+ Find func(ctx context.Context, path string) (io.ReadCloser, error)

+ FindUsingSASUrl func(ctx context.Context, sasURL string) (io.ReadCloser, error)

+ GetSASURL func(ctx context.Context, containerPath string, containerType ContainerType) (string, error)

+ type BlockTestService interface

+ GetBlockTests func(ctx context.Context, tasConfig *TASConfig, repo, branch string) error

+ type Cache struct

+ Key string

+ Paths []string

+ type CacheStore interface

+ CacheWorkspace func(ctx context.Context) error

+ Download func(ctx context.Context, cacheKey string) error

+ ExtractWorkspace func(ctx context.Context) error

+ Upload func(ctx context.Context, cacheKey string, itemsToCompress ...string) error

+ type CommandType string

+ const CoverageMerge

+ const Discovery

+ const Execution

+ const InitGit

+ const InstallNodeVer

+ const InstallRunners

+ const PostRun

+ const PreRun

+ const Zstd

+ type CommitChangeList struct

+ Added []string

+ Link string

+ Message string

+ Modified []string

+ Removed []string

+ Sha string

+ type ContainerImageConfig struct

+ AuthRegistry string

+ Image string

+ Mode config.ModeType

+ PullPolicy config.PullPolicyType

+ type ContainerStatus struct

+ Done bool

+ Error errs.Err

+ type ContainerType string

+ const CacheContainer

+ const LogsContainer

+ const PayloadContainer

+ type CoverageManifest struct

+ AllFilesExecuted bool

+ CoverageThreshold *CoverageThreshold

+ Removedfiles []string

+ type CoverageService interface

+ MergeAndUpload func(ctx context.Context, payload *Payload) error

+ type CoverageThreshold struct

+ Branches float64

+ Functions float64

+ Lines float64

+ PerFile bool

+ Statements float64

+ type DiffManager interface

+ GetChangedFiles func(ctx context.Context, payload *Payload, oauth *Oauth) (map[string]int, error)

+ type DiscoveryResult struct

+ Branch string

+ BuildID string

+ CommitID string

+ ExecuteAllTests bool

+ ImpactedTests []string

+ OrgID string

+ Parallelism int

+ RepoID string

+ TaskID string

+ TestSuites []TestSuitePayload

+ Tests []TestPayload

+ Tier Tier

+ type DockerRunner interface

+ Create func(context.Context, *RunnerOptions) ContainerStatus

+ Destroy func(ctx context.Context, r *RunnerOptions) error

+ GetInfo func(context.Context) (float32, int64)

+ Initiate func(context.Context, *RunnerOptions, chan ContainerStatus)

+ KillRunningDocker func(ctx context.Context)

+ PullImage func(containerImageConfig *ContainerImageConfig, r *RunnerOptions) error

+ Run func(context.Context, *RunnerOptions) ContainerStatus

+ WaitForCompletion func(ctx context.Context, r *RunnerOptions) error

+ type EventType string

+ const EventPullRequest

+ const EventPush

+ type ExecutionID string

+ type ExecutionManager interface

+ ExecuteInternalCommands func(ctx context.Context, commandType CommandType, commands []string, cwd string, ...) error

+ ExecuteUserCommands func(ctx context.Context, commandType CommandType, payload *Payload, runConfig *Run, ...) error

+ GetEnvVariables func(envMap, secretData map[string]string) ([]string, error)

+ StoreCommandLogs func(ctx context.Context, blobPath string, reader io.Reader) <-chan error

+ type ExecutionResult struct

+ TestPayload []TestPayload

+ TestSuitePayload []TestSuitePayload

+ type ExecutionResults struct

+ BuildID string

+ CommitID string

+ OrgID string

+ RepoID string

+ Results []ExecutionResult

+ TaskID string

+ type GitManager interface

+ Clone func(ctx context.Context, payload *Payload, oauth *Oauth) error

+ type JobInfo struct

+ BuildID string

+ ID string

+ JobID string

+ Mode string

+ Status StatusType

+ type LoginDetails struct

+ CPU float32

+ Name string

+ RAM int64

+ SecretKey string

+ SynapseID string

+ type Merge struct

+ EnvMap map[string]string

+ Patterns []string

+ type Message struct

+ Content []byte

+ Success bool

+ Type MessageType

+ type MessageType string

+ const MsgError

+ const MsgInfo

+ const MsgJobInfo

+ const MsgLogin

+ const MsgLogout

+ const MsgResourceStats

+ const MsgTask

+ type Modifier struct

+ Cli string

+ Config string

+ Type string

+ type NotifMessage struct

+ Error string

+ Status string

+ Type string

+ Value string

+ type Oauth struct

+ AccessToken string

+ Expiry time.Time

+ RefreshToken string

+ Type TokenType

+ type Payload struct

+ BranchName string

+ BuildBaseCommit string

+ BuildID string

+ BuildTargetCommit string

+ CollectCoverage bool

+ Commits []CommitChangeList

+ Diff string

+ EventType EventType

+ ForkSlug string

+ GitProvider string

+ LicenseTier Tier

+ LocatorAddress string

+ Locators string

+ OrgID string

+ ParentCommitCoverageExists bool

+ PrivateRepo bool

+ PullRequestNumber int

+ RepoID string

+ RepoLink string

+ RepoSlug string

+ TasFileName string

+ TaskID string

+ type PayloadManager interface

+ FetchPayload func(ctx context.Context, payloadAddress string) (*Payload, error)

+ ValidatePayload func(ctx context.Context, payload *Payload) error

+ type Pipeline struct

+ BlockTestService BlockTestService

+ CacheStore CacheStore

+ Cfg *config.NucleusConfig

+ CoverageService CoverageService

+ DiffManager DiffManager

+ ExecutionManager ExecutionManager

+ GitManager GitManager

+ HttpClient http.Client

+ Logger lumber.Logger

+ Payload *Payload

+ PayloadManager PayloadManager

+ SecretParser SecretParser

+ TASConfigManager TASConfigManager

+ Task Task

+ TestDiscoveryService TestDiscoveryService

+ TestExecutionService TestExecutionService

+ TestStats TestStats

+ func NewPipeline(cfg *config.NucleusConfig, logger lumber.Logger) (*Pipeline, error)

+ func (pl *Pipeline) Start(ctx context.Context) (err error)

+ type PodType string

+ const CoveragePod

+ const NucleusPod

+ type PostMergeStrategyName string

+ const AfterNCommitStrategy

+ type Requests interface

+ MakeAPIRequest func(ctx context.Context, httpMethod, endpoint string, body []byte) error

+ type ResourceStats struct

+ CPU float32

+ RAM int64

+ Status StatType

+ type Run struct

+ Commands []string

+ EnvMap map[string]string

+ type RunnerOptions struct

+ ContainerArgs []string

+ ContainerCommands []string

+ ContainerID string

+ ContainerName string

+ ContainerPort int

+ DockerImage string

+ Env []string

+ HostPort int

+ HostVolumePath string

+ Label map[string]string

+ LogfilePath string

+ NameSpace string

+ OrgID string

+ PersistentVolumeClaimName string

+ PodName string

+ PodType PodType

+ ServiceAccount string

+ Tier Tier

+ Vault *VaultOpts

+ type Secret map[string]string

+ type SecretParser interface

+ Expired func(token *Oauth) bool

+ GetOauthSecret func(filepath string) (*Oauth, error)

+ GetRepoSecret func(string) (map[string]string, error)

+ SubstituteSecret func(command string, secretData map[string]string) (string, error)

+ type SecretsManager interface

+ GetDockerSecrets func(r *RunnerOptions) (ContainerImageConfig, error)

+ GetLambdatestSecrets func() *config.LambdatestConfig

+ GetSynapseName func() string

+ WriteGitSecrets func(path string) error

+ WriteRepoSecrets func(repo string, path string) error

+ type Specs struct

+ CPU float32

+ RAM int64

+ type Stability struct

+ ConsecutiveRuns int

+ type StatType string

+ const ResourceCapture

+ const ResourceRelease

+ type Status string

+ const Aborted

+ const Error

+ const Failed

+ const Initiating

+ const Passed

+ const Running

+ type StatusType string

+ const JobCompleted

+ const JobFailed

+ const JobStarted

+ type SynapseManager interface

+ InitiateConnection func(ctx context.Context, wg *sync.WaitGroup, connectionFailed chan struct{})

+ type TASConfig struct

+ Blocklist []string

+ Cache *Cache

+ ConfigFile string

+ ContainerImage string

+ CoverageThreshold *CoverageThreshold

+ Framework string

+ NodeVersion string

+ Parallelism int

+ Postmerge *Merge

+ Postrun *Run

+ Premerge *Merge

+ Prerun *Run

+ SkipCache bool

+ SmartRun bool

+ Tier Tier

+ type TASConfigManager interface

+ LoadAndValidate func(ctx context.Context, path string, eventType EventType, licenseTier Tier) (*TASConfig, error)

+ type Task interface

+ UpdateStatus func(payload *TaskPayload) error

+ type TaskPayload struct

+ BuildID string

+ CommitID string

+ EndTime time.Time

+ GitProvider string

+ OrgID string

+ Remark string

+ RepoID string

+ RepoLink string

+ RepoSlug string

+ StartTime time.Time

+ Status Status

+ TaskID string

+ Type TaskType

+ type TaskType string

+ const DiscoveryTask

+ const ExecutionTask

+ const FlakyTask

+ type TestDiscoveryService interface

+ Discover func(ctx context.Context, tasConfig *TASConfig, payload *Payload, ...) error

+ type TestExecutionService interface

+ Run func(ctx context.Context, tasConfig *TASConfig, payload *Payload, ...) (*ExecutionResults, error)

+ type TestPayload struct

+ BlocklistSource string

+ Blocklisted bool

+ Col string

+ CommitID string

+ CurrentRetry int

+ DAG []string

+ Detail string

+ Duration int

+ EndTime time.Time

+ FilePath string

+ Filelocator string

+ FullTitle string

+ Line string

+ Name string

+ StartTime time.Time

+ Stats []TestProcessStats

+ Status string

+ SuiteID string

+ Suites []string

+ TestID string

+ Title string

+ type TestProcessStats struct

+ CPU float64

+ Memory uint64

+ RecordTime time.Time

+ Storage uint64

+ type TestStats interface

+ CaptureTestStats func(pid int32, collectStats bool) error

+ type TestStatus string

+ const Blocklisted

+ const Quarantined

+ type TestSuitePayload struct

+ BlocklistSource string

+ Blocklisted bool

+ Duration int

+ EndTime time.Time

+ ParentSuiteID string

+ StartTime time.Time

+ Stats []TestProcessStats

+ Status string

+ SuiteID string

+ SuiteName string

+ TotalTests int

+ type Tier string

+ const Internal

+ const Large

+ const Medium

+ const Small

+ const XLarge

+ const XSmall

+ type TokenType string

+ const Basic

+ const Bearer

+ type VaultOpts struct

+ Namespace string

+ RoleName string

+ SecretPath string

+ TokenPath string

+ type VaultSecret struct

+ Secrets Secret

+ type ZstdCompressor interface

+ Compress func(ctx context.Context, compressedFileName string, preservePath bool, ...) error

+ Decompress func(ctx context.Context, filePath string, preservePath bool, ...) error