MCPcopy Create free account

hub / github.com/baidu/EasyFaaS / functions

Functions1,662 in github.com/baidu/EasyFaaS

↓ 8 callersMethodStepDone
(stage metricStage)
pkg/controller/metric.go:382
↓ 8 callersMethodSync
(rs *Resource)
pkg/api/funclet.go:101
↓ 8 callersFunctionUnmarshal
Unmarshal unmarshals the given data If v is a *map[string]interface{}, numbers are converted to int64 or float64
pkg/util/json/json.go:53
↓ 8 callersMethodcommand
(args ...string)
pkg/funclet/runtime/runc/runc.go:57
↓ 8 callersFunctionfindAndMarkRuntimeMap
(b *testing.B, args *benchmarkRuntimeArgs)
pkg/controller/rtctrl/runtime_dispatcher_test.go:283
↓ 7 callersMethodAddCondition
(key, value string)
pkg/rest/criteria.go:25
↓ 7 callersMethodBaseURL
(baseURL *url.URL)
pkg/rest/request.go:205
↓ 7 callersMethodDo
(ctx *InvokeContext)
pkg/controller/invoke.go:40
↓ 7 callersMethodGetPaths
(id string)
pkg/funclet/file/path_manager.go:29
↓ 7 callersMethodName
Name returns the name of the subsystem.
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:254
↓ 7 callersFunctionNewRuntimeInfo
(params *NewRuntimeParameters)
pkg/controller/rtctrl/runtimeinfo.go:26
↓ 7 callersMethodPost
()
pkg/rest/client.go:32
↓ 7 callersMethodScrapStage
(stage metricStage)
pkg/controller/metric.go:348
↓ 7 callersMethodTimeout
Timeout makes the request use the given duration as a timeout. Sets the "timeout" parameter.
pkg/rest/request.go:191
↓ 7 callersMethodWriteHeader
(stateCode int)
pkg/util/httptest/response.go:51
↓ 7 callersMethodWriteStdLog
(from int, buf []byte, eof bool)
pkg/controller/rtctrl/logstore.go:38
↓ 7 callersMethodadaptName
adaptName converts a CgroupName identifier to a driver specific conversion value. if outputToCgroupFs is true, the result is returned in the cgroupfs
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:68
↓ 7 callersMethodsetFlagLocked
(flag bits)
pkg/controller/rtctrl/logstore.go:350
↓ 6 callersFunctionByteSize
ByteSize returns a human-readable byte string of the form 10M, 12.5K, and so forth. The following units are available: T: Terabyte G: Gigabyte M:
pkg/util/bytefmt/bytes.go:51
↓ 6 callersFunctionCacheKey
(cacheType CacheType, key string)
pkg/controller/function/cache.go:38
↓ 6 callersMethodContainerInfo
(ID string)
pkg/funclet/runtime/api/container.go:35
↓ 6 callersMethodExists
Exists checks if the cgroup already exists
pkg/funclet/runtime/cgroup/types.go:83
↓ 6 callersMethodHas
Has returns true if and only if item is contained in the set.
pkg/funclet/runtime/cgroup/string.go:63
↓ 6 callersFunctionInitFlags
InitFlags normalizes, parses, then logs the command line flags
pkg/util/flag/flags.go:48
↓ 6 callersMethodInsert
Insert adds items to the set.
pkg/funclet/runtime/cgroup/string.go:49
↓ 6 callersMethodMode
()
pkg/util/zip/streamSingleZip.go:45
↓ 6 callersFunctionNewDispatchServerV2
(c *DispatcherV2Options, rtMap RuntimeDispatcher)
pkg/controller/rtctrl/dispatcherv2.go:40
↓ 6 callersFunctionNewRegistry
(o *Options)
pkg/controller/registry/registry.go:42
↓ 6 callersFunctionNewResource
()
pkg/api/funclet.go:77
↓ 6 callersMethodNotify
()
pkg/controller/rtctrl/request.go:200
↓ 6 callersFunctionRegister
(name string, factory AuthFactory)
pkg/auth/factory/factory.go:31
↓ 6 callersMethodResourceStatistics
()
pkg/controller/rtctrl/runtime_dispatcher.go:53
↓ 6 callersMethodSetCommitID
(cm string)
pkg/controller/rtctrl/runtimeinfo.go:78
↓ 6 callersMethodSetLabel
(k, v string)
pkg/controller/metric.go:360
↓ 6 callersFunctionToBytes
ToBytes parses a string formatted by ByteSize as bytes.
pkg/util/bytefmt/bytes.go:90
↓ 6 callersFunctiongetTmpSock
()
pkg/controller/rtctrl/dispatcherv2_test.go:38
↓ 6 callersFunctionparseInfoFile
(r io.Reader)
pkg/util/mount/mountinfo_linux.go:59
↓ 6 callersMethodrefreshMuxLocked
refreshMuxLocked creates a new mux and must be called while locked. Otherwise the view of handlers may not be consistent
pkg/server/mux/pathrecorder.go:114
↓ 6 callersFunctionsetupHijackConn
(w http.ResponseWriter, r *http.Request)
pkg/controller/rtctrl/dispatcherv2.go:93
↓ 5 callersMethodAddCallerSkip
(n int)
pkg/util/logs/logs.go:437
↓ 5 callersMethodAddFlags
(prefix string, fs *pflag.FlagSet)
pkg/controller/registry/options.go:66
↓ 5 callersMethodCode
()
pkg/util/httptest/response.go:75
↓ 5 callersMethodDebug
Debug is equivalent to the global Debug function, guarded by the value of v. See the documentation of V for usage.
pkg/util/logs/logs.go:361
↓ 5 callersMethodError
()
pkg/funclet/errors.go:47
↓ 5 callersMethodError
()
pkg/controller/rtctrl/errors.go:40
↓ 5 callersFunctionFatalf
(template string, args ...interface{})
pkg/util/logs/logs.go:486
↓ 5 callersFunctionGetNormalizedString
(s string, skipSlash bool)
pkg/auth/bce/helper.go:42
↓ 5 callersMethodGetSignature
(*rest.Request)
pkg/auth/auth.go:25
↓ 5 callersMethodHas
Has returns true if and only if item is contained in the set.
pkg/funclet/runtime/cgroup/utils.go:65
↓ 5 callersMethodHeaders
()
pkg/api/controller.go:83
↓ 5 callersMethodKill
(id string, signal string, all bool)
pkg/funclet/runtime/runc/runc.go:43
↓ 5 callersMethodListenAndServe
()
pkg/controller/rtctrl/dispatcherv2.go:66
↓ 5 callersMethodLockContainer
(id string, event api.Event, ctx *funcletCtx.Context)
pkg/funclet/container.go:44
↓ 5 callersMethodMemUsed
()
pkg/controller/rtctrl/logstore.go:43
↓ 5 callersMethodName
()
pkg/server/healthz/healthz.go:31
↓ 5 callersFunctionNewDecoder
NewDecoder delegates to json.NewDecoder It is only here so this package can be a drop-in for common encoding/json uses
pkg/util/json/json.go:41
↓ 5 callersFunctionNewInvokeProxyRequest
(headers map[string]string, body []byte, bodyStream io.ReadWriter)
pkg/api/controller.go:138
↓ 5 callersFunctionNewInvokeProxyResponse
()
pkg/api/controller.go:155
↓ 5 callersFunctionNewOption
()
pkg/controller/registry/options.go:43
↓ 5 callersFunctionNewRequest
NewRequest creates a new request helper object for accessing runtime.Objects on a server. TODO: add client-side throttle & backoff like k8s TODO: more
pkg/rest/request.go:113
↓ 5 callersFunctionParse
Parse parses an BRN into its constituent parts. Some example BRNs: brn:cloud:elasticbeanstalk:us-east-1:123456789012:environment/My App/MyEnvironment
pkg/brn/brn.go:79
↓ 5 callersMethodRequest
()
pkg/server/context.go:63
↓ 5 callersMethodSetContainer
(container *api.ContainerInfo)
pkg/funclet/context/context.go:32
↓ 5 callersMethodStart
(id string)
pkg/funclet/runtime/runc/runc.go:37
↓ 5 callersMethodUnLockContainerWithLog
(id string, ctx *funcletCtx.Context)
pkg/funclet/container.go:74
↓ 5 callersMethodUnlistedHandleFunc
UnlistedHandleFunc registers the handler function for the given pattern, but doesn't list it. If a handler already exists for pattern, Handle panics.
pkg/server/mux/pathrecorder.go:199
↓ 5 callersMethodValue
()
pkg/rest/criteria.go:26
↓ 5 callersMethodVerb
Verb begins a request with a verb (GET, POST, PUT, DELETE). Example usage of RESTClient's request building interface: c, err := rest.NewRESTClient(..
pkg/rest/client.go:90
↓ 5 callersFunctionWarnf
(template string, args ...interface{})
pkg/util/logs/logs.go:462
↓ 5 callersMethodbuildCgroupPaths
buildCgroupPaths builds a path to each cgroup subsystem for the specified name.
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:130
↓ 5 callersFunctiongetFlagName
(prefix, flagName string)
pkg/controller/registry/options.go:74
↓ 5 callersMethodloadRequest
(requestID string)
pkg/controller/rtctrl/runtime.go:291
↓ 5 callersFunctionnewLogStatStore
func newLogStatStore(requestID, runtimeID, userID, funcName, funcVer, fpath, logtype string) LogStatStore {
pkg/controller/rtctrl/logstore.go:152
↓ 5 callersFunctionreadFile
(dir, file string)
pkg/funclet/runtime/cgroup/freezer.go:38
↓ 5 callersMethodupdateStreamMode
updateStreamMode: update runtime stream mode
pkg/controller/rtctrl/runtimeinfo.go:141
↓ 4 callersMethodAdd
Add adds delta, which may be negative, similar to sync.WaitGroup. If Add with a positive delta happens after Wait, it will return error, which prevent
pkg/util/waitgroup/waitgroup.go:36
↓ 4 callersMethodContainerResourceStats
ContainerResourceStats
pkg/funclet/runtime/resource.go:52
↓ 4 callersFunctionError
(msg string, fields ...zap.Field)
pkg/util/logs/logs.go:466
↓ 4 callersMethodError
()
pkg/controller/rtctrl/errors.go:31
↓ 4 callersMethodError
()
pkg/auth/errors.go:27
↓ 4 callersMethodExist
(id string)
pkg/funclet/container.go:97
↓ 4 callersFunctionFlushLogs
()
pkg/util/logs/logs.go:444
↓ 4 callersMethodGetFunction
(input *api.GetFunctionInput)
pkg/controller/registry/registry.go:37
↓ 4 callersFunctionGetVersionAndAlias
(qualifier string)
pkg/brn/function.go:176
↓ 4 callersMethodHandle
(pattern string, handler http.Handler)
pkg/server/healthz/healthz.go:84
↓ 4 callersMethodHeader
Header returns HTTP Header
pkg/rest/request.go:591
↓ 4 callersFunctionInitLogs
InitLogs need to be called explicit in the main application
pkg/util/logs/logs.go:82
↓ 4 callersMethodInstall
Install registers the APIServer's `/version` handler.
pkg/server/routes/version.go:33
↓ 4 callersFunctionInstallHandler
InstallHandler registers handlers for health checking on the path "/healthz" to mux. *All handlers* for mux must be specified in exactly one call to I
pkg/server/healthz/healthz.go:68
↓ 4 callersMethodInvokeDone
(request *RequestInfo, signal bool)
pkg/controller/rtctrl/runtime.go:316
↓ 4 callersMethodList
()
pkg/funclet/runtime/runc/runc.go:42
↓ 4 callersFunctionListenerFromAddress
(addr string, fileMode os.FileMode)
pkg/controller/rtctrl/listener.go:56
↓ 4 callersFunctionMd5BceUid
(uid string)
pkg/brn/brn.go:122
↓ 4 callersMethodNewContext
(requestID string, logger *logs.Logger)
pkg/funclet/handler.go:35
↓ 4 callersFunctionNewDataStorer
NewDataStorer create a apiserver client
pkg/controller/function/function_server.go:40
↓ 4 callersFunctionNewInt
New creates a Int from a list of values.
pkg/funclet/runtime/cgroup/utils.go:32
↓ 4 callersFunctionNewInvokeMetrics
(reqID string)
pkg/controller/metric.go:304
↓ 4 callersFunctionNewOptions
()
cmd/controller/options/options.go:74
↓ 4 callersFunctionNewPathRecorderMux
NewPathRecorderMux creates a new PathRecorderMux
pkg/server/mux/pathrecorder.go:83
↓ 4 callersFunctionNewRequestInfo
(requestID string, runtime *RuntimeInfo)
pkg/controller/rtctrl/request.go:79
← previousnext →101–200 of 1,662, ranked by callers