newTransfer initiates a new docker-pull if there's no active docker-pull present for the same image.

since New with fresh dbs skips all migrations: * open a fresh db on latest version * run all down migrations * run all up migrations [ then run tests

https://github.com/fsouza/go-dockerclient/blob/master/misc.go#L166

prepHeaders is a utility function to compile http headers into a flat array.

prometheus only allows [a-zA-Z0-9:_] in metrics names.

record a retry attempt for the api with status/reason provided

rmBusyLocked updates an image in the in-use list and returns true if the image is removed from the in-use list.

Run executes the docker container. If task runs, drivers.RunResult will be returned. If something fails outside the task (ie: Docker), it will return

runHotReq enqueues a free slot to slot queue manager and watches various timers and the consumer until the slot is consumed. A return value of false m

runImageStats runs continuously in background to periodically sample image cleaner statistics

check if the db already existed, if the db is brand new then we can skip over all the migrations BUT we must be sure to set the right migration number

Runs a status call using status image with baked in parameters.

setRequestGetBody sets GetBody function on the given http.Request if it is missing. GetBody allows reading from the request body without mutating the

spawnPipeToFn pumps data to Function via callHandle io.PipeWriter (pipeToFnW) which is fed using input channel.

spawnReceiver starts a gRPC receiver, which feeds received LB messages into inQueue

spawnSender starts a gRPC sender, which pumps messages from outQueue to the LB.

waitError waits until the session is completed and results any queued error if there is any.

waitHot pings and waits for a hot container from the slot queue

whoAmI searches for a non-local address on any network interface, returning the first one it finds. it could be expanded to search eth0 or en0 only bu

AddAPIMiddleware add middleware

AddAPIMiddlewareFunc add middlewarefunc

AddAppListener adds an AppListener for the server to use.

AddAppListener adds a listener that will be invoked around any relevant methods.

AddCA adds a ca cert to the given tls config

AddCallListener adds a listener that will be fired before and after a function is executed.

implements Agent

implements Agent

AddCallListener adds a listener that will be invoked around any call invocations.

AddClientCA adds a client cert to the given tls config

AddEndpointFunc adds an endpoint to /v2/x

AddExtension both registers an extension and adds it. This is useful during extension development or if you want to build a custom server without usin