processor

Documentation

Index

• Constants
• func GarbageCollector(c *config.CloudbuildOpts)
• func Heartbeat(c *config.CloudbuildOpts)
• func WorkersDtoFromModels(models *[]WorkerModel) *[]WorkerDto
• type Worker
  • func New(artifactory *artifactory.Artifactory) *Worker
  • func (worker *Worker) PullImage(ctx context.Context, buildImage string) error
  • func (worker *Worker) Run()
  • func (worker *Worker) Stop(ctx context.Context) error
• type WorkerDB
  • func NewWorkerDB(c *config.CloudbuildOpts) *WorkerDB
  • func (w *WorkerDB) List() (*[]WorkerModel, error)
• type WorkerDto
  • func WorkerDtoFromModel(model *WorkerModel) WorkerDto
• type WorkerModel
  • func (base *WorkerModel) BeforeCreate(db *gorm.DB) error
  • func (WorkerModel) TableName() string

Constants

const (
	HeartbeatInterval = time.Second * 10
	Timeout           = time.Second * 30
)

Functions

func GarbageCollector

func GarbageCollector(c *config.CloudbuildOpts)

func Heartbeat

func Heartbeat(c *config.CloudbuildOpts)

func WorkersDtoFromModels

func WorkersDtoFromModels(models *[]WorkerModel) *[]WorkerDto

Types

type Worker

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

func New

func New(artifactory *artifactory.Artifactory) *Worker

func (*Worker) PullImage

func (worker *Worker) PullImage(ctx context.Context, buildImage string) error

func (*Worker) Run

func (worker *Worker) Run()

func (*Worker) Stop

func (worker *Worker) Stop(ctx context.Context) error

type WorkerDB

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

func NewWorkerDB

func NewWorkerDB(c *config.CloudbuildOpts) *WorkerDB

func (*WorkerDB) List

func (w *WorkerDB) List() (*[]WorkerModel, error)

type WorkerDto

type WorkerDto struct {
	ID        string    `json:"id"`
	Hostname  string    `json:"hostname"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

func WorkerDtoFromModel

func WorkerDtoFromModel(model *WorkerModel) WorkerDto

type WorkerModel

type WorkerModel struct {
	ID        uuid.UUID `gorm:"type:uuid;primary_key;"`
	Hostname  string    `gorm:"index:worker_hostname_idx"`
	CreatedAt time.Time
	UpdatedAt time.Time
}

func (*WorkerModel) BeforeCreate

func (base *WorkerModel) BeforeCreate(db *gorm.DB) error

func (WorkerModel) TableName

func (WorkerModel) TableName() string