Scan scans a DateTime value from database driver type.

Status should return the current status of the task. Only valid options are {"error", "success", "timeout", "killed", "cancelled"}.

Convenience function for us to get number of calls

DoneSession decrements 1 from accumulated sessions and wakes up listeners when this reaches zero.

FromModel creates a call object from an existing stored call model object, reading the body from the stored call payload

GetApps gets a slice of Apps, optionally filtered by name, and a cursor. Missing filter or empty name will match all Apps.

Image returns the runtime specific image to run.

InsertFn inserts a new function if one does not exist, applying any defaults necessary,

PerformEviction performs evictions to satisfy cpu & mem arguments and returns a slice of channels for evictions performed. The callers can wait on the

Reset behaves as both Stop and Reset, draining its channel before calling reset. It differs from the stdlib Timer.Reset by being safe to call on an '

shutdown initiates a shutdown and terminates the gRPC session with a given error.

fetch a pre-allocated free id from the pool may return too busy error.

Annotates a trigger on read

DeleteEvictToken deletes an eviction token from evictor system

GetFnByID returns a function by ID. Returns ErrDatastoreEmptyFnID if fnID is empty. Returns ErrFnsNotFound if a fn is not found.

GetFns returns a list of funcs, and a cursor, applying any additional filters provided.

GetString returns a string value if the annotation value is a string, otherwise an error

GetTriggerByID gets a trigger by it's id. Returns ErrTriggerNotFound when no matching trigger is found

InsertApp inserts an App. Returns ErrDatastoreEmptyApp when app is nil, and ErrDatastoreEmptyAppName when app.Name is empty. Returns ErrAppsAlreadyExi

NewAPIError returns an APIError given a code and error

NewTimer starts a new Timer with the given duration.

RemoveApp removes the App named appName. Returns ErrDatastoreEmptyAppName if appName is empty. Returns ErrAppsNotFound if an App is not found.

Generate an Fn structure which passes validation

IsAPIError returns whether err implements APIError

RemoveFn removes a function. Returns ErrDatastoreEmptyFnID if fnID is empty. Returns ErrFnsNotFound if a func is not found.

SetCreated sets zeroed field to defaults.

enqueueCallResponse enqueues a Submit() response to the LB and initiates a graceful shutdown of the session.

Generate a Trigger structure which passes validation

for test methods, return concrete type, but don't expose

Attempt to queue/transmit the error to client

AddAPIMiddleware add middleware

Annotates a trigger on read

BackgroundContext returns a context that is specifically not a child of the provided parent context wrt any cancellation or deadline of the parent, so

GetAPIErrorCode returns 0 if an error is not an APIError, or the result of the Code() method from an APIError

Mark/Unmark an image in-use. If an image is in-use, it will not be a candidate in LRU. When the reference count of the image drops to zero (via MarkFr

NewDockerDriver creates a default docker driver from agent config

Removes a Trigger. Returns field specific errors if they are empty. Returns nil if successful

returns an error for unrecoverable errors that should not be retried

Validate/Inspect image. Returns true if the image needs to be pulled and non-nil error if validation/inspection fails.

See fn-test-utils for json response

CloseGroupNB is non-blocking version of CloseGroup which returns a channel that can be waited on.

Decimate will down sample to a max number of points in a given sample by averaging samples together. i.e. max=240, if we have 240 samples, return them

Release the id back to the pool

GetResourceToken returns a resource token. Memory is expected to be provided in MB units.

GetResourceTokenNB is the non-blocking equivalent of GetResourceToken. The return value is the resource token itself. If the request cannot be satisfi

GetTriggerBySource loads a trigger by type and source ID - this is only needed when the data store is also used for agent read access

MergeChange merges a delta (possibly including deletes) with an existing annotations object and returns a new (copy) annotations object or an error. T

New creates a new Functions server with the opts given. For convenience, users may prefer to use NewFromEnv but New is more flexible if needed.

NewBasicResourceProvider creates a dumb resource provider that generates resources that have valid, random names (and other unique attributes)

NewRequestBasedTriggerAnnotator creates a TriggerAnnotator that inspects the incoming request host and port, and uses this to generate http trigger en

NewValidator returns a models.Datastore which validates certain arguments before delegating to ds.

ParseDateTime parses a string that represents an ISO8601 time or a unix epoch

UpdateFn updates a function that exists under the same id. ErrMissingName is func.Name is empty.

WithDockerDriver Provides a customer driver to agent

WithLogger stores the logger.

WithType maps EnvNodeType