MCPcopy Create free account

hub / github.com/baidu/EasyFaaS / functions

Functions1,662 in github.com/baidu/EasyFaaS

↓ 532 callersMethodErrorf
(template string, args ...interface{})
pkg/util/logs/logs.go:387
↓ 294 callersMethodError
(msg string, fields ...zap.Field)
pkg/util/logs/logs.go:381
↓ 150 callersMethodGet
()
pkg/rest/client.go:35
↓ 145 callersMethodSet
Set the cgroup represented by cgroup.
pkg/funclet/runtime/cgroup/cgroup_manage_linux.go:256
↓ 141 callersMethodInfof
Infof is equivalent to the global Infof function, guarded by the value of v. See the documentation of V for usage.
pkg/util/logs/logs.go:337
↓ 95 callersMethodLock
()
pkg/api/funclet.go:187
↓ 83 callersFunctionNew
New return a new cache with a given default expiration duration and cleanup interval. If the expiration duration is less than one (or NoExpiration), t
pkg/util/cache/cache.go:1151
↓ 72 callersMethodString
()
pkg/controller/rtctrl/logstore.go:37
↓ 69 callersMethodError
()
pkg/controller/rtctrl/errors.go:69
↓ 62 callersMethodNew
New creates a new server which logically combines the handling chain with the passed server. name is used to differentiate for logging. The handler ch
pkg/server/config.go:123
↓ 60 callersMethodClose
()
pkg/userlog/userlog.go:29
↓ 59 callersFunctionErrorf
(template string, args ...interface{})
pkg/util/logs/logs.go:470
↓ 58 callersMethodAdd
Add an item to the cache only if an item doesn't already exist for the given key, or if the existing item has expired. Returns an error otherwise.
pkg/util/cache/cache.go:110
↓ 56 callersMethodV
V is a replacement of glog.V()
pkg/util/logs/logs.go:323
↓ 55 callersFunctionV
V is a replacement of glog.V()
pkg/util/logs/logs.go:314
↓ 48 callersMethodWrite
(l *UserLog, buf []byte)
pkg/userlog/userlog.go:28
↓ 48 callersMethodWriteString
(str string)
pkg/util/httptest/response.go:59
↓ 45 callersMethodSetHeader
(key string, values ...string)
pkg/rest/request.go:170
↓ 38 callersMethodEqual
Equal returns true if and only if s1 is equal (as a set) to s2. Two sets are equal if their membership is identical. (In practice, this means same ele
pkg/funclet/runtime/cgroup/utils.go:159
↓ 37 callersMethodWithField
(k, v string)
pkg/util/logs/logs.go:406
↓ 34 callersFunctionInfof
Infof is a repalcement of glog.Infof()
pkg/util/logs/logs.go:454
↓ 33 callersFunctionStageName
(ms metricStage)
pkg/controller/metric.go:236
↓ 31 callersMethodExpired
Expired returns true if the item has expired.
pkg/util/cache/cache.go:36
↓ 30 callersMethodSetState
(s RuntimeStateType)
pkg/controller/rtctrl/runtimeinfo.go:51
↓ 24 callersMethodInfo
(*api.FuncletClientContainerInfoInput)
pkg/funclet/client/client.go:57
↓ 24 callersMethodWarnf
(template string, args ...interface{})
pkg/util/logs/logs.go:375
↓ 23 callersFunctionMarshal
Marshal delegates to json.Marshal It is only here so this package can be a drop-in for common encoding/json uses
pkg/util/json/json.go:47
↓ 23 callersFunctionNewLogger
NewLogger creates a new log.Logger
pkg/util/logs/logs.go:260
↓ 23 callersMethodSetStatusCode
(c int)
pkg/api/controller.go:104
↓ 21 callersMethodError
Error returns the error executing the request, nil if no error occurred. If the returned object is of type Status and has Status != StatusSuccess, the
pkg/rest/request.go:628
↓ 21 callersMethodGetPathByName
(t pathType, n string)
pkg/funclet/file/helper.go:44
↓ 21 callersMethodWait
()
pkg/controller/rtctrl/logstore.go:46
↓ 20 callersMethodCAS
CAS check and set runtime info
pkg/controller/rtctrl/event.go:292
↓ 19 callersMethodClose
()
pkg/controller/rtctrl/logstore.go:45
↓ 18 callersMethodBytes
()
pkg/controller/rtctrl/logstore_test.go:211
↓ 18 callersMethodError
Error is part of the error interface.
pkg/util/errors/errors.go:62
↓ 18 callersFunctionRunWithLog
(fn func(), des string)
pkg/funclet/quota/xfs_quota.go:350
↓ 18 callersFunctionStageName
(stage rtCtrlInvokeStage)
pkg/controller/rtctrl/metrics.go:132
↓ 17 callersMethodDone
Done decrements the WaitGroup counter.
pkg/util/waitgroup/waitgroup.go:47
↓ 17 callersMethodHas
(f bits)
pkg/controller/rtctrl/logstore.go:61
↓ 17 callersMethodTimeTrack
(start time.Time, thumbnail string, fields ...zap.Field)
pkg/util/logs/logs.go:420
↓ 16 callersMethodBody
Body makes the request use obj as the body. Optional. If obj is a string, try to read a file of that name. If obj is a []byte, send it directly. If ob
pkg/rest/request.go:251
↓ 16 callersMethodErrors
()
pkg/util/errors/errors.go:31
↓ 16 callersFunctionRuntimeMetricName
(m metricRuntime)
pkg/controller/metric.go:267
↓ 16 callersMethodStepDone
(state rtCtrlInvokeStage)
pkg/controller/rtctrl/request.go:207
↓ 15 callersMethodCopy
()
pkg/api/funclet.go:91
↓ 15 callersFunctionDebugf
(template string, args ...interface{})
pkg/util/logs/logs.go:478
↓ 15 callersMethodIncrement
Increment an item of type int, int8, int16, int32, int64, uintptr, uint, uint8, uint32, or uint64, float32 or float64 by n. Returns an error if the it
pkg/util/cache/cache.go:205
↓ 15 callersMethodSleep
(d time.Duration)
pkg/rest/urlbackoff.go:34
↓ 15 callersMethodWriteTo
WriteTo xxx
pkg/error/error.go:169
↓ 15 callersFunctioninitRuntimeList
(num int)
pkg/controller/rtctrl/runtime_dispatcher_test.go:56
↓ 14 callersFunctionCheck
Check if need to print log
pkg/util/logs/logs.go:331
↓ 14 callersMethodCreate
(c *CreateOpts)
pkg/funclet/runtime/runc/runc.go:35
↓ 14 callersMethodDecrement
Decrement an item of type int, int8, int16, int32, int64, uintptr, uint, uint8, uint32, or uint64, float32 or float64 by n. Returns an error if the it
pkg/util/cache/cache.go:565
↓ 14 callersMethodFatalf
(template string, args ...interface{})
pkg/util/logs/logs.go:393
↓ 14 callersFunctionGetRequestID
()
pkg/util/id/id.go:21
↓ 14 callersMethodLoad
Add (Gob-serialized) cache items from an io.Reader, excluding any items with keys that already exist (and haven't expired) in the current cache. NOTE
pkg/util/cache/cache.go:1020
↓ 14 callersMethodWriteByte
(t byte)
pkg/controller/rtctrl/logstore_test.go:207
↓ 13 callersMethodDecode
Decode attempts to deserialize the provided data using either the innate typing of the scheme or the default kind, group, and version provided. It ret
pkg/rest/serializer.go:39
↓ 13 callersMethodGetRuntime
(string)
pkg/controller/rtctrl/runtime_dispatcher.go:37
↓ 13 callersMethodParam
Param creates a query parameter with the given string value.
pkg/rest/request.go:322
↓ 12 callersFunctionErrResponse
(c *routing.Context, code int, err error)
pkg/stubs/apiserver.go:165
↓ 12 callersFunctionNewGenericException
NewGenericException xxx
pkg/error/error.go:254
↓ 12 callersMethodURL
URL returns the current working URL.
pkg/rest/request.go:292
↓ 11 callersMethodDebugf
Debugf is equivalent to the global Debugf function, guarded by the value of v. See the documentation of V for usage.
pkg/util/logs/logs.go:353
↓ 11 callersMethodError
()
pkg/funclet/runtime/error/error.go:43
↓ 11 callersFunctionNewAggregate
NewAggregate converts a slice of errors into an Aggregate interface, which is itself an implementation of the error interface. If the slice is empty,
pkg/util/errors/errors.go:39
↓ 11 callersMethodRuntimeList
runtime
pkg/controller/rtctrl/runtime_dispatcher.go:36
↓ 11 callersMethodStepStart
(stage metricStage)
pkg/controller/metric.go:370
↓ 10 callersMethodEncode
Encode writes an object to a stream. Implementations may return errors if the versions are incompatible, or if no conversion is defined.
pkg/rest/serializer.go:27
↓ 10 callersMethodInto
Into stores the result into obj, if possible. If obj is nil it is ignored. If the returned object is of type Status and has .Status != StatusSuccess,
pkg/rest/request.go:609
↓ 10 callersMethodInvalidate
()
pkg/controller/rtctrl/runtimeinfo.go:106
↓ 10 callersMethodLogger
()
pkg/server/context.go:75
↓ 10 callersMethodNewRuntime
(params *NewRuntimeParameters)
pkg/controller/rtctrl/runtime_dispatcher.go:126
↓ 10 callersFunctionNewRuntimeManager
(r *api.FuncletNodeInfo, params *RuntimeManagerParameters)
pkg/controller/rtctrl/runtime_dispatcher.go:91
↓ 10 callersMethodPath
Path returns the path to the loopback device
pkg/funclet/device/loop/loop_linux.go:42
↓ 10 callersMethodResource
Resource sets the resource to access (<resource>/[ns/<namespace>/]<name>)
pkg/rest/request.go:211
↓ 10 callersMethodRun
(c *CreateOpts)
pkg/funclet/runtime/runc/runc.go:38
↓ 10 callersMethodWithErrorLog
(e error)
pkg/server/context.go:79
↓ 10 callersFunctionffjsonWriteJSONBytesAsString
(buf *bytes.Buffer, s []byte)
pkg/userlog/userlog.go:202
↓ 9 callersMethodDo
(req *http.Request)
pkg/rest/request.go:46
↓ 9 callersMethodGetContainer
(id string)
pkg/funclet/container.go:90
↓ 9 callersMethodHandleFunc
HandleFunc registers the handler function for the given pattern. If a handler already exists for pattern, Handle panics.
pkg/server/mux/pathrecorder.go:182
↓ 9 callersMethodName
()
pkg/auth/auth.go:24
↓ 9 callersMethodRelease
Release: release the occupation of runtime
pkg/controller/rtctrl/event.go:397
↓ 9 callersMethodResponse
()
pkg/server/context.go:71
↓ 9 callersMethodSetBody
(b []byte)
pkg/api/controller.go:75
↓ 9 callersMethodWarn
Warn is equivalent to the global Warn function, guarded by the value of v. See the documentation of V for usage.
pkg/util/logs/logs.go:369
↓ 9 callersMethodWith
(fields ...zap.Field)
pkg/util/logs/logs.go:399
↓ 9 callersFunctionWrapRestRouteFunc
(h func(*Context))
pkg/server/context.go:89
↓ 9 callersFunctiongetFuncletNode
()
pkg/controller/rtctrl/runtime_dispatcher_test.go:36
↓ 8 callersMethodDelete
()
pkg/rest/client.go:36
↓ 8 callersMethodGetWithExpiration
GetWithExpiration returns an item and its expiration time from the cache. It returns the item or nil, the expiration time if one is set (if the item n
pkg/util/cache/cache.go:160
↓ 8 callersMethodInsert
Insert adds items to the set.
pkg/funclet/runtime/cgroup/utils.go:51
↓ 8 callersMethodInvokeResult
(status RequestStatus, result string)
pkg/controller/rtctrl/request.go:117
↓ 8 callersMethodIsRunnerDefunct
IsRunnerDefunct
pkg/controller/rtctrl/runtimeinfo.go:146
↓ 8 callersMethodListedPaths
ListedPaths returns the registered handler exposedPaths.
pkg/server/mux/pathrecorder.go:98
↓ 8 callersMethodOccupyColdRuntime
(*InvocationInput)
pkg/controller/rtctrl/runtime_dispatcher.go:39
↓ 8 callersMethodReplace
Set a new value for the cache key only if it already exists, and the existing item hasn't expired. Returns an error otherwise.
pkg/util/cache/cache.go:124
↓ 8 callersMethodStatusCode
StatusCode returns the HTTP status code of the request. (Only valid if no error was returned.)
pkg/rest/request.go:597
next →1–100 of 1,662, ranked by callers