func TestRegistry(t *testing.T) { image := test.GetTestUtilsImage() sizer, err := CheckRegistry(context.Background(), image, docker.AuthConfigurat

CloseGroup initiates a close and blocks until session counter becomes zero.

DefaultCtx returns a context object (which may have custom attributes set) this may be used (e.g.) to pass on tenancy and user details that would orig

DockerAuth should return docker auth credentials that will authenticate against a docker registry for a given drivers.ContainerTask.Image(). An error

Extensions are extra driver specific configuration options. They should be more specific but it's easier to be lazy.

GetNotifier returns a channel that can be monitored. The channel will return data every time IsMaxCapacity() flips from false to true state.

Input feeds the container with data

IsFuncError checks if err is of type FuncError

MarshalText implements the encoding.TextMarshaler interface by returning the string encoded Id.

NewLBAgent creates an Agent that knows how to load-balance function calls across a group of runner nodes.

NewRequestBasedFnAnnotator creates a FnAnnotator that inspects the incoming request host and port, and uses this to generate fn invoke endpoint URLs b

RequestIDFromContext extract the request id from the context

Set image pull retry policy and retriable error checker

Rather than rely on Prometheus for this, expose status that's specific to the runner lifecycle through this. Deprecated: Do not use.

If a status image container is configured (for handling custom statuses) the supplied opaque JSON is passed as an input to that image. Output from the

Tmpfs Filesystem size limit for the container, in megabytes.

UpdateTrigger updates a trigger object in the data store

returns inuse versus free

WithDBURL maps EnvDBURL

WithFnAnnotator adds a fnEndpoint provider to the server

WithLogFormat maps EnvLogFormat TODO(deprecate): caller should just call SetLogFormat

WithLogLevel maps EnvLogLevel TODO(deprecate): caller should just call WithLogLevel

WithTriggerAnnotator adds a trigggerEndpoint provider to the server

WithWebPort maps EnvPort

See fn-test-utils for json response

We compare both busy + lru size against max. However, we also check if lru is not empty. This is because there's no point to show over capacity if Pop

newHotContainer creates a container that can be used for multiple sequential events

AddRootMiddlewareFunc add middleware for end user applications

Command returns the command to run within the container.

Configure the remote runner by passing config data.

EnableShutdownEndpoint adds /shutdown to initiate a shutdown of an fn server.

EnvVars returns environment variable key-value pairs.

Port exposed in Fn Container for local debugger to attach to

GetAppID gets an app ID by app name, ensures if app exists. Returns ErrDatastoreEmptyAppName for empty appName. Returns ErrAppsNotFound if no app is f

GetHelper returns a helper for a specific driver

Retrieve current stats/usage

HandleDone is cleanup function to cancel pending contexts and to record stats for the placement session.

IsDuplicateKeyError determines if an error indicates if the prior error was caused by a duplicate key insert

Driver will write output log from task execution to these writers. Must be non-nil. Use io.Discard if log is irrelevant.

NewCachedDataAccess is a wrapper that caches entries temporarily

NewClamWriter creates a clamp writer that will limit the number of bytes written to to an underlying stream This allows up to max bytes to be written

NewFromEnv creates a new Functions server based on env vars.