build

Documentation

Index

• Variables
• type Build
  • func New(projectDir string, tasks []*api.Task, logger logger.Lightweight) (*Build, error)
  • func (b *Build) GetNextTask() (result *Task)
  • func (b *Build) GetTask(id int64) *Task
  • func (b *Build) GetTaskFromIdentification(tid *api.TaskIdentification, clientSecret string) (*Task, error)
  • func (b *Build) Tasks() (result []*Task)
• type Command
  • func (command *Command) SetStatus(status commandstatus.Status)
  • func (command *Command) Status() commandstatus.Status
• type Task
  • func NewFromProto(protoTask *api.Task, logger logger.Lightweight) (*Task, error)
  • func (task *Task) FailedAtLeastOnce() bool
  • func (task *Task) GetCommand(name string) *Command
  • func (task *Task) ProtoCommands() []*api.Command
  • func (task *Task) SetStatus(status taskstatus.Status)
  • func (task *Task) Status() taskstatus.Status
  • func (task *Task) String() string
  • func (task *Task) UniqueDescription() string

Variables

var ErrFailedToCreateTask = errors.New("failed to create task")

Types

type Build

type Build struct {
	// A directory on host where .cirrus.yml that drives this execution is located
	ProjectDir string

	Cache *cache.Cache
	// contains filtered or unexported fields
}

func New

func New(projectDir string, tasks []*api.Task, logger logger.Lightweight) (*Build, error)

func (*Build) GetNextTask

func (b *Build) GetNextTask() (result *Task)

func (*Build) GetTask

func (b *Build) GetTask(id int64) *Task

func (*Build) GetTaskFromIdentification

func (b *Build) GetTaskFromIdentification(tid *api.TaskIdentification, clientSecret string) (*Task, error)

func (*Build) Tasks

func (b *Build) Tasks() (result []*Task)

type Command

type Command struct {

	// Original Protocol Buffers structure for reference
	ProtoCommand *api.Command

	// A mutex to guarantee safe accesses from both the main loop and gRPC server handlers
	Mutex sync.RWMutex
	// contains filtered or unexported fields
}

func (*Command) SetStatus

func (command *Command) SetStatus(status commandstatus.Status)

func (*Command) Status

func (command *Command) Status() commandstatus.Status

type Task

type Task struct {
	ID          int64
	RequiredIDs []int64
	Name        string
	Labels      []string

	Instance    abstract.Instance
	Timeout     time.Duration
	Environment map[string]string
	Commands    []*Command

	LastHeartbeatReceivedAt atomic.Pointer[time.Time]

	// A mutex to guarantee safe accesses from both the main loop and gRPC server handlers
	Mutex sync.RWMutex
	// contains filtered or unexported fields
}

func NewFromProto

func NewFromProto(protoTask *api.Task, logger logger.Lightweight) (*Task, error)

func (*Task) FailedAtLeastOnce

func (task *Task) FailedAtLeastOnce() bool

func (*Task) GetCommand

func (task *Task) GetCommand(name string) *Command

func (*Task) ProtoCommands

func (task *Task) ProtoCommands() []*api.Command

func (*Task) SetStatus

func (task *Task) SetStatus(status taskstatus.Status)

func (*Task) Status

func (task *Task) Status() taskstatus.Status

func (*Task) String

func (task *Task) String() string

func (*Task) UniqueDescription

func (task *Task) UniqueDescription() string