bk

Documentation

Index

• Constants
• Variables
• type API
• type AgentAPI
  • func NewAgentAPI() *AgentAPI
  • func (ab *AgentAPI) AcceptJob(agentKey string, job *api.Job) (*api.Job, error)
  • func (ab *AgentAPI) Beat(agentKey string) (*api.Heartbeat, error)
  • func (ab *AgentAPI) Ping(agentKey string) (*api.Ping, error)
  • func (ab *AgentAPI) Register(agentName string, agentKey string, tags []string) (*api.Agent, error)
• type WorkflowData

Constants

const (
	// DefaultAPIEndpoint default api endpoint
	DefaultAPIEndpoint = "https://agent.buildkite.com/v3"

	// MaxAgentConcurrentJobs jobs which can be run per agent instance
	MaxAgentConcurrentJobs = 1

	// DefaultAgentNamePrefix serverless agent name prefix used when registering the agent
	DefaultAgentNamePrefix = "serverless-agent"
)

Variables

var (
	// Version the serverless agent version
	Version = "dev"

	// BuildVersion the serverless agent version
	BuildVersion = "dev"
)

Types

type API

type API interface {
	Register(string, string, []string) (*api.Agent, error)
	Beat(string) (*api.Heartbeat, error)
	Ping(string) (*api.Ping, error)
	AcceptJob(string, *api.Job) (*api.Job, error)
}

API wrap up all the buildkite api operations

type AgentAPI

type AgentAPI struct {
}

AgentAPI wrapper around all the buildkite api operations

func NewAgentAPI

func NewAgentAPI() *AgentAPI

NewAgentAPI create a new agent api

func (*AgentAPI) AcceptJob

func (ab *AgentAPI) AcceptJob(agentKey string, job *api.Job) (*api.Job, error)

AcceptJob accept the job provided by buildkite

func (*AgentAPI) Beat

func (ab *AgentAPI) Beat(agentKey string) (*api.Heartbeat, error)

Beat send a heartbeat to the agent api

func (*AgentAPI) Ping

func (ab *AgentAPI) Ping(agentKey string) (*api.Ping, error)

Ping ping the agent api for a job

func (*AgentAPI) Register

func (ab *AgentAPI) Register(agentName string, agentKey string, tags []string) (*api.Agent, error)

Register register an agent

type WorkflowData

type WorkflowData struct {
	Job                  *api.Job `json:"job,omitempty"`
	BuildID              string   `json:"build_id,omitempty"`
	BuildStatus          string   `json:"build_status,omitempty"`
	WaitTime             int      `json:"wait_time,omitempty"`
	NextToken            string   `json:"next_token,omitempty"`
	LogBytes             int      `json:"log_bytes,omitempty"`
	LogSequence          int      `json:"log_sequence,omitempty"`
	AgentName            string   `json:"agent_name,omitempty"`
	CodeBuildProjectName string   `json:"code_build_project_name,omitempty"`
}

WorkflowData this is information passed along in the step function workflow