server

Documentation

Index

• Variables
• func InitServer(job *engine.Job) engine.Status
• type BuildFile
  • func NewBuildFile(srv *Server, outStream, errStream io.Writer, verbose, utilizeCache, rm bool, ...) BuildFile
• type Server
  • func NewServer(eng *engine.Engine, config *daemonconfig.Config) (*Server, error)
  • func (srv *Server) AddEvent(jm utils.JSONMessage)
  • func (srv *Server) Auth(job *engine.Job) engine.Status
  • func (srv *Server) Build(job *engine.Job) engine.Status
  • func (srv *Server) Close() error
  • func (srv *Server) ContainerAttach(job *engine.Job) engine.Status
  • func (srv *Server) ContainerChanges(job *engine.Job) engine.Status
  • func (srv *Server) ContainerCommit(job *engine.Job) engine.Status
  • func (srv *Server) ContainerCopy(job *engine.Job) engine.Status
  • func (srv *Server) ContainerCreate(job *engine.Job) engine.Status
  • func (srv *Server) ContainerDestroy(job *engine.Job) engine.Status
  • func (srv *Server) ContainerExport(job *engine.Job) engine.Status
  • func (srv *Server) ContainerInspect(name string) (*daemon.Container, error)
  • func (srv *Server) ContainerKill(job *engine.Job) engine.Status
  • func (srv *Server) ContainerResize(job *engine.Job) engine.Status
  • func (srv *Server) ContainerRestart(job *engine.Job) engine.Status
  • func (srv *Server) ContainerStart(job *engine.Job) engine.Status
  • func (srv *Server) ContainerStop(job *engine.Job) engine.Status
  • func (srv *Server) ContainerTop(job *engine.Job) engine.Status
  • func (srv *Server) ContainerWait(job *engine.Job) engine.Status
  • func (srv *Server) Containers(job *engine.Job) engine.Status
  • func (srv *Server) DeleteImage(name string, imgs *engine.Table, first, force, noprune bool) error
  • func (srv *Server) DockerInfo(job *engine.Job) engine.Status
  • func (srv *Server) DockerVersion(job *engine.Job) engine.Status
  • func (srv *Server) Events(job *engine.Job) engine.Status
  • func (srv *Server) GetEvents() []utils.JSONMessage
  • func (srv *Server) HTTPRequestFactory(metaHeaders map[string][]string) *utils.HTTPRequestFactory
  • func (srv *Server) ImageDelete(job *engine.Job) engine.Status
  • func (srv *Server) ImageExport(job *engine.Job) engine.Status
  • func (srv *Server) ImageGetCached(imgID string, config *runconfig.Config) (*image.Image, error)
  • func (srv *Server) ImageHistory(job *engine.Job) engine.Status
  • func (srv *Server) ImageImport(job *engine.Job) engine.Status
  • func (srv *Server) ImageInsert(job *engine.Job) engine.Status
  • func (srv *Server) ImageInspect(name string) (*image.Image, error)
  • func (srv *Server) ImageLoad(job *engine.Job) engine.Status
  • func (srv *Server) ImagePull(job *engine.Job) engine.Status
  • func (srv *Server) ImagePush(job *engine.Job) engine.Status
  • func (srv *Server) ImageTag(job *engine.Job) engine.Status
  • func (srv *Server) Images(job *engine.Job) engine.Status
  • func (srv *Server) ImagesSearch(job *engine.Job) engine.Status
  • func (srv *Server) ImagesViz(job *engine.Job) engine.Status
  • func (srv *Server) IsRunning() bool
  • func (srv *Server) JobInspect(job *engine.Job) engine.Status
  • func (srv *Server) LogEvent(action, id, from string) *utils.JSONMessage
  • func (srv *Server) RegisterLinks(container *daemon.Container, hostConfig *runconfig.HostConfig) error
  • func (srv *Server) SetRunning(status bool)

Variables

var (
	ErrDockerfileEmpty = errors.New("Dockerfile cannot be empty")
)

Functions

func InitServer

func InitServer(job *engine.Job) engine.Status

jobInitApi runs the remote api server `srv` as a daemon, Only one api server can run at the same time - this is enforced by a pidfile. The signals SIGINT, SIGQUIT and SIGTERM are intercepted for cleanup.

Types

type BuildFile

type BuildFile interface {
	Build(io.Reader) (string, error)
	CmdFrom(string) error
	CmdRun(string) error
}

func NewBuildFile

func NewBuildFile(srv *Server, outStream, errStream io.Writer, verbose, utilizeCache, rm bool, outOld io.Writer, sf *utils.StreamFormatter, configFile *registry.ConfigFile) BuildFile

type Server

type Server struct {
	sync.RWMutex

	Eng *engine.Engine
	// contains filtered or unexported fields
}

func NewServer

func NewServer(eng *engine.Engine, config *daemonconfig.Config) (*Server, error)

func (*Server) AddEvent

func (srv *Server) AddEvent(jm utils.JSONMessage)

func (*Server) Auth

func (srv *Server) Auth(job *engine.Job) engine.Status

func (*Server) Build

