api

package
v3.5.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2018 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsRetryableError

func IsRetryableError(err error) bool

Looks at a bunch of connection related errors, and returns true if the error matches one of them.

func NewUUID

func NewUUID() string

Types

type Agent

type Agent struct {
	Name              string   `json:"name" msgpack:"name"`
	AccessToken       string   `json:"access_token" msgpack:"access_token"`
	Hostname          string   `json:"hostname" msgpack:"hostname"`
	Endpoint          string   `json:"endpoint" msgpack:"endpoint"`
	PingInterval      int      `json:"ping_interval" msgpack:"ping_interval"`
	JobStatusInterval int      `json:"job_status_interval" msgpack:"job_status_interval"`
	HearbeatInterval  int      `json:"heartbeat_interval" msgpack:"heartbeat_interval"`
	OS                string   `json:"os" msgpack:"os"`
	Arch              string   `json:"arch" msgpack:"arch"`
	ScriptEvalEnabled bool     `json:"script_eval_enabled" msgpack:"script_eval_enabled"`
	Priority          string   `json:"priority,omitempty" msgpack:"priority,omitempty"`
	Version           string   `json:"version" msgpack:"version"`
	Build             string   `json:"build" msgpack:"build"`
	Tags              []string `json:"meta_data" msgpack:"meta_data"`
	PID               int      `json:"pid,omitempty" msgpack:"pid,omitempty"`
	MachineID         string   `json:"machine_id,omitempty" msgpack:"machine_id,omitempty"`
}

Agent represents an agent on the Buildkite Agent API

type AgentsService

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

AgentsService handles communication with the agent related methods of the Buildkite Agent API.

func (*AgentsService) Connect

func (as *AgentsService) Connect() (*Response, error)

Connects the agent to the Buildkite Agent API

func (*AgentsService) Disconnect

func (as *AgentsService) Disconnect() (*Response, error)

Disconnects the agent to the Buildkite Agent API

func (*AgentsService) Register

func (as *AgentsService) Register(agent *Agent) (*Agent, *Response, error)

Registers the agent against the Buildktie Agent API. The client for this call must be authenticated using an Agent Registration Token

type Annotation

type Annotation struct {
	Body    string `json:"body,omitempty"`
	Context string `json:"context,omitempty"`
	Style   string `json:"style,omitempty"`
	Append  bool   `json:"append,omitempty"`
}

Annotation represents a Buildkite Agent API Annotation

type AnnotationsService

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

AnnotationsService handles communication with the annotation related methods of the Buildkite Agent API.

func (*AnnotationsService) Create

func (cs *AnnotationsService) Create(jobId string, annotation *Annotation) (*Response, error)

Annotates a build in the Buildkite UI

type Artifact

type Artifact struct {
	// The ID of the artifact. The ID is assigned to it after a successful
	// batch creation
	ID string `json:"-"`

	// The path to the artifact relative to the working directory
	Path string `json:"path"`

	// The absolute path to the artifact
	AbsolutePath string `json:"absolute_path"`

	// The glob path used to find this artifact
	GlobPath string `json:"glob_path"`

	// The size of the file in bytes
	FileSize int64 `json:"file_size"`

	// A Sha1Sum calculation of the file
	Sha1Sum string `json:"sha1sum"`

	// The HTTP url to this artifact once it's been uploaded
	URL string `json:"url,omitempty"`

	// The destination specified on the command line when this file was
	// uploaded
	UploadDestination string `json:"upload_destination,omitempty"`

	// Information on how to upload this artifact.
	UploadInstructions *ArtifactUploadInstructions `json:"-"`
}

Artifact represents an artifact on the Buildkite Agent API

type ArtifactBatch

type ArtifactBatch struct {
	ID                string      `json:"id"`
	Artifacts         []*Artifact `json:"artifacts"`
	UploadDestination string      `json:"upload_destination"`
}

type ArtifactBatchCreateResponse

type ArtifactBatchCreateResponse struct {
	ID                 string                      `json:"id"`
	ArtifactIDs        []string                    `json:"artifact_ids"`
	UploadInstructions *ArtifactUploadInstructions `json:"upload_instructions"`
}

type ArtifactBatchUpdateArtifact

type ArtifactBatchUpdateArtifact struct {
	ID    string `json:"id"`
	State string `json:"state"`
}

type ArtifactBatchUpdateRequest

type ArtifactBatchUpdateRequest struct {
	Artifacts []*ArtifactBatchUpdateArtifact `json:"artifacts"`
}

type ArtifactSearchOptions

