container

Documentation

Index

• Constants
• Variables
• func BsSysLogPort() int
• func SafeAttachWaitContainer(p DockerProvisioner, opts docker.AttachToContainerOptions) (int, error)
• type AppLocker
• type Container
  • func (c *Container) Address() *url.URL
  • func (c *Container) AsUnit(a provision.App) provision.Unit
  • func (c *Container) Available() bool
  • func (c *Container) Commit(p DockerProvisioner, writer io.Writer) (string, error)
  • func (c *Container) Create(args *CreateArgs) error
  • func (c *Container) Exec(p DockerProvisioner, stdout, stderr io.Writer, cmd string, args ...string) error
  • func (c *Container) Logs(p DockerProvisioner, w io.Writer) (int, error)
  • func (c *Container) NetworkInfo(p DockerProvisioner) (NetworkInfo, error)
  • func (c *Container) Remove(p DockerProvisioner) error
  • func (c *Container) SetImage(p DockerProvisioner, imageId string) error
  • func (c *Container) SetStatus(p DockerProvisioner, status provision.Status, updateDB bool) error
  • func (c *Container) Shell(p DockerProvisioner, stdin io.Reader, stdout, stderr io.Writer, pty Pty) error
  • func (c *Container) ShortID() string
  • func (c *Container) Sleep(p DockerProvisioner) error
  • func (c *Container) Start(args *StartArgs) error
  • func (c *Container) Stop(p DockerProvisioner) error
• type CreateArgs
• type DockerLog
  • func (d *DockerLog) IsBS(pool string) (bool, error)
  • func (d *DockerLog) LogOpts(pool string) (string, map[string]string, error)
  • func (d *DockerLog) Update(toMerge *provision.ScopedConfig) error
• type DockerProvisioner
• type NetworkInfo
• type Pty
• type StartArgs

Constants

const (
	DockerLogDriverConfig = "log-driver"
)

Variables

var (
	ErrLogDriverMandatory  = errors.New("log-driver is mandatory")
	ErrLogDriverBSNoParams = errors.New("bs log-driver do not accept log-opts, please use bs-env-set to configure it.")
)

Functions

func BsSysLogPort

func BsSysLogPort() int

func SafeAttachWaitContainer

func SafeAttachWaitContainer(p DockerProvisioner, opts docker.AttachToContainerOptions) (int, error)

Types

type AppLocker

type AppLocker interface {
	Lock(appName string) bool
	Unlock(appName string)
}

type Container

type Container struct {
	MongoID                 bson.ObjectId `bson:"_id,omitempty"`
	ID                      string
	AppName                 string
	ProcessName             string
	Type                    string
	IP                      string
	HostAddr                string
	HostPort                string
	PrivateKey              string
	Status                  string
	Version                 string
	Image                   string
	Name                    string
	User                    string
	BuildingImage           string
	LastStatusUpdate        time.Time
	LastSuccessStatusUpdate time.Time
	LockedUntil             time.Time
	Routable                bool `bson:"-"`
}

func (*Container) Address

func (c *Container) Address() *url.URL

func (*Container) AsUnit

func (c *Container) AsUnit(a provision.App) provision.Unit

func (*Container) Available

func (c *Container) Available() bool

func (*Container) Commit

func (c *Container) Commit(p DockerProvisioner, writer io.Writer) (string, error)

Commits commits the container, creating an image in Docker. It then returns the image identifier for usage in future container creation.

func (*Container) Create

func (c *Container) Create(args *CreateArgs) error

func (*Container) Exec

func (c *Container) Exec(p DockerProvisioner, stdout, stderr io.Writer, cmd string, args ...string) error

func (*Container) Logs

func (c *Container) Logs(p DockerProvisioner, w io.Writer) (int, error)

func (*Container) NetworkInfo

func (c *Container) NetworkInfo(p DockerProvisioner) (NetworkInfo, error)

func (*Container) Remove

func (c *Container) Remove(p DockerProvisioner) error

func (*Container) SetImage

func (c *Container) SetImage(p DockerProvisioner, imageId string) error

func (*Container) SetStatus

func (c *Container) SetStatus(p DockerProvisioner, status provision.Status, updateDB bool) error

func (*Container) Shell

func (c *Container) Shell(p DockerProvisioner, stdin io.Reader, stdout, stderr io.Writer, pty Pty) error

func (*Container) ShortID

func (c *Container) ShortID() string

func (*Container) Sleep

func (c *Container) Sleep(p DockerProvisioner) error

func (*Container) Start

func (c *Container) Start(args *StartArgs) error

func (*Container) Stop

func (c *Container) Stop(p DockerProvisioner) error

type CreateArgs

type CreateArgs struct {
	ImageID          string
	Commands         []string
	App              provision.App
	Deploy           bool
	Provisioner      DockerProvisioner
	DestinationHosts []string
	ProcessName      string
}

type DockerLog

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

func (*DockerLog) IsBS

func (d *DockerLog) IsBS(pool string) (bool, error)

func (*DockerLog) LogOpts

func (d *DockerLog) LogOpts(pool string) (string, map[string]string, error)

func (*DockerLog) Update

func (d *DockerLog) Update(toMerge *provision.ScopedConfig) error

type DockerProvisioner

type DockerProvisioner interface {
	Cluster() *cluster.Cluster
	Collection() *storage.Collection
	PushImage(name, tag string) error
}

type NetworkInfo

type NetworkInfo struct {
	HTTPHostPort string
	IP           string
}

type Pty

type Pty struct {
	Width  int
	Height int
	Term   string
}

type StartArgs

type StartArgs struct {
	Provisioner DockerProvisioner
	App         provision.App
	Deploy      bool
}