func (srv *Server) Build(job *engine.Job) engine.Status

func (*Server) Close

func (srv *Server) Close() error

func (*Server) ContainerAttach

func (srv *Server) ContainerAttach(job *engine.Job) engine.Status

func (*Server) ContainerChanges

func (srv *Server) ContainerChanges(job *engine.Job) engine.Status

func (*Server) ContainerCommit

func (srv *Server) ContainerCommit(job *engine.Job) engine.Status

func (*Server) ContainerCopy

func (srv *Server) ContainerCopy(job *engine.Job) engine.Status

func (*Server) ContainerCreate

func (srv *Server) ContainerCreate(job *engine.Job) engine.Status

func (*Server) ContainerDestroy

func (srv *Server) ContainerDestroy(job *engine.Job) engine.Status

func (*Server) ContainerExport

func (srv *Server) ContainerExport(job *engine.Job) engine.Status

func (*Server) ContainerInspect

func (srv *Server) ContainerInspect(name string) (*daemon.Container, error)

func (*Server) ContainerKill

func (srv *Server) ContainerKill(job *engine.Job) engine.Status

ContainerKill send signal to the container If no signal is given (sig 0), then Kill with SIGKILL and wait for the container to exit. If a signal is given, then just send it to the container and return.

func (*Server) ContainerResize

func (srv *Server) ContainerResize(job *engine.Job) engine.Status

func (*Server) ContainerRestart

func (srv *Server) ContainerRestart(job *engine.Job) engine.Status

func (*Server) ContainerStart

func (srv *Server) ContainerStart(job *engine.Job) engine.Status

func (*Server) ContainerStop

func (srv *Server) ContainerStop(job *engine.Job) engine.Status

func (*Server) ContainerTop

func (srv *Server) ContainerTop(job *engine.Job) engine.Status

func (*Server) ContainerWait

func (srv *Server) ContainerWait(job *engine.Job) engine.Status

func (*Server) Containers

func (srv *Server) Containers(job *engine.Job) engine.Status

func (*Server) DeleteImage

func (srv *Server) DeleteImage(name string, imgs *engine.Table, first, force, noprune bool) error

func (*Server) DockerInfo

func (srv *Server) DockerInfo(job *engine.Job) engine.Status

func (*Server) DockerVersion

func (srv *Server) DockerVersion(job *engine.Job) engine.Status

func (*Server) Events

func (srv *Server) Events(job *engine.Job) engine.Status

func (*Server) GetEvents

func (srv *Server) GetEvents() []utils.JSONMessage

func (*Server) HTTPRequestFactory

func (srv *Server) HTTPRequestFactory(metaHeaders map[string][]string) *utils.HTTPRequestFactory

func (*Server) ImageDelete

func (srv *Server) ImageDelete(job *engine.Job) engine.Status

func (*Server) ImageExport

func (srv *Server) ImageExport(job *engine.Job) engine.Status

ImageExport exports all images with the given tag. All versions containing the same tag are exported. The resulting output is an uncompressed tar ball. name is the set of tags to export. out is the writer where the images are written to.

func (*Server) ImageGetCached

func (srv *Server) ImageGetCached(imgID string, config *runconfig.Config) (*image.Image, error)

func (*Server) ImageHistory

func (srv *Server) ImageHistory(job *engine.Job) engine.Status

func (*Server) ImageImport

func (srv *Server) ImageImport(job *engine.Job) engine.Status

func (*Server) ImageInsert

func (srv *Server) ImageInsert(job *engine.Job) engine.Status

FIXME: 'insert' is deprecated and should be removed in a future version.

func (*Server) ImageInspect

func (srv *Server) ImageInspect(name string) (*image.Image, error)

func (*Server) ImageLoad

func (srv *Server) ImageLoad(job *engine.Job) engine.Status

Loads a set of images into the repository. This is the complementary of ImageExport. The input stream is an uncompressed tar ball containing images and metadata.

func (*Server) ImagePull

func (srv *Server) ImagePull(job *engine.Job) engine.Status

func (*Server) ImagePush

func (srv *Server) ImagePush(job *engine.Job) engine.Status

FIXME: Allow to interrupt current push when new push of same image is done.

func (*Server) ImageTag

func (srv *Server) ImageTag(job *engine.Job) engine.Status

func (*Server) Images

func (srv *Server) Images(job *engine.Job) engine.Status

func (*Server) ImagesSearch

func (srv *Server) ImagesSearch(job *engine.Job) engine.Status

func (*Server) ImagesViz

func (srv *Server) ImagesViz(job *engine.Job) engine.Status

func (*Server) IsRunning

func (srv *Server) IsRunning() bool

func (*Server) JobInspect

func (srv *Server) JobInspect(job *engine.Job) engine.Status

func (*Server) LogEvent

func (srv *Server) LogEvent(action, id, from string) *utils.JSONMessage

func (*Server) RegisterLinks

func (srv *Server) RegisterLinks(container *daemon.Container, hostConfig *runconfig.HostConfig) error

func (*Server) SetRunning

func (srv *Server) SetRunning(status bool)