agent

type APIClient interface {
	AcceptJob(*api.Job) (*api.Job, *api.Response, error)
	AcquireJob(string) (*api.Job, *api.Response, error)
	Annotate(string, *api.Annotation) (*api.Response, error)
	Config() api.Config
	Connect() (*api.Response, error)
	CreateArtifacts(string, *api.ArtifactBatch) (*api.ArtifactBatchCreateResponse, *api.Response, error)
	Disconnect() (*api.Response, error)
	ExistsMetaData(string, string) (*api.MetaDataExists, *api.Response, error)
	FinishJob(*api.Job) (*api.Response, error)
	FromAgentRegisterResponse(*api.AgentRegisterResponse) *api.Client
	FromPing(*api.Ping) *api.Client
	GetJobState(string) (*api.JobState, *api.Response, error)
	GetMetaData(string, string) (*api.MetaData, *api.Response, error)
	Heartbeat() (*api.Heartbeat, *api.Response, error)
	Ping() (*api.Ping, *api.Response, error)
	Register(*api.AgentRegisterRequest) (*api.AgentRegisterResponse, *api.Response, error)
	SaveHeaderTimes(string, *api.HeaderTimes) (*api.Response, error)
	SearchArtifacts(string, *api.ArtifactSearchOptions) ([]*api.Artifact, *api.Response, error)
	SetMetaData(string, *api.MetaData) (*api.Response, error)
	StartJob(*api.Job) (*api.Response, error)
	StepUpdate(string, *api.StepUpdate) (*api.Response, error)
	UpdateArtifacts(string, map[string]string) (*api.Response, error)
	UploadChunk(string, *api.Chunk) (*api.Response, error)
	UploadPipeline(string, *api.Pipeline) (*api.Response, error)
}

type AgentConfiguration struct {
	ConfigPath                 string
	BootstrapScript            string
	BuildPath                  string
	HooksPath                  string
	GitMirrorsPath             string
	GitMirrorsLockTimeout      int
	PluginsPath                string
	GitCloneFlags              string
	GitCloneMirrorFlags        string
	GitCleanFlags              string
	GitFetchFlags              string
	GitSubmodules              bool
	SSHKeyscan                 bool
	CommandEval                bool
	PluginsEnabled             bool
	PluginValidation           bool
	LocalHooksEnabled          bool
	RunInPty                   bool
	TimestampLines             bool
	HealthCheckAddr            string
	DisconnectAfterJob         bool
	DisconnectAfterIdleTimeout int
	CancelGracePeriod          int
	Shell                      string
	Profile                    string
	RedactedVars               []string
	AcquireJob                 string
}

type AgentPool struct {
	// contains filtered or unexported fields
}

type AgentWorker struct {
	// contains filtered or unexported fields
}

type AgentWorkerConfig struct {
	// Whether to set debug in the job
	Debug bool

	// Whether to set debugHTTP in the job
	DebugHTTP bool

	// What signal to use for worker cancellation
	CancelSignal process.Signal

	// The index of this agent worker
	SpawnIndex int

	// The configuration of the agent from the CLI
	AgentConfiguration AgentConfiguration
}

type ArtifactBatchCreator struct {
	// contains filtered or unexported fields
}

type ArtifactBatchCreatorConfig struct {
	// The ID of the Job that these artifacts belong to
	JobID string

	// All the artifacts that need to be created
	Artifacts []*api.Artifact

	// Where the artifacts are being uploaded to on the command line
	UploadDestination string
}

type ArtifactDownloader struct {
	// contains filtered or unexported fields
}

type ArtifactDownloaderConfig struct {
	// The ID of the Build
	BuildID string

	// The query used to find the artifacts
	Query string

	// Which step should we look at for the jobs
	Step string

	// Whether to include artifacts from retried jobs in the search
	IncludeRetriedJobs bool

	// Where we'll be downloading artifacts to
	Destination string

	// Whether to show HTTP debugging
	DebugHTTP bool
}

type ArtifactSearcher struct {
	// contains filtered or unexported fields
}

type ArtifactUploader struct {
	// contains filtered or unexported fields
}

type ArtifactUploaderConfig struct {
	// The ID of the Job
	JobID string

	// The path of the uploads
	Paths string

	// Where we'll be uploading artifacts
	Destination string

	// A specific Content-Type to use for all artifacts
	ContentType string

	// Whether to show HTTP debugging
	DebugHTTP bool
}

type ArtifactoryDownloader struct {
	// contains filtered or unexported fields
}

type ArtifactoryDownloaderConfig struct {
	// The Artifactory repository name and the path, e.g rt://my-repo-name/foo/bar
	Repository string

	// The root directory of the download
	Destination string

	// The relative path that should be preserved in the download folder,
	// also its location in the repo
	Path string

	// How many times should it retry the download before giving up
	Retries int

	// If failed responses should be dumped to the log
	DebugHTTP bool
}