type ArtifactSearchOptions struct {
	Query string `url:"query,omitempty"`
	Scope string `url:"scope,omitempty"`
}

ArtifactSearchOptions specifies the optional parameters to the ArtifactsService.Search method.

type ArtifactUploadInstructions

type ArtifactUploadInstructions struct {
	Data   map[string]string `json: "data"`
	Action struct {
		URL       string `json:"url,omitempty"`
		Method    string `json:"method"`
		Path      string `json:"path"`
		FileInput string `json:"file_input"`
	}
}

type ArtifactsService

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

ArtifactsService handles communication with the artifact related methods of the Buildkite Artifact API.

func (*ArtifactsService) Create

Accepts a slice of artifacts, and creates them on Buildkite as a batch.

func (*ArtifactsService) Search

func (as *ArtifactsService) Search(buildId string, opt *ArtifactSearchOptions) ([]*Artifact, *Response, error)

Searches Buildkite for a set of artifacts

func (*ArtifactsService) Update

func (as *ArtifactsService) Update(jobId string, artifactStates map[string]string) (*Response, error)

Updates a paticular artifact

type AuthenticatedTransport

type AuthenticatedTransport struct {
	// The Token used for authentication. This can either the be
	// organizations registration token, or the agents access token.
	Token string

	// Transport is the underlying HTTP transport to use when making
	// requests. It will default to http.DefaultTransport if nil.
	Transport http.RoundTripper
}

Transport manages injection of the API token

func (*AuthenticatedTransport) CancelRequest

func (t *AuthenticatedTransport) CancelRequest(req *http.Request)

CancelRequest cancels an in-flight request by closing its connection.

func (AuthenticatedTransport) RoundTrip

func (t AuthenticatedTransport) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip invoked each time a request is made

type Chunk

type Chunk struct {
	Data     string
	Sequence int
	Offset   int
	Size     int
}

Chunk represents a Buildkite Agent API Chunk

type ChunksService

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

ChunksService handles communication with the chunk related methods of the Buildkite Agent API.

func (*ChunksService) Upload

func (cs *ChunksService) Upload(jobId string, chunk *Chunk) (*Response, error)

Uploads the chunk to the Buildkite Agent API. This request sends the compressed log directly as a request body.

type Client

type Client struct {

	// Base URL for API requests. Defaults to the public Buildkite Agent API.
	// The URL should always be specified with a trailing slash.
	BaseURL *url.URL

	// User agent used when communicating with the Buildkite Agent API.
	UserAgent string

	// If true, requests and responses will be dumped and set to the logger
	DebugHTTP bool

	// Services used for talking to different parts of the Buildkite Agent API.
	Agents      *AgentsService
	Pings       *PingsService
	Jobs        *JobsService
	Chunks      *ChunksService
	MetaData    *MetaDataService
	HeaderTimes *HeaderTimesService
	Artifacts   *ArtifactsService
	Pipelines   *PipelinesService
	Heartbeats  *HeartbeatsService
	Annotations *AnnotationsService
	// contains filtered or unexported fields
}

A Client manages communication with the Buildkite Agent API.

func NewClient

func NewClient(httpClient *http.Client) *Client

NewClient returns a new Buildkite Agent API Client.

func (*Client) Do

func (c *Client) Do(req *http.Request, v interface{}) (*Response, error)

Do sends an API request and returns the API response. The API response is JSON decoded and stored in the value pointed to by v, or returned as an error if an API error has occurred. If v implements the io.Writer interface, the raw response body will be written to v, without attempting to first decode it.

func (*Client) NewFormRequest

func (c *Client) NewFormRequest(method, urlStr string, body *bytes.Buffer) (*http.Request, error)

NewFormRequest creates an multi-part form request. A relative URL can be provided in urlStr, in which case it is resolved relative to the UploadURL of the Client. Relative URLs should always be specified without a preceding slash.

func (*Client) NewRequest

func (c *Client) NewRequest(method, urlStr string, body interface{}) (*http.Request, error)

NewRequest creates an API request. A relative URL can be provided in urlStr, in which case it is resolved relative to the BaseURL of the Client. Relative URLs should always be specified without a preceding slash. If specified, the value pointed to by body is JSON encoded and included as the request body.

func (*Client) NewRequestWithMessagePack

func (c *Client) NewRequestWithMessagePack(method, urlStr string, body interface{}) (*http.Request, error)

NewRequestWithMessagePack behaves the same as NewRequest expect it encodes the body with MessagePack instead of JSON.

type ErrorResponse

type ErrorResponse struct {
	Response *http.Response // HTTP response that caused this error
	Message  string         `json:"message" msgpack:"message"` // error message
}

