MCPcopy Create free account

hub / github.com/fnproject/fn / functions

Functions2,053 in github.com/fnproject/fn

↓ 1 callersFunctionPureRunnerWithSSL
(tlsCfg *tls.Config)
api/agent/pure_runner.go:874
↓ 1 callersFunctionPureRunnerWithStatusImage
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 callersFunctionPureRunnerWithStatusNetworkEnabler
(barrierPath string)
api/agent/pure_runner.go:881
↓ 1 callersFunctionRecordImageCleanerStats
(ctx context.Context, sample *ImageCacherStats)
api/agent/drivers/docker/docker_client.go:103
↓ 1 callersFunctionRecordInstanceId
(ctx context.Context, id string)
api/agent/drivers/docker/docker_client.go:96
↓ 1 callersFunctionRecordWaitContainerResult
(ctx context.Context, exitCode int)
api/agent/drivers/docker/docker_client.go:209
↓ 1 callersFunctionRegister
Register globally registers a data store provider
api/datastore/datastore.go:42
↓ 1 callersFunctionRegister
Register adds a container driver by name to this process
api/agent/drivers/register.go:12
↓ 1 callersFunctionRegisterAPIViews
(tagKeys []string, dist []float64)
api/server/gin_middlewares.go:104
↓ 1 callersFunctionRegisterAgentViews
RegisterAgentViews creates and registers all agent views
api/agent/stats.go:240
↓ 1 callersFunctionRegisterContainerViews
RegisterContainerViews creates and register containers views with provided tag keys
api/agent/stats.go:314
↓ 1 callersFunctionRegisterDockerViews
RegisterDockerViews creates a and registers Docker views with provided tag keys
api/agent/stats.go:286
↓ 1 callersFunctionRegisterExtension
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 callersFunctionRegisterLBAgentViews
(tagKeys []string, latencyDist []float64)
api/agent/stats.go:219
↓ 1 callersFunctionRegisterViews
RegisterViews creates and registers views with provided tag keys
api/agent/drivers/docker/docker_client.go:233
↓ 1 callersMethodRemoveEventListener
(ctx context.Context, listener chan *docker.APIEvents)
api/agent/drivers/docker/docker_client.go:47
↓ 1 callersMethodRemoveEventListener
(ctx context.Context, listener chan *docker.APIEvents)
api/agent/drivers/docker/docker_client.go:281
↓ 1 callersMethodRemoveImage
(id string, opts docker.RemoveImageOptions)
api/agent/drivers/docker/docker_client.go:41
↓ 1 callersMethodRequestBody
()
api/runnerpool/runner_pool.go:64
↓ 1 callersMethodResponseWriter
()
api/runnerpool/runner_pool.go:65
↓ 1 callersFunctionRunAppsTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:184
↓ 1 callersFunctionRunFnsTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:504
↓ 1 callersFunctionRunTriggerBySourceTests
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:1192
↓ 1 callersFunctionRunTriggersTest
(t *testing.T, dsf DataStoreFunc, rp ResourceProvider)
api/datastore/datastoretest/test.go:774
↓ 1 callersMethodServeFnInvoke
(c *gin.Context, app *models.App, fn *models.Fn)
api/server/runner_fninvoke.go:86
↓ 1 callersMethodServeHTTPTrigger
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 callersFunctionSetMachineId
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 callersFunctionSetUpAPINode
(ctx context.Context)
test/fn-system-tests/system_test.go:223
↓ 1 callersFunctionSetUpLBNode
(ctx context.Context)
test/fn-system-tests/system_test.go:240
↓ 1 callersMethodSetup
(s ExtServer)
fnext/setup.go:13
↓ 1 callersMethodSlotHashId
()
api/runnerpool/runner_pool.go:62
↓ 1 callersMethodSpanContextToRequest
(sc trace.SpanContext, req *http.Request)
api/agent/agent.go:1338
↓ 1 callersMethodStreamLogs
(runner.RunnerProtocol_StreamLogsServer)
api/agent/pure_runner.go:618
↓ 1 callersMethodString
()
api/datastore/sql/mysql/mysql.go:43
↓ 1 callersMethodString
()
api/models/annotations.go:57
↓ 1 callersMethodSupports
Supports indicates if this provider can handle a given data store.
api/datastore/datastore.go:34
↓ 1 callersMethodSupports
Supports indicates if this helper supports this driver name
api/datastore/sql/dbhelper/dbhelper.go:21
↓ 1 callersMethodTemporary
()
api/common/errors.go:10
↓ 1 callersFunctionTranslateGRPCStatusToRunnerStatus
TranslateGRPCStatusToRunnerStatus runner.RunnerStatus to runnerpool.RunnerStatus
api/agent/runner_client.go:122
↓ 1 callersMethodTryExec
(ctx context.Context, call RunnerCall)
api/runnerpool/runner_pool.go:53
↓ 1 callersMethodUDSDockerDest
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 callersMethodUDSDockerPath
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 callersMethodUnfreeze
Unfreeze a frozen container to unpause frozen processes
api/agent/drivers/driver.go:39
↓ 1 callersMethodUnmarshalText
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 callersMethodUp
(context.Context, *sqlx.Tx)
api/datastore/sql/migratex/migrate.go:54
↓ 1 callersMethodUpdate
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 callersMethodUpdate
Update applies a change to a trigger
api/models/trigger.go:202
↓ 1 callersMethodUpdate
Update adds entries from patch to a.Config and a.Annotations, and removes entries with empty values.
api/models/app.go:202
↓ 1 callersFunctionValidTriggerType
ValidTriggerType checks that a given trigger type is valid on this service
api/models/trigger.go:71
↓ 1 callersMethodValidate
()
api/models/app_wrapper.go:7
↓ 1 callersMethodValidate
Validate checks that trigger has valid data for inserting into a store
api/models/trigger.go:142
↓ 1 callersMethodValidate
()
api/models/app.go:81
↓ 1 callersMethodValidateShape
()
api/models/app.go:131
↓ 1 callersMethodValue
(key interface{})
api/common/ctx.go:63
↓ 1 callersFunctionWithAgentFromEnv
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 callersFunctionWithCallOptions
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 callersFunctionWithCallOverrider
WithCallOverrider registers register a CallOverrider to modify a Call and extensions on call construction
api/agent/agent.go:189
↓ 1 callersFunctionWithExtensions
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 callersFunctionWithExtraCtx
WithExtraCtx appends a context to the list of contexts the server will watch for cancellations / errors / signals.
api/server/server.go:467
↓ 1 callersFunctionWithFullAgent
WithFullAgent is a shorthand for WithAgent(... create a full agent here ...)
api/server/server.go:401
↓ 1 callersFunctionWithJaeger
WithJaeger maps EnvJaegerURL
api/server/server.go:686
↓ 1 callersFunctionWithLBCallOptions
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 callersFunctionWithLBCallOverrider
WithLBCallOverrider is for LB agents to register a CallOverrider to modify a Call and extensions
api/agent/lb_agent.go:75
↓ 1 callersFunctionWithRIDProvider
WithRIDProvider will generate request ids for each http request using the given generator.
api/server/server_options.go:24
↓ 1 callersFunctionWithRequestID
WithRequestID stores a request ID into the context
api/common/ctx.go:16
↓ 1 callersFunctionWithTrigger
WithTrigger adds trigger specific bits to a call. TODO consider removal, this is from a shuffle
api/agent/call.go:156
↓ 1 callersFunctionWithZipkin
WithZipkin maps EnvZipkinURL
api/server/server.go:712
↓ 1 callersMethodWithout
Without returns a new annotations object with a value excluded
api/models/annotations.go:178
↓ 1 callersMethodWorkDir
WorkDir returns the working directory to use for the task. Empty string leaves it unset.
api/agent/drivers/driver.go:178
↓ 1 callersFunctionWrap
(ds models.Datastore)
api/datastore/datastore.go:26
↓ 1 callersMethodWrapAfterCall
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 callersMethodWrapBeforeCall
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 callersMethodWrapClose
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 callersMethodWrite
(bytes []byte)
api/common/io_utils_test.go:27
↓ 1 callersMethodWrite
(b []byte)
api/agent/agent.go:771
↓ 1 callersFunctionWriteError
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 callersMethodWriteHeader
(serviceStatus int)
api/server/runner_httptrigger.go:91
↓ 1 callersMethodWriteStat
WriteStat writes a single Stat, implementation need not be thread safe.
api/agent/drivers/driver.go:135
↓ 1 callersMethodaddBusyLocked
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 callersMethodapiHandlerWrapperFn
(apiHandler fnext.APIHandler)
api/server/extension_points.go:10
↓ 1 callersFunctionapiMetricsWrap
(s *Server)
api/server/gin_middlewares.go:142
↓ 1 callersMethodapiMiddlewareWrapper
()
api/server/middleware.go:22
↓ 1 callersFunctionappIDCacheKey
(appID string)
api/agent/data_access.go:79
↓ 1 callersFunctionappNameCacheKey
(appName string)
api/agent/data_access.go:80
↓ 1 callersMethodauthImage
(ctx context.Context)
api/agent/drivers/docker/cookie.go:421
↓ 1 callersMethodawaitRealReader
()
api/common/io_utils.go:241
↓ 1 callersMethodawaitRealWriter
()
api/common/io_utils.go:168
↓ 1 callersMethodbindHandlers
(ctx context.Context)
api/server/server.go:956
↓ 1 callersFunctionbuildConfig
(app *models.App, fn *models.Fn)
api/agent/call.go:87
↓ 1 callersFunctionbuildFilterAppQuery
(filter *models.AppFilter)
api/datastore/sql/sql.go:705
↓ 1 callersFunctionbuildFilterFnQuery
(filter *models.FnFilter)
api/datastore/sql/sql.go:730
↓ 1 callersFunctionbuildFilterTriggerQuery
(filter *models.TriggerFilter)
api/datastore/sql/sql.go:957
↓ 1 callersMethodcheckAndIncrCalls
()
api/agent/lb_agent_test.go:54
↓ 1 callersFunctioncheckCgroupCPU
()
api/agent/resource.go:429
↓ 1 callersFunctioncheckCgroupMem
()
api/agent/resource.go:421
↓ 1 callersMethodcheckLaunch
(ctx context.Context, call *call, caller slotCaller)
api/agent/agent.go:458
↓ 1 callersFunctioncheckProcCPU
()
api/agent/resource.go:500
↓ 1 callersFunctioncheckProcMem
()
api/agent/resource.go:461
↓ 1 callersMethodcheckStatusCall
(ctx context.Context)
api/agent/runner_status.go:291
↓ 1 callersFunctioncherryPick
(ds *docker.Stats)
api/agent/drivers/docker/docker.go:548
← previousnext →601–700 of 2,053, ranked by callers