MCPcopy Create free account

hub / github.com/fnproject/fn / functions

Functions2,053 in github.com/fnproject/fn

↓ 2 callersMethodMarshalTextTo
MarshalTextTo writes the Id as a string to the given buffer. an error is returned when the len(dst) != 26.
api/id/id.go:141
↓ 2 callersMethodMemory
Memory determines the max amount of RAM given to the container to use. 0 is unlimited.
api/agent/drivers/driver.go:144
↓ 2 callersMethodModel
()
api/runnerpool/runner_pool.go:67
↓ 2 callersFunctionNewClient
(u string)
api/agent/hybrid/client.go:33
↓ 2 callersFunctionNewFuncError
NewFuncError returns a FuncError
api/models/error.go:281
↓ 2 callersFunctionNewSystemTestNodePool
()
test/fn-system-tests/system_test.go:91
↓ 2 callersMethodPauseContainer
(id string, ctx context.Context)
api/agent/drivers/docker/docker_client.go:36
↓ 2 callersMethodRead
([]byte)
api/common/io_utils.go:280
↓ 2 callersFunctionRegisterRunnerViews
RegisterRunnerViews creates and registers all runner views
api/agent/stats.go:262
↓ 2 callersMethodRetryAllBackoff
RetryAllBackoff blocks until it is time to try the runner list again. Returns false if the placer should stop trying.
api/runnerpool/placer_tracker.go:116
↓ 2 callersMethodRootError
()
api/models/error.go:299
↓ 2 callersMethodScan
implements sql.Scanner
api/agent/drivers/stats/stats.go:36
↓ 2 callersFunctionSetCallType
SetCallType create a models.Call setting up the provided Call Type
api/agent/lb_agent_test.go:239
↓ 2 callersFunctionSetLogDest
(to, prefix string)
api/common/logging.go:51
↓ 2 callersFunctionSetLogFormat
(format string)
api/common/logging.go:15
↓ 2 callersFunctionSetLogLevel
(ll string)
api/common/logging.go:31
↓ 2 callersFunctionSetMachineIdHost
SetMachineIdHost is a convenience wrapper to hide bit twiddling of calling SetMachineId, it has the same constraints as SetMachineId with an addition
api/id/id.go:28
↓ 2 callersMethodSetRetryPolicy
(policy common.BackOffConfig, checker drivers.RetryErrorChecker)
api/agent/drivers/docker/image_puller.go:27
↓ 2 callersMethodStats
(opts docker.StatsOptions)
api/agent/drivers/docker/docker_client.go:42
↓ 2 callersMethodStreamLogs
Logging Interface
api/agent/grpc/runner.pb.go:1462
↓ 2 callersMethodTryRunner
TryRunner is a convenience function to TryExec a call on a runner and analyze the results.
api/runnerpool/placer_tracker.go:56
↓ 2 callersMethodUnmarshalText
UnmarshalText implements the text unmarshaller interface
api/common/time.go:113
↓ 2 callersMethodUnpauseContainer
(id string, ctx context.Context)
api/agent/drivers/docker/docker_client.go:37
↓ 2 callersFunctionUp
TODO instance must have `multiStatements` set to true ?
api/datastore/sql/migratex/migrate.go:80
↓ 2 callersMethodUpdateState
(ctx context.Context, newState ContainerStateType, call *call)
api/agent/state_trackers.go:28
↓ 2 callersMethodValidateName
()
api/models/fn.go:178
↓ 2 callersMethodValidateName
()
api/models/trigger.go:175
↓ 2 callersMethodValidateName
()
api/models/app.go:113
↓ 2 callersMethodValue
implements sql.Valuer, returning a string
api/models/config.go:31
↓ 2 callersMethodVolumes
Volumes returns an array of 2-element tuples indicating storage volume mounts. The first element is the path on the host, and the second element is th
api/agent/drivers/driver.go:140
↓ 2 callersFunctionWithContext
WithContext overrides the context on the call
api/agent/call.go:190
↓ 2 callersFunctionWithDatastore
WithDatastore allows directly setting a datastore
api/server/server.go:372
↓ 2 callersFunctionWithGRPCPort
WithGRPCPort maps EnvGRPCPort
api/server/server.go:299
↓ 2 callersFunctionWithPrometheus
WithPrometheus activates the prometheus collection and /metrics endpoint
api/server/server.go:606
↓ 2 callersMethodWrite
([]byte)
api/common/io_utils.go:287
↓ 2 callersMethodaddLRULocked
addLRULocked performs a classic LRU add operation
api/agent/drivers/docker/image_cache.go:113
↓ 2 callersMethodallocResourcesLocked
(memory uint64, cpuQuota models.MilliCPUs)
api/agent/resource.go:150
↓ 2 callersFunctionannotateFnWithBaseURL
(baseURL string, app *models.App, fn *models.Fn)
api/server/fn_annotator.go:19
↓ 2 callersFunctionannotateTriggerWithBaseURL
(baseURL string, app *models.App, t *models.Trigger)
api/server/trigger_annotator.go:18
↓ 2 callersFunctionappFieldGenerators
(t *testing.T)
api/models/app_test.go:41
↓ 2 callersFunctionappReflectType
()
api/models/app_test.go:17
↓ 2 callersFunctionaverage
(samples []Stat)
api/agent/drivers/stats/stats.go:63
↓ 2 callersFunctionchainAndServe
chainAndServe essentially makes a chain of middleware wrapped around each other, then calls ServerHTTP on the end result. then each middleware also ca
api/server/middleware.go:84
↓ 2 callersFunctioncheckExpectedHeaders
TODO need to add at least one test for our cachy cache
api/agent/agent_test.go:46
↓ 2 callersFunctioncheckLogs
(t *testing.T, tnum int, callID string, expected []string)
api/server/runner_httptrigger_test.go:46
↓ 2 callersMethodclear
clear is for tests only, be careful, it deletes all records.
api/datastore/sql/sql.go:273
↓ 2 callersFunctioncloneStrMap
(src map[string]string)
api/agent/agent.go:1496
↓ 2 callersMethodclosePipeToFn
closePipeToFn closes the pipe that feeds data to the function in agent.
api/agent/pure_runner.go:139
↓ 2 callersFunctionconfigGenerator
()
api/models/app_test.go:22
↓ 2 callersFunctiondirtyErr
(version int64)
api/datastore/sql/migratex/migrate.go:40
↓ 2 callersMethodenqueueCallErrorResponse
Used to short circuit the error path when its necessary to return a well formed error to the LB and we don't want to complete the call. Errors qeueue
api/agent/pure_runner.go:317
↓ 2 callersMethodenqueueMsgStrict
enqueueMsgStricy enqueues a message to the gRPC sender and if that fails then initiates an error case shutdown.
api/agent/pure_runner.go:212
↓ 2 callersMethodfetchStatusCall
(ctx context.Context)
api/agent/runner_status.go:263
↓ 2 callersFunctionfireAfterCallFun
(callListeners []fnext.CallListener, ctx context.Context, call *models.Call)
api/agent/listeners.go:37
↓ 2 callersFunctionfireBeforeCallFun
(callListeners []fnext.CallListener, ctx context.Context, call *models.Call)
api/agent/listeners.go:27
↓ 2 callersFunctionfnFieldGenerators
(t *testing.T)
api/models/fn_test.go:34
↓ 2 callersMethodfnInvoke
(resp http.ResponseWriter, req *http.Request, app *models.App, fn *models.Fn, trig *models.Trigger)
api/server/runner_fninvoke.go:90
↓ 2 callersFunctionfnReflectType
()
api/models/fn_test.go:12
↓ 2 callersFunctiongenerateAdvisoryLockId
inspired by rails migrations, see https://goo.gl/8o9bCT NOTE that this means if the db server has multiple databases that use this library then this c
api/datastore/sql/migratex/migrate.go:217
↓ 2 callersFunctiongetChunk
(size int)
images/fn-test-utils/fn-test-utils.go:380
↓ 2 callersFunctiongetDefaultCfg
()
api/agent/drivers/docker/docker_pool_test.go:12
↓ 2 callersFunctiongetFakeDocker
(t *testing.T)
api/agent/agent_repo_test.go:12
↓ 2 callersFunctiongetSlotQueueKey
TODO do better; once we have app+fn versions this function can be simply app+fn ids & version
api/agent/slots.go:302
↓ 2 callersMethodgetStats
()
api/agent/slots.go:183
↓ 2 callersFunctiongetTrackerTestVals
(tr *resourceTracker, vals *trackerVals)
api/agent/resource_test.go:22
↓ 2 callersMethodisEligible
()
api/agent/evictor.go:79
↓ 2 callersMethodisEmptyValue
()
api/models/annotations.go:65
↓ 2 callersMethodisIdle
isIdle() returns true is there's no activity for this slot queue. This means no one is waiting, running or starting.
api/agent/slots.go:165
↓ 2 callersFunctionisPidMatchCmd
(cmdName string, pid int)
api/server/server.go:790
↓ 2 callersFunctionlookupRegistryConfig
(reg string, configs map[string]driverAuthConfig)
api/agent/drivers/docker/registry.go:95
↓ 2 callersFunctionmigrate
(ctx context.Context, tx *sqlx.Tx, migs []Migration, up bool)
api/datastore/sql/migratex/migrate.go:88
↓ 2 callersFunctionmultiError
(errs ...error)
api/datastore/sql/migratex/migrate.go:155
↓ 2 callersFunctionmustParseMd
(t *testing.T, md string)
api/models/annotations_test.go:31
↓ 2 callersFunctionnewDirectoryIOFS
(ctx context.Context, cfg *Config)
api/agent/iofs.go:55
↓ 2 callersFunctionnewID
(ms, machineID uint64, count uint32)
api/id/id.go:62
↓ 2 callersFunctionnewLineWriterWithBuffer
(b *bytes.Buffer, w io.WriteCloser)
api/agent/func_logger.go:134
↓ 2 callersMethodnewMiddlewareController
(c *gin.Context)
api/server/middleware.go:67
↓ 2 callersFunctionpreprocessAuths
(auths *docker.AuthConfigurations)
api/agent/drivers/docker/registry.go:33
↓ 2 callersMethodrmLRULocked
addLRULocked performs a classic LRU remove operation
api/agent/drivers/docker/image_cache.go:124
↓ 2 callersMethodrun
(t *testing.T, i int, buf *bytes.Buffer)
api/server/fns_test.go:28
↓ 2 callersFunctionrunImageCleaner
runImageCleaner runs continuously and monitors image cache state. If the cache is over the high water mark limit, then it tries to remove least recent
api/agent/drivers/docker/docker.go:273
↓ 2 callersMethodrunMiddleware
This is basically a single gin middleware that runs a bunch of fn middleware. The final handler will pass it back to gin for further processing.
api/server/middleware.go:38
↓ 2 callersFunctionsetupCtx
(c *call)
api/agent/call.go:273
↓ 2 callersFunctionsetupStaticPool
(runners []string)
api/agent/static_pool_test.go:10
↓ 2 callersMethodstartDequeuer
(ctx context.Context)
api/agent/slots.go:106
↓ 2 callersFunctionstatsCalls
(ctx context.Context)
api/agent/stats.go:34
↓ 2 callersFunctionstatsCanceled
(ctx context.Context)
api/agent/stats.go:58
↓ 2 callersFunctionstatsComplete
(ctx context.Context)
api/agent/stats.go:54
↓ 2 callersFunctionstatsEnqueue
(ctx context.Context)
api/agent/stats.go:38
↓ 2 callersFunctionstatsErrors
(ctx context.Context)
api/agent/stats.go:66
↓ 2 callersFunctionstatsStartRun
(ctx context.Context)
api/agent/stats.go:46
↓ 2 callersFunctionstatsStopRun
(ctx context.Context)
api/agent/stats.go:50
↓ 2 callersFunctionstatsTimedout
(ctx context.Context)
api/agent/stats.go:62
↓ 2 callersMethodstatusV2
(ctx context.Context, req json.RawMessage)
api/agent/runner_status.go:81
↓ 2 callersFunctionsyncImageCleaner
syncImageCleaner lists the current images on the system and adds them to the image cache. The operation is performed once during startup to ensure a r
api/agent/drivers/docker/docker.go:216
↓ 2 callersFunctiontriggerFieldGenerators
(t *testing.T)
api/models/trigger_test.go:76
↓ 2 callersFunctiontriggerReflectType
()
api/models/trigger_test.go:71
↓ 2 callersFunctionvalidateField
(key string, value annotationValue)
api/models/annotations.go:86
↓ 1 callersMethodAddAPIMiddlewareFunc
AddAPIMiddlewareFunc add middlewarefunc
api/server/middleware.go:110
↓ 1 callersMethodAddEndpoint
AddEndpoint adds an endpoint to /v2/x
api/server/extension_points.go:17
← previousnext →401–500 of 2,053, ranked by callers