docker

Documentation

Index

• Variables
• type Console
  • func (c Console) Write(b []byte) (int, error)
• type Environment
  • func New(id string, m *Metadata, c *environment.Configuration) (*Environment, error)
  • func (e *Environment) Attach() error
  • func (e *Environment) Config() *environment.Configuration
  • func (e *Environment) Create() error
  • func (e *Environment) Destroy() error
  • func (e *Environment) Events() *events.EventBus
  • func (e *Environment) Exists() (bool, error)
  • func (e *Environment) ExitState() (uint32, bool, error)
  • func (e *Environment) InSituUpdate() error
  • func (e *Environment) IsAttached() bool
  • func (e *Environment) IsRunning() (bool, error)
  • func (e *Environment) OnBeforeStart() error
  • func (e *Environment) Readlog(lines int) ([]string, error)
  • func (e *Environment) SendCommand(c string) error
  • func (e *Environment) SetImage(i string)
  • func (e *Environment) SetStopConfiguration(c api.ProcessStopConfiguration)
  • func (e *Environment) SetStream(s *types.HijackedResponse)
  • func (e *Environment) Start() error
  • func (e *Environment) State() string
  • func (e *Environment) Stop() error
  • func (e *Environment) Terminate(signal os.Signal) error
  • func (e *Environment) Type() string
  • func (e *Environment) WaitForStop(seconds uint, terminate bool) error
• type Metadata

Variables

var ErrNotAttached = errors.New("not attached to instance")

Types

type Console

type Console struct {
	HandlerFunc *func(string)
}

func (Console) Write

func (c Console) Write(b []byte) (int, error)

type Environment

type Environment struct {

	// The public identifier for this environment. In this case it is the Docker container
	// name that will be used for all instances created under it.
	Id string

	// The environment configuration.
	Configuration *environment.Configuration
	// contains filtered or unexported fields
}

func New

func New(id string, m *Metadata, c *environment.Configuration) (*Environment, error)

Creates a new base Docker environment. The ID passed through will be the ID that is used to reference the container from here on out. This should be unique per-server (we use the UUID by default). The container does not need to exist at this point.

func (*Environment) Attach

func (e *Environment) Attach() error

Attaches to the docker container itself and ensures that we can pipe data in and out of the process stream. This should not be used for reading console data as you *will* miss important output at the beginning because of the time delay with attaching to the output.

func (*Environment) Config

func (e *Environment) Config() *environment.Configuration

Returns the environment configuration allowing a process to make modifications of the environment on the fly.

func (*Environment) Create

func (e *Environment) Create() error

Creates a new container for the server using all of the data that is currently available for it. If the container already exists it will be returnee.

func (*Environment) Destroy

func (e *Environment) Destroy() error

Remove the Docker container from the machine. If the container is currently running it will be forcibly stopped by Docker.

func (*Environment) Events

func (e *Environment) Events() *events.EventBus

func (*Environment) Exists

func (e *Environment) Exists() (bool, error)

Determines if the container exists in this environment. The ID passed through should be the server UUID since containers are created utilizing the server UUID as the name and docker will work fine when using the container name as the lookup parameter in addition to the longer ID auto-assigned when the container is created.

func (*Environment) ExitState

func (e *Environment) ExitState() (uint32, bool, error)

Determine the container exit state and return the exit code and whether or not the container was killed by the OOM killer.

func (*Environment) InSituUpdate

func (e *Environment) InSituUpdate() error

Performs an in-place update of the Docker container's resource limits without actually making any changes to the operational state of the container. This allows memory, cpu, and IO limitations to be adjusted on the fly for individual instances.

func (*Environment) IsAttached

func (e *Environment) IsAttached() bool

Determine if the this process is currently attached to the container.

func (*Environment) IsRunning

func (e *Environment) IsRunning() (bool, error)

Determines if the server's docker container is currently running. If there is no container present, an error will be raised (since this shouldn't be a case that ever happens under correctly developed circumstances).

You can confirm if the instance wasn't found by using client.IsErrNotFound from the Docker API.

@see docker/client/errors.go

func (*Environment) OnBeforeStart

func (e *Environment) OnBeforeStart() error

Run before the container starts and get the process configuration from the Panel. This is important since we use this to check configuration files as well as ensure we always have the latest version of an egg available for server processes.

This process will also confirm that the server environment exists and is in a bootable state. This ensures that unexpected container deletion while Wings is running does not result in the server becoming unbootable.

func (*Environment) Readlog

func (e *Environment) Readlog(lines int) ([]string, error)

Reads the log file for the server. This does not care if the server is running or not, it will simply try to read the last X bytes of the file and return them.

func (*Environment) SendCommand

func (e *Environment) SendCommand(c string) error

Sends the specified command to the stdin of the running container instance. There is no confirmation that this data is sent successfully, only that it gets pushed into the stdin.

func (*Environment) SetImage

func (e *Environment) SetImage(i string)

func (*Environment) SetStopConfiguration

func (e *Environment) SetStopConfiguration(c api.ProcessStopConfiguration)

Sets the stop configuration for the environment.

func (*Environment) SetStream

func (e *Environment) SetStream(s *types.HijackedResponse)

Set if this process is currently attached to the process.

func (*Environment) Start

func (e *Environment) Start() error

Starts the server environment and begins piping output to the event listeners for the console. If a container does not exist, or needs to be rebuilt that will happen in the call to OnBeforeStart().

func (*Environment) State

func (e *Environment) State() string

Returns the current environment state.

func (*Environment) Stop

func (e *Environment) Stop() error

Stops the container that the server is running in. This will allow up to 30 seconds to pass before the container is forcefully terminated if we are trying to stop it without using a command sent into the instance.

You most likely want to be using WaitForStop() rather than this function, since this will return as soon as the command is sent, rather than waiting for the process to be completed stopped.

func (*Environment) Terminate

func (e *Environment) Terminate(signal os.Signal) error

Forcefully terminates the container using the signal passed through.

func (*Environment) Type

func (e *Environment) Type() string

func (*Environment) WaitForStop

func (e *Environment) WaitForStop(seconds uint, terminate bool) error

Attempts to gracefully stop a server using the defined stop command. If the server does not stop after seconds have passed, an error will be returned, or the instance will be terminated forcefully depending on the value of the second argument.

type Metadata

type Metadata struct {
	Image string
	Stop  api.ProcessStopConfiguration
}