Documentation ¶
Index ¶
- Variables
- type APIEndpoint
- type APIRequestStatusesMap
- type GitLabClient
- func (n *GitLabClient) DownloadArtifacts(config common.JobCredentials, artifactsFile string) common.DownloadState
- func (n *GitLabClient) PatchTrace(config common.RunnerConfig, jobCredentials *common.JobCredentials, ...) (int, common.UpdateState)
- func (n *GitLabClient) ProcessJob(config common.RunnerConfig, jobCredentials *common.JobCredentials) (common.JobTrace, error)
- func (n *GitLabClient) RegisterRunner(runner common.RunnerCredentials, parameters common.RegisterRunnerParameters) *common.RegisterRunnerResponse
- func (n *GitLabClient) RequestJob(config common.RunnerConfig, sessionInfo *common.SessionInfo) (*common.JobResponse, bool)
- func (n *GitLabClient) UnregisterRunner(runner common.RunnerCredentials) bool
- func (n *GitLabClient) UpdateJob(config common.RunnerConfig, jobCredentials *common.JobCredentials, ...) common.UpdateState
- func (n *GitLabClient) UploadRawArtifacts(config common.JobCredentials, reader io.Reader, ...) common.UploadState
- func (n *GitLabClient) VerifyRunner(runner common.RunnerCredentials) bool
- type RemoteJobStateResponse
- type ResponseTLSData
- type TracePatchResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var CertificateDirectory string
Functions ¶
This section is empty.
Types ¶
type APIEndpoint ¶
type APIEndpoint string
const ( APIEndpointRequestJob APIEndpoint = "request_job" APIEndpointUpdateJob APIEndpoint = "update_job" APIEndpointPatchTrace APIEndpoint = "patch_trace" )
type APIRequestStatusesMap ¶
type APIRequestStatusesMap struct {
// contains filtered or unexported fields
}
func NewAPIRequestStatusesMap ¶
func NewAPIRequestStatusesMap() *APIRequestStatusesMap
func (*APIRequestStatusesMap) Append ¶
func (arspm *APIRequestStatusesMap) Append(runnerID string, endpoint APIEndpoint, status int)
func (*APIRequestStatusesMap) Collect ¶
func (arspm *APIRequestStatusesMap) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector.
func (*APIRequestStatusesMap) Describe ¶
func (arspm *APIRequestStatusesMap) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector.
type GitLabClient ¶
type GitLabClient struct {
// contains filtered or unexported fields
}
func NewGitLabClient ¶
func NewGitLabClient() *GitLabClient
func NewGitLabClientWithRequestStatusesMap ¶
func NewGitLabClientWithRequestStatusesMap(rsMap *APIRequestStatusesMap) *GitLabClient
func (*GitLabClient) DownloadArtifacts ¶
func (n *GitLabClient) DownloadArtifacts(config common.JobCredentials, artifactsFile string) common.DownloadState
func (*GitLabClient) PatchTrace ¶
func (n *GitLabClient) PatchTrace(config common.RunnerConfig, jobCredentials *common.JobCredentials, content []byte, startOffset int) (int, common.UpdateState)
func (*GitLabClient) ProcessJob ¶
func (n *GitLabClient) ProcessJob(config common.RunnerConfig, jobCredentials *common.JobCredentials) (common.JobTrace, error)
func (*GitLabClient) RegisterRunner ¶
func (n *GitLabClient) RegisterRunner(runner common.RunnerCredentials, parameters common.RegisterRunnerParameters) *common.RegisterRunnerResponse
func (*GitLabClient) RequestJob ¶
func (n *GitLabClient) RequestJob(config common.RunnerConfig, sessionInfo *common.SessionInfo) (*common.JobResponse, bool)
func (*GitLabClient) UnregisterRunner ¶
func (n *GitLabClient) UnregisterRunner(runner common.RunnerCredentials) bool
func (*GitLabClient) UpdateJob ¶
func (n *GitLabClient) UpdateJob(config common.RunnerConfig, jobCredentials *common.JobCredentials, jobInfo common.UpdateJobInfo) common.UpdateState
func (*GitLabClient) UploadRawArtifacts ¶
func (n *GitLabClient) UploadRawArtifacts(config common.JobCredentials, reader io.Reader, options common.ArtifactsOptions) common.UploadState
func (*GitLabClient) VerifyRunner ¶
func (n *GitLabClient) VerifyRunner(runner common.RunnerCredentials) bool
type RemoteJobStateResponse ¶
func NewRemoteJobStateResponse ¶
func NewRemoteJobStateResponse(response *http.Response) *RemoteJobStateResponse
func (*RemoteJobStateResponse) IsAborted ¶
func (r *RemoteJobStateResponse) IsAborted() bool
type ResponseTLSData ¶
type TracePatchResponse ¶
type TracePatchResponse struct { *RemoteJobStateResponse RemoteRange string }
func NewTracePatchResponse ¶
func NewTracePatchResponse(response *http.Response) *TracePatchResponse
func (*TracePatchResponse) NewOffset ¶
func (p *TracePatchResponse) NewOffset() int
Click to show internal directories.
Click to hide internal directories.