bs

Documentation

Index

• Constants
• func RecreateContainers(p DockerProvisioner, w io.Writer) error
• func RegisterQueueTask(p DockerProvisioner) error
• func SaveEnvs(envMap EnvMap, poolEnvMap PoolEnvMap) error
• func SaveImage(digest string) error
• type ClusterHook
  • func (h *ClusterHook) BeforeCreateContainer(node cluster.Node) error
• type Config
  • func LoadConfig() (*Config, error)
  • func (conf *Config) EnvListForEndpoint(dockerEndpoint, poolName string) ([]string, error)
  • func (conf *Config) UpdateEnvMaps(envMap EnvMap, poolEnvMap PoolEnvMap) error
• type DockerProvisioner
• type Env
• type EnvMap
• type EnvSetCmd
  • func (c *EnvSetCmd) Flags() *gnuflag.FlagSet
  • func (c *EnvSetCmd) Info() *cmd.Info
  • func (c *EnvSetCmd) Run(context *cmd.Context, client *cmd.Client) error
• type InfoCmd
  • func (c *InfoCmd) Info() *cmd.Info
  • func (c *InfoCmd) Run(context *cmd.Context, client *cmd.Client) error
• type PoolEnvMap
• type PoolEnvs
• type UpgradeCmd
  • func (c *UpgradeCmd) Info() *cmd.Info
  • func (c *UpgradeCmd) Run(context *cmd.Context, client *cmd.Client) error

Constants

const QueueTaskName = "run-bs"

Functions

func RecreateContainers

func RecreateContainers(p DockerProvisioner, w io.Writer) error

RecreateContainers relaunch all bs containers in the cluster for the given DockerProvisioner, logging progress to the given writer.

It assumes that the given writer is thread safe.

func RegisterQueueTask

func RegisterQueueTask(p DockerProvisioner) error

RegisterQueueTask registers the internal bs queue task for later execution.

func SaveEnvs

func SaveEnvs(envMap EnvMap, poolEnvMap PoolEnvMap) error

func SaveImage

func SaveImage(digest string) error

Types

type ClusterHook

type ClusterHook struct {
	Provisioner DockerProvisioner
}

func (*ClusterHook) BeforeCreateContainer

func (h *ClusterHook) BeforeCreateContainer(node cluster.Node) error

type Config

type Config struct {
	ID    string `bson:"_id"`
	Image string
	Token string
	Envs  []Env
	Pools []PoolEnvs
}

func LoadConfig

func LoadConfig() (*Config, error)

func (*Config) EnvListForEndpoint

func (conf *Config) EnvListForEndpoint(dockerEndpoint, poolName string) ([]string, error)

func (*Config) UpdateEnvMaps

func (conf *Config) UpdateEnvMaps(envMap EnvMap, poolEnvMap PoolEnvMap) error

type DockerProvisioner

type DockerProvisioner interface {
	Cluster() *cluster.Cluster
	RegistryAuthConfig() docker.AuthConfiguration
}

type Env

type Env struct {
	Name  string
	Value string
}

type EnvMap

type EnvMap map[string]string

type EnvSetCmd

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

func (*EnvSetCmd) Flags

func (c *EnvSetCmd) Flags() *gnuflag.FlagSet

func (*EnvSetCmd) Info

func (c *EnvSetCmd) Info() *cmd.Info

func (*EnvSetCmd) Run

func (c *EnvSetCmd) Run(context *cmd.Context, client *cmd.Client) error

type InfoCmd

type InfoCmd struct{}

func (*InfoCmd) Info

func (c *InfoCmd) Info() *cmd.Info

func (*InfoCmd) Run

func (c *InfoCmd) Run(context *cmd.Context, client *cmd.Client) error

type PoolEnvMap

type PoolEnvMap map[string]EnvMap

type PoolEnvs

type PoolEnvs struct {
	Name string
	Envs []Env
}

type UpgradeCmd

type UpgradeCmd struct{}

func (*UpgradeCmd) Info

func (c *UpgradeCmd) Info() *cmd.Info

func (*UpgradeCmd) Run

func (c *UpgradeCmd) Run(context *cmd.Context, client *cmd.Client) error