server

Documentation

Index

• func AcceptConnections(job *engine.Job) engine.Status
• func AttachProfiler(router *mux.Router)
• func ListenAndServe(proto, addr string, job *engine.Job) error
• func ServeApi(job *engine.Job) engine.Status
• func ServeFd(addr string, handle http.Handler) error
• func ServeRequest(eng *engine.Engine, apiversion version.Version, w http.ResponseWriter, ...) error
• type HttpApiFunc
• type HttpMonApiFunc
• type HttpServer
  • func (s *HttpServer) Close() error
  • func (s *HttpServer) Serve() error
• type MonitorServer
  • func NewMonitorServer(cfg *ServerConfig, m *daemon.DockerMonitor, w watch.Interface) *MonitorServer
  • func (s *MonitorServer) AcceptConnections()
  • func (s *MonitorServer) Attach(streamConfig *daemon.StreamConfig, openStdin, stdinOnce, tty bool, ...) chan error
  • func (s *MonitorServer) Notify(err error)
  • func (s *MonitorServer) Shutdown()
  • func (s *MonitorServer) Start() <-chan struct{}
  • func (s *MonitorServer) Wait() error
• type Server
  • func (s *Server) Close()
  • func (s *Server) ServeApi(protoAddrs []string) error
• type ServerConfig

Functions

func AcceptConnections

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

func AttachProfiler

func AttachProfiler(router *mux.Router)

func ListenAndServe

func ListenAndServe(proto, addr string, job *engine.Job) error

ListenAndServe sets up the required http.Server and gets it listening for each addr passed in and does protocol specific checking.

func ServeApi

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

ServeApi loops through all of the protocols sent in to docker and spawns off a go routine to setup a serving http.Server for each.

func ServeFd

func ServeFd(addr string, handle http.Handler) error

ServeFD creates an http.Server and sets it up to serve given a socket activated argument.

func ServeRequest

func ServeRequest(eng *engine.Engine, apiversion version.Version, w http.ResponseWriter, req *http.Request) error

ServeRequest processes a single http request to the docker remote api. FIXME: refactor this to be part of Server and not require re-creating a new router each time. This requires first moving ListenAndServe into Server.

Types

type HttpApiFunc

type HttpApiFunc func(eng *engine.Engine, version version.Version, w http.ResponseWriter, r *http.Request, vars map[string]string) error

type HttpMonApiFunc

type HttpMonApiFunc func(version version.Version, w http.ResponseWriter, r *http.Request, vars map[string]string) error

type HttpServer

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

func (*HttpServer) Close

func (s *HttpServer) Close() error

func (*HttpServer) Serve

func (s *HttpServer) Serve() error

type MonitorServer

type MonitorServer struct {
	Server
	AttachSignal chan struct{}
	// contains filtered or unexported fields
}

func NewMonitorServer

func NewMonitorServer(cfg *ServerConfig, m *daemon.DockerMonitor, w watch.Interface) *MonitorServer

func (*MonitorServer) AcceptConnections

func (s *MonitorServer) AcceptConnections()

func (*MonitorServer) Attach

func (s *MonitorServer) Attach(streamConfig *daemon.StreamConfig, openStdin, stdinOnce, tty bool, stdin io.ReadCloser, stdinCloser io.Closer, stdout io.Writer, stderr io.Writer) chan error

func (*MonitorServer) Notify

func (s *MonitorServer) Notify(err error)

func (*MonitorServer) Shutdown

func (s *MonitorServer) Shutdown()

func (*MonitorServer) Start

func (s *MonitorServer) Start() <-chan struct{}

func (*MonitorServer) Wait

func (s *MonitorServer) Wait() error

type Server

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

func (*Server) Close

func (s *Server) Close()

func (*Server) ServeApi

func (s *Server) ServeApi(protoAddrs []string) error

ServeApi loops through all of the protocols sent in to docker and spawns off a go routine to setup a serving http.Server for each.

type ServerConfig

type ServerConfig struct {
	Logging    bool
	EnableCors bool
	//CorsHeaders string
	Version     string
	SocketGroup string
	TLSConfig   *tls.Config
}