Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/fnproject/fn
/ functions
Functions
2,053 in github.com/fnproject/fn
⨍
Functions
2,053
◇
Types & classes
309
↓ 1 callers
Function
PureRunnerWithSSL
(tlsCfg *tls.Config)
api/agent/pure_runner.go:874
↓ 1 callers
Function
PureRunnerWithStatusImage
PureRunnerWithStatusImage returns a PureRunnerOption that annotates a PureRunner with a statusImageName attribute. This attribute names an image name
api/agent/pure_runner.go:946
↓ 1 callers
Function
PureRunnerWithStatusNetworkEnabler
(barrierPath string)
api/agent/pure_runner.go:881
↓ 1 callers
Function
RecordImageCleanerStats
(ctx context.Context, sample *ImageCacherStats)
api/agent/drivers/docker/docker_client.go:103
↓ 1 callers
Function
RecordInstanceId
(ctx context.Context, id string)
api/agent/drivers/docker/docker_client.go:96
↓ 1 callers
Function
RecordWaitContainerResult
(ctx context.Context, exitCode int)
api/agent/drivers/docker/docker_client.go:209
↓ 1 callers
Function
Register
Register globally registers a data store provider
api/datastore/datastore.go:42
↓ 1 callers
Function
Register
Register adds a container driver by name to this process
api/agent/drivers/register.go:12
↓ 1 callers
Function
RegisterAPIViews
(tagKeys []string, dist []float64)
api/server/gin_middlewares.go:104
↓ 1 callers
Function
RegisterAgentViews
RegisterAgentViews creates and registers all agent views
api/agent/stats.go:240
↓ 1 callers
Function
RegisterContainerViews
RegisterContainerViews creates and register containers views with provided tag keys
api/agent/stats.go:314
↓ 1 callers
Function
RegisterDockerViews
RegisterDockerViews creates a and registers Docker views with provided tag keys
api/agent/stats.go:286
↓ 1 callers
Function
RegisterExtension
RegisterExtension registers the extension so it's available, but does not initialize it. This is generally what third party extensions will use in the
api/server/extensions.go:14
↓ 1 callers
Function
RegisterLBAgentViews
(tagKeys []string, latencyDist []float64)
api/agent/stats.go:219
↓ 1 callers
Function
RegisterViews
RegisterViews creates and registers views with provided tag keys
api/agent/drivers/docker/docker_client.go:233
↓ 1 callers
Method
RemoveEventListener
(ctx context.Context, listener chan *docker.APIEvents)
api/agent/drivers/docker/docker_client.go:47
↓ 1 callers
Method
RemoveEventListener
(ctx context.Context, listener chan *docker.APIEvents)
api/agent/drivers/docker/docker_client.go:281
↓ 1 callers
Method
RemoveImage
(id string, opts docker.RemoveImageOptions)
api/agent/drivers/docker/docker_client.go:41
↓ 1 callers
Method
RequestBody
()
api/runnerpool/runner_pool.go:64
↓ 1 callers
Method
ResponseWriter
()
api/runnerpool/runner_pool.go:65
↓ 1 callers
Function
RunAppsTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:184
↓ 1 callers
Function
RunFnsTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:504
↓ 1 callers
Function
RunTriggerBySourceTests
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:1192
↓ 1 callers
Function
RunTriggersTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:774
↓ 1 callers
Method
ServeFnInvoke
(c *gin.Context, app *models.App, fn *models.Fn)
api/server/runner_fninvoke.go:86
↓ 1 callers
Method
ServeHTTPTrigger
ServeHTTPTrigger serves an HTTP trigger for a given app/fn/trigger based on the current request This is exported to allow extensions to handle their o
api/server/runner_httptrigger.go:154
↓ 1 callers
Function
SetMachineId
SetMachineId may only be called by one thread before any id generation is done. It must be set if multiple machines are generating ids in order to avo
api/id/id.go:21
↓ 1 callers
Function
SetUpAPINode
(ctx context.Context)
test/fn-system-tests/system_test.go:223
↓ 1 callers
Function
SetUpLBNode
(ctx context.Context)
test/fn-system-tests/system_test.go:240
↓ 1 callers
Method
Setup
(s ExtServer)
fnext/setup.go:13
↓ 1 callers
Method
SlotHashId
()
api/runnerpool/runner_pool.go:62
↓ 1 callers
Method
SpanContextToRequest
(sc trace.SpanContext, req *http.Request)
api/agent/agent.go:1338
↓ 1 callers
Method
StreamLogs
(runner.RunnerProtocol_StreamLogsServer)
api/agent/pure_runner.go:618
↓ 1 callers
Method
String
()
api/datastore/sql/mysql/mysql.go:43
↓ 1 callers
Method
String
()
api/models/annotations.go:57
↓ 1 callers
Method
Supports
Supports indicates if this provider can handle a given data store.
api/datastore/datastore.go:34
↓ 1 callers
Method
Supports
Supports indicates if this helper supports this driver name
api/datastore/sql/dbhelper/dbhelper.go:21
↓ 1 callers
Method
Temporary
()
api/common/errors.go:10
↓ 1 callers
Function
TranslateGRPCStatusToRunnerStatus
TranslateGRPCStatusToRunnerStatus runner.RunnerStatus to runnerpool.RunnerStatus
api/agent/runner_client.go:122
↓ 1 callers
Method
TryExec
(ctx context.Context, call RunnerCall)
api/runnerpool/runner_pool.go:53
↓ 1 callers
Method
UDSDockerDest
UDSDockerDest is the destination mount point for uds path. it is the path of the directory where the sock file resides inside of the container.
api/agent/drivers/driver.go:207
↓ 1 callers
Method
UDSDockerPath
UDSDockerPath to use to configure the unix domain socket. the drivers This is the mount point relative to the docker host.
api/agent/drivers/driver.go:203
↓ 1 callers
Method
Unfreeze
Unfreeze a frozen container to unpause frozen processes
api/agent/drivers/driver.go:39
↓ 1 callers
Method
UnmarshalText
UnmarshalText implements the encoding.TextUnmarshaler interface by parsing the data as string encoded Id. an error is returned if the len(v) is diffe
api/id/id.go:240
↓ 1 callers
Method
Up
(context.Context, *sqlx.Tx)
api/datastore/sql/migratex/migrate.go:54
↓ 1 callers
Method
Update
Update updates fields in f with non-zero field values from new, and sets updated_at if any of the fields change. 0-length slice Header values, and emp
api/models/fn.go:261
↓ 1 callers
Method
Update
Update applies a change to a trigger
api/models/trigger.go:202
↓ 1 callers
Method
Update
Update adds entries from patch to a.Config and a.Annotations, and removes entries with empty values.
api/models/app.go:202
↓ 1 callers
Function
ValidTriggerType
ValidTriggerType checks that a given trigger type is valid on this service
api/models/trigger.go:71
↓ 1 callers
Method
Validate
()
api/models/app_wrapper.go:7
↓ 1 callers
Method
Validate
Validate checks that trigger has valid data for inserting into a store
api/models/trigger.go:142
↓ 1 callers
Method
Validate
()
api/models/app.go:81
↓ 1 callers
Method
ValidateShape
()
api/models/app.go:131
↓ 1 callers
Method
Value
(key interface{})
api/common/ctx.go:63
↓ 1 callers
Function
WithAgentFromEnv
WithAgentFromEnv must be provided as the last server option because it relies on all other options being set first.
api/server/server.go:411
↓ 1 callers
Function
WithCallOptions
WithCallOptions adds additional call options to each call created from GetCall, these options will be executed after any other options supplied to Get
api/agent/agent.go:201
↓ 1 callers
Function
WithCallOverrider
WithCallOverrider registers register a CallOverrider to modify a Call and extensions on call construction
api/agent/agent.go:189
↓ 1 callers
Function
WithExtensions
WithExtensions adds internal attributes to the call that can be interpreted by extensions in the agent Pure runner can use this to pass an extension t
api/agent/call.go:199
↓ 1 callers
Function
WithExtraCtx
WithExtraCtx appends a context to the list of contexts the server will watch for cancellations / errors / signals.
api/server/server.go:467
↓ 1 callers
Function
WithFullAgent
WithFullAgent is a shorthand for WithAgent(... create a full agent here ...)
api/server/server.go:401
↓ 1 callers
Function
WithJaeger
WithJaeger maps EnvJaegerURL
api/server/server.go:686
↓ 1 callers
Function
WithLBCallOptions
WithLBCallOptions adds additional call options to each call created from GetCall, these options will be executed after any other options supplied to G
api/agent/lb_agent.go:87
↓ 1 callers
Function
WithLBCallOverrider
WithLBCallOverrider is for LB agents to register a CallOverrider to modify a Call and extensions
api/agent/lb_agent.go:75
↓ 1 callers
Function
WithRIDProvider
WithRIDProvider will generate request ids for each http request using the given generator.
api/server/server_options.go:24
↓ 1 callers
Function
WithRequestID
WithRequestID stores a request ID into the context
api/common/ctx.go:16
↓ 1 callers
Function
WithTrigger
WithTrigger adds trigger specific bits to a call. TODO consider removal, this is from a shuffle
api/agent/call.go:156
↓ 1 callers
Function
WithZipkin
WithZipkin maps EnvZipkinURL
api/server/server.go:712
↓ 1 callers
Method
Without
Without returns a new annotations object with a value excluded
api/models/annotations.go:178
↓ 1 callers
Method
WorkDir
WorkDir returns the working directory to use for the task. Empty string leaves it unset.
api/agent/drivers/driver.go:178
↓ 1 callers
Function
Wrap
(ds models.Datastore)
api/datastore/datastore.go:26
↓ 1 callers
Method
WrapAfterCall
WrapBeforeCall can add additional post-call behaviour to be added. This should be called once per ContainerTask and applies to all successive calls th
api/agent/drivers/driver.go:232
↓ 1 callers
Method
WrapBeforeCall
WrapBeforeCall can add additional pre-call behaviour to be added. This should be called once per ContainerTaskand applies to all successive calls that
api/agent/drivers/driver.go:223
↓ 1 callers
Method
WrapClose
AddCloseWrapper is used to add additional cleanup to a task. The original close operation is passed to the wrapping factory. Implementation need not b
api/agent/drivers/driver.go:190
↓ 1 callers
Method
Write
(bytes []byte)
api/common/io_utils_test.go:27
↓ 1 callers
Method
Write
(b []byte)
api/agent/agent.go:771
↓ 1 callers
Function
WriteError
WriteError easy way to do standard error response, but can set statuscode and error message easier than handleErrorResponse
api/server/error_response.go:65
↓ 1 callers
Method
WriteHeader
(serviceStatus int)
api/server/runner_httptrigger.go:91
↓ 1 callers
Method
WriteStat
WriteStat writes a single Stat, implementation need not be thread safe.
api/agent/drivers/driver.go:135
↓ 1 callers
Method
addBusyLocked
addBusyLocked updates an image in the in-use list and returns true if a new insertion to in-use list was performed.
api/agent/drivers/docker/image_cache.go:135
↓ 1 callers
Method
apiHandlerWrapperFn
(apiHandler fnext.APIHandler)
api/server/extension_points.go:10
↓ 1 callers
Function
apiMetricsWrap
(s *Server)
api/server/gin_middlewares.go:142
↓ 1 callers
Method
apiMiddlewareWrapper
()
api/server/middleware.go:22
↓ 1 callers
Function
appIDCacheKey
(appID string)
api/agent/data_access.go:79
↓ 1 callers
Function
appNameCacheKey
(appName string)
api/agent/data_access.go:80
↓ 1 callers
Method
authImage
(ctx context.Context)
api/agent/drivers/docker/cookie.go:421
↓ 1 callers
Method
awaitRealReader
()
api/common/io_utils.go:241
↓ 1 callers
Method
awaitRealWriter
()
api/common/io_utils.go:168
↓ 1 callers
Method
bindHandlers
(ctx context.Context)
api/server/server.go:956
↓ 1 callers
Function
buildConfig
(app *models.App, fn *models.Fn)
api/agent/call.go:87
↓ 1 callers
Function
buildFilterAppQuery
(filter *models.AppFilter)
api/datastore/sql/sql.go:705
↓ 1 callers
Function
buildFilterFnQuery
(filter *models.FnFilter)
api/datastore/sql/sql.go:730
↓ 1 callers
Function
buildFilterTriggerQuery
(filter *models.TriggerFilter)
api/datastore/sql/sql.go:957
↓ 1 callers
Method
checkAndIncrCalls
()
api/agent/lb_agent_test.go:54
↓ 1 callers
Function
checkCgroupCPU
()
api/agent/resource.go:429
↓ 1 callers
Function
checkCgroupMem
()
api/agent/resource.go:421
↓ 1 callers
Method
checkLaunch
(ctx context.Context, call *call, caller slotCaller)
api/agent/agent.go:458
↓ 1 callers
Function
checkProcCPU
()
api/agent/resource.go:500
↓ 1 callers
Function
checkProcMem
()
api/agent/resource.go:461
↓ 1 callers
Method
checkStatusCall
(ctx context.Context)
api/agent/runner_status.go:291
↓ 1 callers
Function
cherryPick
(ds *docker.Stats)
api/agent/drivers/docker/docker.go:548
← previous
next →
601–700 of 2,053, ranked by callers