deployment

Documentation

Overview

Package deployment provides functionality for planning and running deployment jobs.

Index

• type AbortedError
  • func (e *AbortedError) Error() string
• type ClientResponseError
  • func (e *ClientResponseError) Error() string
• type Deployment
  • func New(cfg *config.Configuration, deploymentsClient s3.Client, ...) *Deployment
  • func (d *Deployment) Handler(ctx context.Context, msg *engine.Message) error
  • func (d *Deployment) NewHandler(ctx context.Context, cfg config.Configuration, msg *message.MessageSQS) error
• type EvaluationAbortedError
  • func (e *EvaluationAbortedError) Error() string
• type EvaluationError
  • func (e *EvaluationError) Error() string
• type PlanError
  • func (e *PlanError) Error() string
• type TimeoutError
  • func (e *TimeoutError) Error() string

Types

type AbortedError

type AbortedError struct {
	EvaluationID  string
	CorrelationID string
}

AbortedError is an error implementation that includes the ids of the aborted evaluation and message correlation.

func (*AbortedError) Error

func (e *AbortedError) Error() string

type ClientResponseError

type ClientResponseError struct {
	Body       string
	StatusCode int
	URL        string
}

ClientResponseError is an error implementation that includes the body and status code of the response.

func (*ClientResponseError) Error

func (e *ClientResponseError) Error() string

type Deployment

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

Deployment represents a deployment.

func New

func New(cfg *config.Configuration, deploymentsClient s3.Client, nomadClient *nomad.Client) *Deployment

New returns a new deployment.

func (*Deployment) Handler

func (d *Deployment) Handler(ctx context.Context, msg *engine.Message) error

Handler handles deployment messages that are delegated by the engine. TODO This function will be removed once the new queue has been implemented

func (*Deployment) NewHandler

func (d *Deployment) NewHandler(ctx context.Context, cfg config.Configuration, msg *message.MessageSQS) error

NewHandler change this to our way not using S3

type EvaluationAbortedError

type EvaluationAbortedError struct {
	ID string
}

EvaluationAbortedError is an error implementation that includes the id of the evaluation.

func (*EvaluationAbortedError) Error

func (e *EvaluationAbortedError) Error() string

type EvaluationError

type EvaluationError struct {
	ID string
}

EvaluationError is an error implementation that includes the evaluation id of the allocations.

func (*EvaluationError) Error

func (e *EvaluationError) Error() string

type PlanError

type PlanError struct {
	Errors   string
	Service  string
	Warnings string
}

PlanError is an error implementation that includes the errors or warnings

func (*PlanError) Error

func (e *PlanError) Error() string

type TimeoutError

type TimeoutError struct {
	Action string
}

TimeoutError is an error implementation that includes the action that timed out.

func (*TimeoutError) Error

func (e *TimeoutError) Error() string