plans

package
Version: v0.21.2 Latest Latest
Warning

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

Go to latest
Published: Nov 20, 2021 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Callback

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

func NewCallback

func NewCallback(timeout time.Duration) *Callback

func (*Callback) Post

func (c *Callback) Post(ctx context.Context, url string, body interface{}) error

type DeploymentCron

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

func NewDeploymentCron

func NewDeploymentCron(repo DeploymentCronRepo, dq DeploymentQueuer, timeout time.Duration) *DeploymentCron

func (*DeploymentCron) Start

func (dc *DeploymentCron) Start()

func (*DeploymentCron) Stop

func (dc *DeploymentCron) Stop()

type DeploymentCronRepo

type DeploymentCronRepo interface {
	ScheduleDeploymentCronJobs(ctx context.Context, schedule func(context.Context, *data.DeploymentCronJob) ([]uuid.UUID, error)) error
	UpdateFinishedJobs(ctx context.Context) error
}

type DeploymentQueuer

type DeploymentQueuer interface {
	QueuePlan(ctx context.Context, options *eve.DeploymentPlanOptions) error
}

type HttpCallback

type HttpCallback interface {
	Post(ctx context.Context, url string, body interface{}) error
}

type PlanGenerator

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

func NewPlanGenerator

func NewPlanGenerator(r *data.Repo, v VersionQuery, q QWriter) *PlanGenerator

func (*PlanGenerator) QueuePlan

func (d *PlanGenerator) QueuePlan(ctx context.Context, options *eve.DeploymentPlanOptions) error

type QWriter

type QWriter interface {
	Message(ctx context.Context, m *queue.M) error
}

type Queue

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

func NewQueue

func NewQueue(
	worker QueueWorker,
	repo *data.Repo,
	crud *crud.Manager,
	uploader eve.CloudUploader,
	downloader eve.CloudDownloader,
	httpCallBack HttpCallback) *Queue

func (*Queue) Logger

func (dq *Queue) Logger(ctx context.Context) *zap.Logger

func (*Queue) Start

func (dq *Queue) Start()

func (*Queue) Stop

func (dq *Queue) Stop()

type QueueWorker

type QueueWorker interface {
	Start(queue.Handler)
	Stop()
	DeleteMessage(ctx context.Context, m *queue.M) error
	// Message sends a message to a different queue given a url, not this one
	Message(ctx context.Context, qUrl string, m *queue.M) error
}

type VersionQuery

type VersionQuery interface {
	GetLatestVersion(ctx context.Context, repository string, path string, version string) (string, error)
}

Jump to

Keyboard shortcuts

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