New creates a new data store from the specified URL

Run should execute task on the implementation. RunResult captures the result of task execution. This means if task execution fails due to a problem in

following encodings are slightly modified from https://github.com/oklog/ulid String returns a lexicographically sortable string encoded Id (26 charact

End will be called immediately after attempting a call execution, regardless of whether the execution failed or not. An error will be passed to End, w

New will generate a new Id for use. New is safe to be called from concurrent threads. SetMachineId should be called once before any calls to New are m

Logger returns the structured logger.

Get returns a raw JSON value of a annotation key

Error is an actionable/checkable error from the container, nil if Status() returns "success", otherwise non-nil

ValidApp returns a valid app to use for inserts

The id to assign the container

GetCall will return a Call that is executable by the Agent, which can be built via various CallOpt's provided to the method.

NewMockInit allows specifying certain apps/fns/triggers. args helps break tests less if we change stuff

ValidFn returns a valid fn to use for inserts

stop and terminate the pool

Wait may be called to await the result of a container's execution. If the provided context is canceled and the container does not return first, the re

New creates an Agent that executes functions locally as Docker containers.

Submit will attempt to execute a call locally, a Call may store information about itself in its Start and End methods, which will be called in Submit

nice compiler errors

ValidTrigger returns a valid trigger to use for inserts

Model will return the underlying models.Call configuration for this call.

WithWriter sets the writer that the call uses to send its output message to TODO this should be required

WARN: this is read only

Create a span/tracker with required context tags

capture logs so they shut up when things are fine

FromHTTPFnRequest Sets up a call from an http trigger request

Header implements http.ResponseWriter, which is used by Agent to push headers to pure runner

LoggerWithFields returns a child context of the provided parent that contains a logger with additional fields from the parent's logger, it returns the

Validate validates all field values, returning the first error, if any.

WriteHeader implements http.ResponseWriter, which is used by Agent to push http status to pure runner

GetAppByID gets an App by ID. Returns ErrAppsNotFound if no app is found.

NewConfig returns a config set from env vars, plus defaults

NewMock creates a new mock datastore

Closer returns a channel that is closed if WaitGroup is in closing state

Removes an image from the LRU cache if cache is not empty

GetTriggers gets a list of triggers that match the specified filter Return ErrDatastoreEmptyAppId if no AppID set in the filter

NewDocker implements drivers.Driver

simple GetCall/Submit combo.

AddSession manipulates the session counter by adding the delta value. Incrementing the session counter is not possible and will set return value to fa

InsertTrigger inserts a trigger. Returns ErrDatastoreEmptyTrigger when trigger is nil, and specific errors for each field Returns ErrTriggerAlreadyExi

UpdateApp updates an App's Config. Returns ErrDatastoreEmptyApp when app is nil, and ErrDatastoreEmptyAppName when app.Name is empty. Returns ErrAppsN

WithConfig sets the agent config to the provided config

Create a new cookie with defaults and/or settings from container task. Callers should Close the cookie regardless of whether they prepare or run it.

IsMaxCapacity returns true if total size of all images exceeds the limit and if there's an image in LRU cache that can be removed.

Start will be called before this call is executed, it may be used to guarantee mutual exclusion, check docker permissions, update timestamps, etc. TOD

Update adds an image to the LRU cache if the image is not marked in-use

With Creates a new annotations object containing the specified value - this does not perform size checks on the total number of keys this validates th

CreateEvictToken creates an eviction token to be used in evictor tracking. Returns an eviction token.