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
↓ 2 callers
Method
MarshalTextTo
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 callers
Method
Memory
Memory determines the max amount of RAM given to the container to use. 0 is unlimited.
api/agent/drivers/driver.go:144
↓ 2 callers
Method
Model
()
api/runnerpool/runner_pool.go:67
↓ 2 callers
Function
NewClient
(u string)
api/agent/hybrid/client.go:33
↓ 2 callers
Function
NewFuncError
NewFuncError returns a FuncError
api/models/error.go:281
↓ 2 callers
Function
NewSystemTestNodePool
()
test/fn-system-tests/system_test.go:91
↓ 2 callers
Method
PauseContainer
(id string, ctx context.Context)
api/agent/drivers/docker/docker_client.go:36
↓ 2 callers
Method
Read
([]byte)
api/common/io_utils.go:280
↓ 2 callers
Function
RegisterRunnerViews
RegisterRunnerViews creates and registers all runner views
api/agent/stats.go:262
↓ 2 callers
Method
RetryAllBackoff
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 callers
Method
RootError
()
api/models/error.go:299
↓ 2 callers
Method
Scan
implements sql.Scanner
api/agent/drivers/stats/stats.go:36
↓ 2 callers
Function
SetCallType
SetCallType create a models.Call setting up the provided Call Type
api/agent/lb_agent_test.go:239
↓ 2 callers
Function
SetLogDest
(to, prefix string)
api/common/logging.go:51
↓ 2 callers
Function
SetLogFormat
(format string)
api/common/logging.go:15
↓ 2 callers
Function
SetLogLevel
(ll string)
api/common/logging.go:31
↓ 2 callers
Function
SetMachineIdHost
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 callers
Method
SetRetryPolicy
(policy common.BackOffConfig, checker drivers.RetryErrorChecker)
api/agent/drivers/docker/image_puller.go:27
↓ 2 callers
Method
Stats
(opts docker.StatsOptions)
api/agent/drivers/docker/docker_client.go:42
↓ 2 callers
Method
StreamLogs
Logging Interface
api/agent/grpc/runner.pb.go:1462
↓ 2 callers
Method
TryRunner
TryRunner is a convenience function to TryExec a call on a runner and analyze the results.
api/runnerpool/placer_tracker.go:56
↓ 2 callers
Method
UnmarshalText
UnmarshalText implements the text unmarshaller interface
api/common/time.go:113
↓ 2 callers
Method
UnpauseContainer
(id string, ctx context.Context)
api/agent/drivers/docker/docker_client.go:37
↓ 2 callers
Function
Up
TODO instance must have `multiStatements` set to true ?
api/datastore/sql/migratex/migrate.go:80
↓ 2 callers
Method
UpdateState
(ctx context.Context, newState ContainerStateType, call *call)
api/agent/state_trackers.go:28
↓ 2 callers
Method
ValidateName
()
api/models/fn.go:178
↓ 2 callers
Method
ValidateName
()
api/models/trigger.go:175
↓ 2 callers
Method
ValidateName
()
api/models/app.go:113
↓ 2 callers
Method
Value
implements sql.Valuer, returning a string
api/models/config.go:31
↓ 2 callers
Method
Volumes
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 callers
Function
WithContext
WithContext overrides the context on the call
api/agent/call.go:190
↓ 2 callers
Function
WithDatastore
WithDatastore allows directly setting a datastore
api/server/server.go:372
↓ 2 callers
Function
WithGRPCPort
WithGRPCPort maps EnvGRPCPort
api/server/server.go:299
↓ 2 callers
Function
WithPrometheus
WithPrometheus activates the prometheus collection and /metrics endpoint
api/server/server.go:606
↓ 2 callers
Method
Write
([]byte)
api/common/io_utils.go:287
↓ 2 callers
Method
addLRULocked
addLRULocked performs a classic LRU add operation
api/agent/drivers/docker/image_cache.go:113
↓ 2 callers
Method
allocResourcesLocked
(memory uint64, cpuQuota models.MilliCPUs)
api/agent/resource.go:150
↓ 2 callers
Function
annotateFnWithBaseURL
(baseURL string, app *models.App, fn *models.Fn)
api/server/fn_annotator.go:19
↓ 2 callers
Function
annotateTriggerWithBaseURL
(baseURL string, app *models.App, t *models.Trigger)
api/server/trigger_annotator.go:18
↓ 2 callers
Function
appFieldGenerators
(t *testing.T)
api/models/app_test.go:41
↓ 2 callers
Function
appReflectType
()
api/models/app_test.go:17
↓ 2 callers
Function
average
(samples []Stat)
api/agent/drivers/stats/stats.go:63
↓ 2 callers
Function
chainAndServe
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 callers
Function
checkExpectedHeaders
TODO need to add at least one test for our cachy cache
api/agent/agent_test.go:46
↓ 2 callers
Function
checkLogs
(t *testing.T, tnum int, callID string, expected []string)
api/server/runner_httptrigger_test.go:46
↓ 2 callers
Method
clear
clear is for tests only, be careful, it deletes all records.
api/datastore/sql/sql.go:273
↓ 2 callers
Function
cloneStrMap
(src map[string]string)
api/agent/agent.go:1496
↓ 2 callers
Method
closePipeToFn
closePipeToFn closes the pipe that feeds data to the function in agent.
api/agent/pure_runner.go:139
↓ 2 callers
Function
configGenerator
()
api/models/app_test.go:22
↓ 2 callers
Function
dirtyErr
(version int64)
api/datastore/sql/migratex/migrate.go:40
↓ 2 callers
Method
enqueueCallErrorResponse
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 callers
Method
enqueueMsgStrict
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 callers
Method
fetchStatusCall
(ctx context.Context)
api/agent/runner_status.go:263
↓ 2 callers
Function
fireAfterCallFun
(callListeners []fnext.CallListener, ctx context.Context, call *models.Call)
api/agent/listeners.go:37
↓ 2 callers
Function
fireBeforeCallFun
(callListeners []fnext.CallListener, ctx context.Context, call *models.Call)
api/agent/listeners.go:27
↓ 2 callers
Function
fnFieldGenerators
(t *testing.T)
api/models/fn_test.go:34
↓ 2 callers
Method
fnInvoke
(resp http.ResponseWriter, req *http.Request, app *models.App, fn *models.Fn, trig *models.Trigger)
api/server/runner_fninvoke.go:90
↓ 2 callers
Function
fnReflectType
()
api/models/fn_test.go:12
↓ 2 callers
Function
generateAdvisoryLockId
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 callers
Function
getChunk
(size int)
images/fn-test-utils/fn-test-utils.go:380
↓ 2 callers
Function
getDefaultCfg
()
api/agent/drivers/docker/docker_pool_test.go:12
↓ 2 callers
Function
getFakeDocker
(t *testing.T)
api/agent/agent_repo_test.go:12
↓ 2 callers
Function
getSlotQueueKey
TODO do better; once we have app+fn versions this function can be simply app+fn ids & version
api/agent/slots.go:302
↓ 2 callers
Method
getStats
()
api/agent/slots.go:183
↓ 2 callers
Function
getTrackerTestVals
(tr *resourceTracker, vals *trackerVals)
api/agent/resource_test.go:22
↓ 2 callers
Method
isEligible
()
api/agent/evictor.go:79
↓ 2 callers
Method
isEmptyValue
()
api/models/annotations.go:65
↓ 2 callers
Method
isIdle
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 callers
Function
isPidMatchCmd
(cmdName string, pid int)
api/server/server.go:790
↓ 2 callers
Function
lookupRegistryConfig
(reg string, configs map[string]driverAuthConfig)
api/agent/drivers/docker/registry.go:95
↓ 2 callers
Function
migrate
(ctx context.Context, tx *sqlx.Tx, migs []Migration, up bool)
api/datastore/sql/migratex/migrate.go:88
↓ 2 callers
Function
multiError
(errs ...error)
api/datastore/sql/migratex/migrate.go:155
↓ 2 callers
Function
mustParseMd
(t *testing.T, md string)
api/models/annotations_test.go:31
↓ 2 callers
Function
newDirectoryIOFS
(ctx context.Context, cfg *Config)
api/agent/iofs.go:55
↓ 2 callers
Function
newID
(ms, machineID uint64, count uint32)
api/id/id.go:62
↓ 2 callers
Function
newLineWriterWithBuffer
(b *bytes.Buffer, w io.WriteCloser)
api/agent/func_logger.go:134
↓ 2 callers
Method
newMiddlewareController
(c *gin.Context)
api/server/middleware.go:67
↓ 2 callers
Function
preprocessAuths
(auths *docker.AuthConfigurations)
api/agent/drivers/docker/registry.go:33
↓ 2 callers
Method
rmLRULocked
addLRULocked performs a classic LRU remove operation
api/agent/drivers/docker/image_cache.go:124
↓ 2 callers
Method
run
(t *testing.T, i int, buf *bytes.Buffer)
api/server/fns_test.go:28
↓ 2 callers
Function
runImageCleaner
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 callers
Method
runMiddleware
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 callers
Function
setupCtx
(c *call)
api/agent/call.go:273
↓ 2 callers
Function
setupStaticPool
(runners []string)
api/agent/static_pool_test.go:10
↓ 2 callers
Method
startDequeuer
(ctx context.Context)
api/agent/slots.go:106
↓ 2 callers
Function
statsCalls
(ctx context.Context)
api/agent/stats.go:34
↓ 2 callers
Function
statsCanceled
(ctx context.Context)
api/agent/stats.go:58
↓ 2 callers
Function
statsComplete
(ctx context.Context)
api/agent/stats.go:54
↓ 2 callers
Function
statsEnqueue
(ctx context.Context)
api/agent/stats.go:38
↓ 2 callers
Function
statsErrors
(ctx context.Context)
api/agent/stats.go:66
↓ 2 callers
Function
statsStartRun
(ctx context.Context)
api/agent/stats.go:46
↓ 2 callers
Function
statsStopRun
(ctx context.Context)
api/agent/stats.go:50
↓ 2 callers
Function
statsTimedout
(ctx context.Context)
api/agent/stats.go:62
↓ 2 callers
Method
statusV2
(ctx context.Context, req json.RawMessage)
api/agent/runner_status.go:81
↓ 2 callers
Function
syncImageCleaner
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 callers
Function
triggerFieldGenerators
(t *testing.T)
api/models/trigger_test.go:76
↓ 2 callers
Function
triggerReflectType
()
api/models/trigger_test.go:71
↓ 2 callers
Function
validateField
(key string, value annotationValue)
api/models/annotations.go:86
↓ 1 callers
Method
AddAPIMiddlewareFunc
AddAPIMiddlewareFunc add middlewarefunc
api/server/middleware.go:110
↓ 1 callers
Method
AddEndpoint
AddEndpoint adds an endpoint to /v2/x
api/server/extension_points.go:17
← previous
next →
401–500 of 2,053, ranked by callers