Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/baidu/EasyFaaS
/ functions
Functions
1,662 in github.com/baidu/EasyFaaS
⨍
Functions
1,662
◇
Types & classes
371
↓ 2 callers
Function
getCallers
(r interface{})
pkg/util/runtime/runtime.go:69
↓ 2 callers
Function
getCgroupProcs
getCgroupProcs takes a cgroup directory name as an argument reads through the cgroup's procs file and returns a list of tgid's. It returns an empty li
pkg/funclet/runtime/cgroup/helpers_linux.go:122
↓ 2 callers
Function
getInterfaceAddr
GetInterfaceAddr returns the IPv4 address of a network interface.
pkg/funclet/network/bridge_linux.go:94
↓ 2 callers
Method
getLast
()
pkg/controller/rtctrl/log_dispatcher.go:239
↓ 2 callers
Method
getMap
(runtimeID string)
pkg/controller/rtctrl/log_dispatcher.go:295
↓ 2 callers
Function
getResourceLabels
(ID string)
pkg/controller/task.go:315
↓ 2 callers
Method
getRunnerRouteHandler
()
pkg/controller/rtctrl/dispatcherv2.go:60
↓ 2 callers
Function
helperCommand
(t *testing.T, s ...string)
pkg/funclet/command/command_test.go:53
↓ 2 callers
Method
initRunner
initRunner
pkg/controller/rtctrl/runner.go:65
↓ 2 callers
Function
initRuntime
(s *DispatchServerV2, runtimeID string, commitID string, requestID string)
pkg/controller/rtctrl/client_test.go:155
↓ 2 callers
Method
invokeHandler
(w http.ResponseWriter, r *http.Request)
pkg/controller/rtctrl/dispatcherv2.go:178
↓ 2 callers
Function
mkdirAll
(fDir, target string)
pkg/util/zip/unzip.go:79
↓ 2 callers
Function
newCacheWithJanitor
(de time.Duration, ci time.Duration, m map[string]Item)
pkg/util/cache/cache.go:1131
↓ 2 callers
Function
newFileCore
(level zap.AtomicLevel)
pkg/util/logs/logs.go:167
↓ 2 callers
Method
newManager
newManager returns an implementation of cgroups.Manager
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:53
↓ 2 callers
Method
occupyWithScaleDownRecommendation
(ctx *occupyScaleDownContext)
pkg/controller/rtctrl/runtime_dispatcher.go:314
↓ 2 callers
Function
parseBrn
(ctx *InvokeContext)
pkg/controller/invoke.go:99
↓ 2 callers
Function
parseUint
Saturates negative values at zero and returns a uint64. Due to kernel bugs, some of the memory cgroup stats can be negative.
pkg/funclet/runtime/cgroup/helpers_linux.go:150
↓ 2 callers
Method
prepareUserCode
(ctx *funcletCtx.Context, code *api.CodeStorage, codeSha256, hexCodeSha256 string)
pkg/funclet/warmup.go:181
↓ 2 callers
Method
recvGenericResponseLoop
()
pkg/controller/rtctrl/runtime.go:237
↓ 2 callers
Method
recvHTTPResponseLoop
()
pkg/controller/rtctrl/runtime.go:274
↓ 2 callers
Method
removeFromFile
(path string)
pkg/funclet/quota/xfs_quota.go:303
↓ 2 callers
Method
removeProjectInfo
(path string)
pkg/funclet/quota/xfs_quota.go:260
↓ 2 callers
Method
rollbackRuntime
(runtime *RuntimeInfo, commitID string, logger *logs.Logger)
pkg/controller/rtctrl/runtime_dispatcher.go:365
↓ 2 callers
Method
runnerExample
()
pkg/funclet/runner/manager.go:54
↓ 2 callers
Method
serve
(address string, router *mux.Router)
pkg/controller/rtctrl/dispatcherv2.go:71
↓ 2 callers
Method
startRuntimeLoop
startRuntimeLoop
pkg/controller/rtctrl/runtime.go:99
↓ 2 callers
Function
statisticsInfo
(request *RequestInfo)
pkg/controller/rtctrl/statistics.go:55
↓ 2 callers
Method
stopRuntime
stopRuntime
pkg/controller/rtctrl/runtime.go:355
↓ 2 callers
Method
syncExistsProjects
()
pkg/funclet/quota/xfs_quota.go:182
↓ 2 callers
Function
testFillAndSerialize
(t *testing.T, tc *Cache)
pkg/util/cache/cache_test.go:1275
↓ 2 callers
Method
timeout
(error)
pkg/server/filters/timeout.go:99
↓ 2 callers
Method
toResources
(resourceConfig *runtimeApi.ResourceConfig)
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:290
↓ 2 callers
Function
triFromBool
(b bool)
pkg/util/flag/tristate.go:77
↓ 2 callers
Function
unzip
(reader *zip.ReadCloser, target string)
pkg/util/zip/unzip.go:50
↓ 2 callers
Method
updateLastResetTime
updateLastResetTime
pkg/controller/rtctrl/runtimeinfo.go:126
↓ 1 callers
Method
AddFlags
(fs *pflag.FlagSet)
pkg/controller/rtctrl/options.go:44
↓ 1 callers
Method
AddFlags
(fs *pflag.FlagSet)
pkg/controller/rtctrl/options.go:66
↓ 1 callers
Method
AddFlags
(fs *pflag.FlagSet)
cmd/stubs/options/options.go:33
↓ 1 callers
Method
AddFlags
(fs *pflag.FlagSet)
cmd/httptrigger/options/options.go:37
↓ 1 callers
Method
AddFuncletClientFlags
AddFunctionCacheFlags xxx
pkg/funclet/client/client.go:51
↓ 1 callers
Method
AddHealthzChecks
AddHealthzChecks allows you to add a HealthzCheck.
pkg/server/healthz.go:26
↓ 1 callers
Method
AddPostStartHook
AddPostStartHook allows you to add a PostStartHook.
pkg/server/hooks.go:65
↓ 1 callers
Method
AddPreShutdownHook
AddPreShutdownHook allows you to add a PreShutdownHook.
pkg/server/hooks.go:100
↓ 1 callers
Method
AddUniversalFlags
AddUniversalFlags parse the flags
pkg/server/options/server_run_options.go:48
↓ 1 callers
Function
AddWithLabels
(index string, value float64, labels *prometheus.Labels)
pkg/util/logs/metric/metric.go:152
↓ 1 callers
Function
AggregateGoroutines
AggregateGoroutines runs the provided functions in parallel, stuffing all non-nil errors into the returned Aggregate. Returns nil if all the functions
pkg/util/errors/errors.go:186
↓ 1 callers
Method
AllocTmpDevice
(path string)
pkg/funclet/quota/quota.go:21
↓ 1 callers
Method
Allocate
(fpath string, size uint64)
pkg/funclet/storage/storage.go:27
↓ 1 callers
Function
AppendHostsFile
(path, containerID string)
pkg/funclet/runner/helper.go:67
↓ 1 callers
Method
ApplyTo
(c *server.Config)
pkg/server/options/features.go:62
↓ 1 callers
Function
Attach
Attach attaches backingFile to the loopback device starting at offset. If ro is true, then the file is attached read only.
pkg/funclet/device/loop/loop_unsupported.go:49
↓ 1 callers
Method
BindContainer
(gatewayIP string, addr *net.IPNet)
pkg/funclet/network/veth_linux.go:55
↓ 1 callers
Method
BodyStream
()
pkg/api/controller.go:66
↓ 1 callers
Method
BodyString
()
pkg/api/controller.go:70
↓ 1 callers
Function
BuildContext
(c *routing.Context)
pkg/httptrigger/context.go:26
↓ 1 callers
Method
CalculateBackoff
(url *url.URL)
pkg/rest/urlbackoff.go:33
↓ 1 callers
Method
Check
(req *http.Request)
pkg/server/healthz/healthz.go:32
↓ 1 callers
Method
CheckCode
(ctx *context.Context, filename, codeSha256 string)
pkg/funclet/code/manager.go:37
↓ 1 callers
Method
CleanInput
()
pkg/controller/rtctrl/request.go:105
↓ 1 callers
Method
Close
()
pkg/userlog/json/jsonlogfile.go:86
↓ 1 callers
Method
CloseChan
CloseChan
pkg/funclet/types.go:90
↓ 1 callers
Function
ConvertHTTPResponseToProxy
(rsp *http.Response, reqInfo *RequestInfo)
pkg/controller/rtctrl/httprequest.go:38
↓ 1 callers
Method
CoolDown
(*api.FuncletClientCoolDownInput)
pkg/funclet/client/client.go:60
↓ 1 callers
Function
CopyDir
(src string, dst string, mode os.FileMode)
pkg/funclet/helper.go:150
↓ 1 callers
Function
CopyFile
(src, dst string, mode os.FileMode)
pkg/funclet/helper.go:106
↓ 1 callers
Function
CreateAggregateFromMessageCountMap
CreateAggregateFromMessageCountMap converts MessageCountMap Aggregate
pkg/util/errors/errors.go:154
↓ 1 callers
Function
CreateBridge
(opt *NetworkOption)
pkg/funclet/network/bridge_linux.go:32
↓ 1 callers
Method
CreateCodeCompeleteTag
(path, codeSha256 string)
pkg/funclet/code/manager.go:39
↓ 1 callers
Function
CreateFile
(fileName string, size int64)
pkg/util/file/file.go:24
↓ 1 callers
Function
CreateFunctionHandler
(options *options.StubsOptions)
pkg/stubs/apiserver.go:60
↓ 1 callers
Function
CreateListener
(network, addr string)
pkg/server/options/serving.go:109
↓ 1 callers
Function
CreateLogWriter
(logtype string, fpath string, cap int)
pkg/userlog/factory.go:33
↓ 1 callers
Function
CreateUnixServerChain
(runOptions *options.FuncletOptions, stopCh <-chan struct{}, finishCh chan struct{})
cmd/funclet/app/server.go:44
↓ 1 callers
Method
DecrementFloat32
Decrement an item of type float32 by n. Returns an error if the item's value is not an float32, or if it was not found. If there is no error, the decr
pkg/util/cache/cache.go:881
↓ 1 callers
Method
DecrementFloat64
Decrement an item of type float64 by n. Returns an error if the item's value is not an float64, or if it was not found. If there is no error, the decr
pkg/util/cache/cache.go:903
↓ 1 callers
Method
DecrementInt16
Decrement an item of type int16 by n. Returns an error if the item's value is not an int16, or if it was not found. If there is no error, the decremen
pkg/util/cache/cache.go:683
↓ 1 callers
Method
DecrementInt32
Decrement an item of type int32 by n. Returns an error if the item's value is not an int32, or if it was not found. If there is no error, the decremen
pkg/util/cache/cache.go:705
↓ 1 callers
Method
DecrementInt64
Decrement an item of type int64 by n. Returns an error if the item's value is not an int64, or if it was not found. If there is no error, the decremen
pkg/util/cache/cache.go:727
↓ 1 callers
Method
DecrementInt8
Decrement an item of type int8 by n. Returns an error if the item's value is not an int8, or if it was not found. If there is no error, the decremente
pkg/util/cache/cache.go:661
↓ 1 callers
Method
DecrementUint
Decrement an item of type uint by n. Returns an error if the item's value is not an uint, or if it was not found. If there is no error, the decremente
pkg/util/cache/cache.go:749
↓ 1 callers
Method
DecrementUint16
Decrement an item of type uint16 by n. Returns an error if the item's value is not an uint16, or if it was not found. If there is no error, the decrem
pkg/util/cache/cache.go:815
↓ 1 callers
Method
DecrementUint32
Decrement an item of type uint32 by n. Returns an error if the item's value is not an uint32, or if it was not found. If there is no error, the decrem
pkg/util/cache/cache.go:837
↓ 1 callers
Method
DecrementUint64
Decrement an item of type uint64 by n. Returns an error if the item's value is not an uint64, or if it was not found. If there is no error, the decrem
pkg/util/cache/cache.go:859
↓ 1 callers
Method
DecrementUint8
Decrement an item of type uint8 by n. Returns an error if the item's value is not an uint8, or if it was not found. If there is no error, the decremen
pkg/util/cache/cache.go:793
↓ 1 callers
Method
DecrementUintptr
Decrement an item of type uintptr by n. Returns an error if the item's value is not an uintptr, or if it was not found. If there is no error, the decr
pkg/util/cache/cache.go:771
↓ 1 callers
Function
Deduplication
(slice *[]string)
pkg/util/strtool/codesha.go:35
↓ 1 callers
Function
DefaultCacheExpirationConfigs
()
pkg/controller/function/cache.go:54
↓ 1 callers
Method
Delete
(id string, force bool)
pkg/funclet/runtime/runc/runc.go:40
↓ 1 callers
Method
Delete
Delete removes all items from the set.
pkg/funclet/runtime/cgroup/string.go:56
↓ 1 callers
Method
Delete
Delete removes all items from the set.
pkg/funclet/runtime/cgroup/utils.go:58
↓ 1 callers
Method
DeleteContainer
(ctx *funcletCtx.Context)
pkg/funclet/reset.go:195
↓ 1 callers
Method
Destroy
Destroy the cgroup.
pkg/funclet/runtime/cgroup/types.go:79
↓ 1 callers
Method
Detach
Detach removes the file backing the device.
pkg/funclet/device/loop/loop_linux.go:121
↓ 1 callers
Method
Do
(req *fasthttp.Request)
pkg/rest/fastclient.go:32
↓ 1 callers
Function
EraseFile
(fileName string)
pkg/util/file/file.go:44
↓ 1 callers
Method
Error
()
pkg/controller/rtctrl/errors.go:50
↓ 1 callers
Method
Fetch
(string)
pkg/repository/storagedriver.go:23
↓ 1 callers
Method
FetchCode
(ctx *context.Context, code *api.CodeStorage)
pkg/funclet/code/manager.go:36
↓ 1 callers
Method
FindCode
(path, codeSha256 string)
pkg/funclet/code/manager.go:41
← previous
next →
401–500 of 1,662, ranked by callers