manager

Documentation

Index

• type Command
• type ConfigurationOperations
• type Confirmer
  • func NewConfirmer(broker *broker.Broker, mode Mode, duration time.Duration, reason string) *Confirmer
  • func (c *Confirmer) Cancel()
  • func (c *Confirmer) Confirm(generationUuid string)
  • func (c *Confirmer) Start()
  • func (c *Confirmer) Submit(generationUuid string)
• type Manager
  • func New(s *store.Store, p prometheus.Prometheus, sched scheduler.Scheduler, ...) *Manager
  • func (m *Manager) FetchAndBuild(ctx context.Context)
  • func (m *Manager) GetState() *protobuf.State
  • func (m *Manager) Resume(ctx context.Context) error
  • func (m *Manager) Run(ctx context.Context)
  • func (m *Manager) Suspend() error
  • func (m *Manager) SwitchDeploymentLatest() error
• type Mode
  • func ParseMode(s string) (Mode, error)

Types

type Command

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

type ConfigurationOperations

type ConfigurationOperations map[string](map[string]string)

ConfigurationOperations is a map describing the operation associated to each remote/branch. It is a map looking such as: { origin: { main: switch, testing: test }, local { main: switch }

type Confirmer

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

Confirmer allows to handle user confirmations. A generation is submitted to the confirmer. Once a generation has been confirmed, it is pushed to the submit channel.

func NewConfirmer

func NewConfirmer(broker *broker.Broker, mode Mode, duration time.Duration, reason string) *Confirmer

func (*Confirmer) Cancel

func (c *Confirmer) Cancel()

func (*Confirmer) Confirm

func (c *Confirmer) Confirm(generationUuid string)

func (*Confirmer) Start

func (c *Confirmer) Start()

func (*Confirmer) Submit

func (c *Confirmer) Submit(generationUuid string)

type Manager

type Manager struct {
	Fetcher *fetcher.Fetcher
	Builder *builder.Builder

	BuildConfirmer  *Confirmer
	DeployConfirmer *Confirmer
	// contains filtered or unexported fields
}

func New

func New(s *store.Store,
	p prometheus.Prometheus,
	sched scheduler.Scheduler,
	fetcher *fetcher.Fetcher,
	builder *builder.Builder,
	deployer *deployer.Deployer,
	machineId string,
	executor executor.Executor,
	buildConfirmer *Confirmer,
	deployConfirmer *Confirmer,
	broker *broker.Broker,
	configurationOperations ConfigurationOperations,
) *Manager

func (*Manager) FetchAndBuild

func (m *Manager) FetchAndBuild(ctx context.Context)

FetchAndBuild fetches new commits. If a new commit is available, it evaluates and builds the derivation. Once built, it pushes the generation on a channel which is consumed by the deployer.

func (*Manager) GetState

func (m *Manager) GetState() *protobuf.State

func (*Manager) Resume

func (m *Manager) Resume(ctx context.Context) error

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

func (*Manager) Suspend

func (m *Manager) Suspend() error

func (*Manager) SwitchDeploymentLatest

func (m *Manager) SwitchDeploymentLatest() error

type Mode

type Mode int64

const (
	// The user needs to confirm the generation
	Manual Mode = iota
	// Confirm after several seconds the generation. This can be
	// cancelled by the user.
	Auto
	// Immediately confirm the submitted generation
	Without
)

func ParseMode

func ParseMode(s string) (Mode, error)