ErrorResponse provides a message.

func (*ErrorResponse) Error

func (r *ErrorResponse) Error() string

type HeaderTimes

type HeaderTimes struct {
	Times map[string]string `json:"header_times"`
}

HeaderTimes represents a set of header times that are associated with a job log.

type HeaderTimesService

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

HeaderTimesService handles communication with the meta data related methods of the Buildkite Agent API.

func (*HeaderTimesService) Save

func (hs *HeaderTimesService) Save(jobId string, headerTimes *HeaderTimes) (*Response, error)

Saves the header times to the job

type Heartbeat

type Heartbeat struct {
	SentAt     string `json:"sent_at"`
	ReceivedAt string `json:"received_at,omitempty"`
}

Heartbeat represents a Buildkite Agent API Heartbeat

type HeartbeatsService

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

HeartbeatsService handles communication with the ping related methods of the Buildkite Agent API.

func (*HeartbeatsService) Beat

func (hs *HeartbeatsService) Beat() (*Heartbeat, *Response, error)

Heartbeats the API which keeps the agent connected to Buildkite

type Job

type Job struct {
	ID                 string            `json:"id,omitempty"`
	Endpoint           string            `json:"endpoint"`
	State              string            `json:"state,omitempty"`
	Env                map[string]string `json:"env,omitempty"`
	ChunksMaxSizeBytes int               `json:"chunks_max_size_bytes,omitempty"`
	ExitStatus         string            `json:"exit_status,omitempty"`
	StartedAt          string            `json:"started_at,omitempty"`
	FinishedAt         string            `json:"finished_at,omitempty"`
	ChunksFailedCount  int               `json:"chunks_failed_count,omitempty"`
}

Job represents a Buildkite Agent API Job

type JobState

type JobState struct {
	State string `json:"state,omitempty"`
}

type JobsService

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

JobsService handles communication with the job related methods of the Buildkite Agent API.

func (*JobsService) Accept

func (js *JobsService) Accept(job *Job) (*Job, *Response, error)

Accepts the passed in job. Returns the job with it's finalized set of environment variables (when a job is accepted, the agents environment is applied to the job)

func (*JobsService) Finish

func (js *JobsService) Finish(job *Job) (*Response, error)

Finishes the passed in job

func (*JobsService) GetState

func (js *JobsService) GetState(id string) (*JobState, *Response, error)

Fetches a job

func (*JobsService) Start

func (js *JobsService) Start(job *Job) (*Response, error)

Starts the passed in job

type MetaData

type MetaData struct {
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

MetaData represents a Buildkite Agent API MetaData

type MetaDataExists

type MetaDataExists struct {
	Exists bool `json:"exists"`
}

MetaDataExists represents a Buildkite Agent API MetaData Exists check response

type MetaDataService

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

MetaDataService handles communication with the meta data related methods of the Buildkite Agent API.

func (*MetaDataService) Exists

func (ps *MetaDataService) Exists(jobId string, key string) (*MetaDataExists, *Response, error)

Returns true if the meta data key has been set, false if it hasn't.

func (*MetaDataService) Get

func (ps *MetaDataService) Get(jobId string, key string) (*MetaData, *Response, error)

Gets the meta data value

func (*MetaDataService) Set

func (ps *MetaDataService) Set(jobId string, metaData *MetaData) (*Response, error)

Sets the meta data value

type Ping

type Ping struct {
	Action   string `json:"action,omitempty"`
	Message  string `json:"message,omitempty"`
	Job      *Job   `json:"job,omitempty"`
	Endpoint string `json:"endpoint,omitempty"`
}

Ping represents a Buildkite Agent API Ping

type PingsService

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

PingsService handles communication with the ping related methods of the Buildkite Agent API.

func (*PingsService) Get

func (ps *PingsService) Get() (*Ping, *Response, error)

Pings the API and returns any work the client needs to perform

type Pipeline

type Pipeline struct {
	UUID     string      `json:"uuid"`
	Pipeline interface{} `json:"pipeline"`
	Replace  bool        `json:"replace,omitempty"`
}

Pipeline represents a Buildkite Agent API Pipeline

type PipelinesService

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

PipelinesService handles communication with the pipeline related methods of the Buildkite Agent API.

func (*PipelinesService) Upload

func (cs *PipelinesService) Upload(jobId string, pipeline *Pipeline) (*Response, error)

Uploads the pipeline to the Buildkite Agent API. This request doesn't use JSON, but a multi-part HTTP form upload

type Response

type Response struct {
	*http.Response
}

Response is a Buildkite Agent API response. This wraps the standard http.Response.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL