plans

Documentation

Index

• type Callback
  • func NewCallback(timeout time.Duration) *Callback
  • func (c *Callback) Post(ctx context.Context, url string, body interface{}) error
• type DeploymentCron
  • func NewDeploymentCron(repo DeploymentCronRepo, dq DeploymentQueuer, timeout time.Duration) *DeploymentCron
  • func (dc *DeploymentCron) Start()
  • func (dc *DeploymentCron) Stop()
• type DeploymentCronRepo
• type DeploymentQueuer
• type HttpCallback
• type PlanGenerator
  • func NewPlanGenerator(r *data.Repo, v VersionQuery, q QWriter) *PlanGenerator
  • func (d *PlanGenerator) QueuePlan(ctx context.Context, options *eve.DeploymentPlanOptions) error
• type QWriter
• type Queue
  • func NewQueue(worker QueueWorker, repo *data.Repo, crud *crud.Manager, ...) *Queue
  • func (dq *Queue) Logger(ctx context.Context) *zap.Logger
  • func (dq *Queue) Start()
  • func (dq *Queue) Stop()
• type QueueWorker
• type VersionQuery

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)
}