NewStaticURLFnAnnotator annotates triggers bases on a given, specified URL base - e.g. "https://my.domain" ---> "https://my.domain/t/app/source"

NewStaticURLTriggerAnnotator annotates triggers bases on a given, specified URL base - e.g. "https://my.domain" ---> "https://my.domain/t/app/source"

Register registers a new SQL helper

String converts this time to a string

implements fmt.Stringer

StripHopHeaders removes transport related headers.

ValidateText returns true if the data is a valid encoding.

Value converts DateTime to a primitive value ready to written to a database.

WithAgent allows directly setting an agent

WithLogDest maps EnvLogDest TODO(deprecate): caller should just call SetLogDest

WithLogger sets stderr to the provided one

WithReadDataAccess overrides the LB read DataAccess for a server

checkSocketDestination verifies that the socket file created by the FDK is valid and permitted - notably verifying that any symlinks are relative to t

clone produces a key-wise copy of the underlying annotations publically MD can be copied by reference as it's (by contract) immutable

enqueueMsg attempts to queue a message to the gRPC sender

create a simple non-blocking agent. Non-blocking does not queue, so it's easier to test and see if evictions took place.

isEligible returns true if the image is eligible to be managed by image cacher.

sendNotify tries to wake up any pending listener on notify channel

setupLogger returns a ReadWriteCloser that may have: * [always] writes bytes to a size limited buffer, that can be read from using io.Reader * [always

return a model with all fields filled in with fnproject/fn-test-utils:latest image, change as needed

AfterAppCreate called after creating App in the database

AfterAppDelete called after deleting App in the database

AfterAppGet called after getting app from database

AfterAppUpdate called after updating App in the database

AfterAppsList called after deleting getting a list of user's apps. apps is the result after applying AppFilter.

AfterCall is invoked just after an invocation is finished, providing that BeforeCall returned without an error

AfterFnCreate called after fn create in the datastore

AfterFnDelete called after fn deleted from the datastore

AfterFnUpdate called after fn updated in datastore

AfterTriggerCreate called after trigger create in the datastore

AfterTriggerDelete called after trigger deleted from the datastore

AfterTriggerUpdate called after trigger updated in datastore

Each of these are github.com/fsouza/go-dockerclient methods

BeforeAppCreate called right before creating App in the database

BeforeAppDelete called right before deleting App in the database

BeforeAppGet called right before getting an app

BeforeAppUpdate called right before updating App in the database

BeforeAppsList called right before getting a list of all user's apps. Modify the filter to adjust what gets returned.

BeforeCall is invoked just prior to running an invocation. The Task is definitely going to be used for this invocation. Invocation extensions are pass

BeforeFnCreate called before fn created in the datastore

BeforeFnDelete called before fn deleted from the datastore

BeforeFnUpdate called before fn update in datastore

BeforeTriggerCreate called before trigger created in the datastore

BeforeTriggerDelete called before trigger deleted from the datastore

BeforeTriggerUpdate called before trigger update in datastore

CPUs in milli CPU units

CheckTableExists checks if a table exists in the DB

Clone creates a deep copy of a trigger

Close should clean up any resources the cookie was using, or was going to use.

Fetch driver specific container configuration. Use this to access the container create options. If Driver.Prepare() is not yet called with the cookie,

Datastore implements fnext.ExtServer

EqualsWithAnnotationSubset is equivalent to Equals except it accepts cases where t's annotations are strict subset of t2

FromModelAndInput creates a call object from an existing stored call model object , reading the body from a provided stream

Filesystem size limit for the container, in megabytes.

GenerateLogScaleHistogramBuckets generates number of buckets specified by count on the log scale such that the value specified by max is in the last b

GetAppByID abstracts querying the datastore for an app.

Get serialized string of fields in call extn that determines if we can use an existing hot container slot or pull a new image and start a container

HandleFindRunnersFailure is a convenience function to record error from runnerpool.Runners()

IsDone is a non-blocking check to see if the underlying deadlines are exceeded.

is this request possible to meet? If no, fail quick

LimitRequestBody wraps every http request to limit its size to the specified max bytes.