type ArtifactoryUploader struct {
	// The artifactory bucket path set from the destination
	Path string

	// The artifactory bucket name set from the destination
	Repository string
	// contains filtered or unexported fields
}

type ArtifactoryUploaderConfig struct {
	// The destination which includes the Artifactory bucket name and the path.
	// e.g artifactory://my-repo-name/foo/bar
	Destination string

	// Whether or not HTTP calls should be debugged
	DebugHTTP bool
}

type Download struct {
	// contains filtered or unexported fields
}

type DownloadConfig struct {
	// The actual URL to get the file from
	URL string

	// The root directory of the download
	Destination string

	// Optional Headers to append to the request
	Headers map[string]string

	// The relative path that should be preserved in the download folder
	Path string

	// How many times should it retry the download before giving up
	Retries int

	// If failed responses should be dumped to the log
	DebugHTTP bool
}

type EC2MetaData struct {
}

type EC2Tags struct {
}

type Error struct {
	Status  int    `json:"status"`  // Error code
	Message string `json:"message"` // Message describing the error.
}

type FetchTagsConfig struct {
	Tags []string

	TagsFromEC2MetaData      bool
	TagsFromEC2MetaDataPaths []string
	TagsFromEC2Tags          bool
	TagsFromGCPMetaData      bool
	TagsFromGCPMetaDataPaths []string
	TagsFromGCPLabels        bool
	TagsFromHost             bool
	WaitForEC2TagsTimeout    time.Duration
	WaitForGCPLabelsTimeout  time.Duration
}

type FormUploader struct {
	// contains filtered or unexported fields
}

type FormUploaderConfig struct {
	// Whether or not HTTP calls should be debugged
	DebugHTTP bool
}

type GCPLabels struct {
}

type GCPMetaData struct {
}

type GSDownloader struct {
	// contains filtered or unexported fields
}

type GSDownloaderConfig struct {
	// The name of the bucket
	Bucket string

	// The root directory of the download
	Destination string

	// The relative path that should be preserved in the download folder,
	// also its location in the bucket
	Path string

	// How many times should it retry the download before giving up
	Retries int

	// If failed responses should be dumped to the log
	DebugHTTP bool
}

type GSUploader struct {
	// The gs bucket path set from the destination
	BucketPath string

	// The gs bucket name set from the destination
	BucketName string
	// contains filtered or unexported fields
}

type GSUploaderConfig struct {
	// The destination which includes the GS bucket name and the path.
	// gs://my-bucket-name/foo/bar
	Destination string

	// Whether or not HTTP calls shoud be debugged
	DebugHTTP bool
}

type IdleMonitor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type JobRunner struct {
	// contains filtered or unexported fields
}

type JobRunnerConfig struct {
	// The configuration of the agent from the CLI
	AgentConfiguration AgentConfiguration

	// What signal to use for worker cancellation
	CancelSignal process.Signal

	// Whether to set debug in the job
	Debug bool

	// Whether to set debug HTTP Requests in the job
	DebugHTTP bool
}

type LogStreamer struct {
	// contains filtered or unexported fields
}

type LogStreamerChunk struct {
	// The contents of the chunk
	Data string

	// The sequence number of this chunk
	Order int

	// The byte offset of this chunk
	Offset int

	// The byte size of this chunk
	Size int
}

type LogStreamerConfig struct {
	// How many log streamer workers are running at any one time
	Concurrency int

	// The maximum size of chunks
	MaxChunkSizeBytes int
}

type PipelineParser struct {
	Env             *env.Environment
	Filename        string
	Pipeline        []byte
	NoInterpolation bool
}

type PipelineParserResult struct {
	// contains filtered or unexported fields
}

type S3Downloader struct {
	// contains filtered or unexported fields
}

type S3DownloaderConfig struct {
	// The S3 bucket name and the path, e.g s3://my-bucket-name/foo/bar
	Bucket string

	// The root directory of the download
	Destination string

	// The relative path that should be preserved in the download folder,
	// also its location in the bucket
	Path string

	// How many times should it retry the download before giving up
	Retries int

	// If failed responses should be dumped to the log
	DebugHTTP bool
}

type S3Uploader struct {
	// The s3 bucket path set from the destination
	BucketPath string

	// The s3 bucket name set from the destination
	BucketName string
	// contains filtered or unexported fields
}

type S3UploaderConfig struct {
	// The destination which includes the S3 bucket name and the path.
	// e.g s3://my-bucket-name/foo/bar
	Destination string

	// Whether or not HTTP calls should be debugged
	DebugHTTP bool
}

type Uploader interface {
	// The Artifact.URL property is populated with what ever is returned
	// from this method prior to uploading.
	URL(*api.Artifact) string

	// The actual uploading of the file
	Upload(*api.Artifact) error
}