provision

Documentation

Overview

Package provision provides an interface to provision Database Lab clones.

Index

• func IsValidConfig(cfg Config) error
• func NewNoRoomError(errorMessage string) error
• type Config
• type NoRoomError
  • func (e *NoRoomError) Error() string
• type PortPool
• type Provisioner
  • func New(ctx context.Context, cfg *Config, dbCfg *resources.DB, docker *client.Client, ...) (*Provisioner, error)
  • func (p *Provisioner) GetDiskState() (*resources.Disk, error)
  • func (p *Provisioner) GetSessionState(s *resources.Session) (*resources.SessionState, error)
  • func (p *Provisioner) GetSnapshots() ([]resources.Snapshot, error)
  • func (p *Provisioner) Init() error
  • func (p *Provisioner) LastSessionActivity(session *resources.Session, minimumTime time.Time) (*time.Time, error)
  • func (p *Provisioner) Reload(cfg Config, dbCfg resources.DB)
  • func (p *Provisioner) ResetSession(session *resources.Session, snapshotID string) error
  • func (p *Provisioner) StartSession(snapshotID string, user resources.EphemeralUser, extraConfig map[string]string) (*resources.Session, error)
  • func (p *Provisioner) StopSession(session *resources.Session) error

Functions

func IsValidConfig

func IsValidConfig(cfg Config) error

IsValidConfig defines a method for validation of a configuration.

func NewNoRoomError

func NewNoRoomError(errorMessage string) error

NewNoRoomError instances a new NoRoomError.

Types

type Config

type Config struct {
	PortPool          PortPool          `yaml:"portPool"`
	DockerImage       string            `yaml:"dockerImage"`
	UseSudo           bool              `yaml:"useSudo"`
	KeepUserPasswords bool              `yaml:"keepUserPasswords"`
	ContainerConfig   map[string]string `yaml:"containerConfig"`
}

Config defines configuration for provisioning.

type NoRoomError

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

NoRoomError defines a specific error type.

func (*NoRoomError) Error

func (e *NoRoomError) Error() string

type PortPool

type PortPool struct {
	From uint `yaml:"from"`
	To   uint `yaml:"to"`
}

PortPool describes an available port range for clones.

type Provisioner

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

Provisioner describes a struct for ports and clones management.

func New

func New(ctx context.Context, cfg *Config, dbCfg *resources.DB, docker *client.Client, pm *pool.Manager,
	networkID string) (*Provisioner, error)

New creates a new Provisioner instance.

func (*Provisioner) GetDiskState

func (p *Provisioner) GetDiskState() (*resources.Disk, error)

GetDiskState describes the state of the managed disk.

func (*Provisioner) GetSessionState

func (p *Provisioner) GetSessionState(s *resources.Session) (*resources.SessionState, error)

GetSessionState describes the state of the session.

func (*Provisioner) GetSnapshots

func (p *Provisioner) GetSnapshots() ([]resources.Snapshot, error)

GetSnapshots provides a snapshot list.

func (*Provisioner) Init

func (p *Provisioner) Init() error

Init inits provision.

func (*Provisioner) LastSessionActivity

func (p *Provisioner) LastSessionActivity(session *resources.Session, minimumTime time.Time) (*time.Time, error)

LastSessionActivity returns the time of the last session activity.

func (*Provisioner) Reload

func (p *Provisioner) Reload(cfg Config, dbCfg resources.DB)

Reload reloads provision configuration.

func (*Provisioner) ResetSession

func (p *Provisioner) ResetSession(session *resources.Session, snapshotID string) error

ResetSession resets an existing session.

func (*Provisioner) StartSession

func (p *Provisioner) StartSession(snapshotID string, user resources.EphemeralUser,
	extraConfig map[string]string) (*resources.Session, error)

StartSession starts a new session.

func (*Provisioner) StopSession

func (p *Provisioner) StopSession(session *resources.Session) error

StopSession stops an existing session.