MCPcopy Create free account

hub / github.com/26597925/EastCloud / functions

Functions883 in github.com/26597925/EastCloud

⨍ Functions 883◇ Types & classes 220
↓ 1 callersMethodBool
(name string)
pkg/bootstrap/flag/flag.go:82
↓ 1 callersMethodBoolE
(name string)
pkg/bootstrap/flag/flag.go:73
↓ 1 callersMethodBootstrap
()
pkg/scheduler/server.go:43
↓ 1 callersMethodBootstrap
()
pkg/scheduler/client.go:44
↓ 1 callersMethodBuildConfig
()
pkg/client/etcdv3/options.go:34
↓ 1 callersMethodClient
(ctx context.Context, t *Token)
pkg/oauth2/client/oauth2.go:93
↓ 1 callersMethodClose
()
pkg/registry/registry.go:15
↓ 1 callersMethodConnect
()
pkg/network/tcp/client.go:22
↓ 1 callersMethodConnect
()
pkg/broker/kafka/kafka.go:26
↓ 1 callersMethodConsumeQueue
(queue string, autoAck bool)
pkg/broker/rabbitmq/channel.go:129
↓ 1 callersMethodDebugF
(format string, args ...interface{})
pkg/logger/logger.go:24
↓ 1 callersMethodDeclareDurableExchange
(exchangeType, exchange string)
pkg/broker/rabbitmq/channel.go:76
↓ 1 callersMethodDeclareDurableQueue
(queue string, args amqp.Table)
pkg/broker/rabbitmq/channel.go:105
↓ 1 callersMethodDeclareExchange
(exchangeType, exchange string)
pkg/broker/rabbitmq/channel.go:59
↓ 1 callersMethodDeclareQueue
(queue string, args amqp.Table)
pkg/broker/rabbitmq/channel.go:93
↓ 1 callersMethodDelClient
监听到client掉线后删除handler里面的客户端
pkg/scheduler/handler.go:115
↓ 1 callersMethodDeregister
(sv *registry.Service)
pkg/registry/etcd/registry.go:61
↓ 1 callersMethodDisconnect
()
pkg/broker/kafka/kafka.go:67
↓ 1 callersFunctionErrorF
(format string, args ...interface{})
pkg/logger/logger.go:66
↓ 1 callersMethodErrorF
(format string, args ...interface{})
pkg/logger/logger.go:28
↓ 1 callersFunctionExtract
Extract returns a real ip
pkg/util/addr/addr.go:63
↓ 1 callersMethodFatalF
(format string, args ...interface{})
pkg/logger/logger.go:30
↓ 1 callersMethodFindClients
(name string)
pkg/scheduler/handler.go:98
↓ 1 callersFunctionFindPid
(name string)
pkg/process/process_posix.go:22
↓ 1 callersMethodFindProc
(name string)
internal/agent/core/process.go:49
↓ 1 callersMethodFloat64
(name string)
pkg/bootstrap/flag/flag.go:138
↓ 1 callersMethodFloat64E
(name string)
pkg/bootstrap/flag/flag.go:129
↓ 1 callersFunctionFunctionName
FunctionName ...
pkg/util/stringext/function.go:9
↓ 1 callersMethodGet
Get returns atomic uint32
pkg/util/atomic/uint32.go:18
↓ 1 callersMethodGetAccessToken
(ctx context.Context, tr *TokenRequest)
pkg/oauth2/server/generates.go:77
↓ 1 callersMethodGetAuthorizeData
()
pkg/oauth2/server/token/token.go:32
↓ 1 callersMethodGetAuthorizeToken
(ctx context.Context, req *AuthorizeRequest)
pkg/oauth2/server/generates.go:49
↓ 1 callersMethodGetByAccess
(ctx context.Context, access string)
pkg/oauth2/server/stores/token.go:77
↓ 1 callersMethodGetByRefresh
(ctx context.Context, refresh string)
pkg/oauth2/server/stores/token.go:94
↓ 1 callersMethodGetCount
(ctx context.Context, prefix string)
pkg/client/etcdv3/etcd.go:92
↓ 1 callersFunctionGetDefaultTokenConfig
()
pkg/oauth2/server/options.go:64
↓ 1 callersMethodGetFirstKey
(ctx context.Context, prefix string)
pkg/client/etcdv3/etcd.go:83
↓ 1 callersFunctionGetFlag
()
cmd/hello/boot/engine/context.go:54
↓ 1 callersFunctionGetFlagSet
()
cmd/hello/boot/engine/context.go:62
↓ 1 callersMethodGetGroupName
()
pkg/server/api/server.go:24
↓ 1 callersMethodGetGrpcOptions
()
pkg/server/api/server.go:27
↓ 1 callersMethodGetJob
(id string)
pkg/scheduler/job.go:111
↓ 1 callersMethodGetJobs
()
pkg/scheduler/server.go:31
↓ 1 callersMethodGetOption
()
pkg/server/gin/server.go:54
↓ 1 callersMethodGetPrefixLimit
(ctx context.Context, key string, limit int64)
pkg/client/etcdv3/etcd.go:69
↓ 1 callersMethodGetRegion
()
pkg/server/api/server.go:22
↓ 1 callersMethodGetService
(name string)
pkg/registry/registry.go:12
↓ 1 callersMethodGetTokenByCode
(ctx context.Context, code string)
pkg/oauth2/server/stores/token.go:63
↓ 1 callersMethodGetUpdateTime
()
pkg/network/common/connection.go:167
↓ 1 callersMethodGetVersion
()
pkg/server/api/server.go:20
↓ 1 callersMethodGetZone
()
pkg/server/api/server.go:23
↓ 1 callersMethodGracefulStop
(ctx context.Context)
pkg/server/api/server.go:13
↓ 1 callersMethodHandle
(req *Request)
pkg/network/common/router.go:5
↓ 1 callersMethodHandleAuthorizeRequest
(w http.ResponseWriter, r *http.Request)
pkg/oauth2/server/oauth2.go:107
↓ 1 callersMethodHandleTokenRequest
(w http.ResponseWriter, r *http.Request)
pkg/oauth2/server/oauth2.go:163
↓ 1 callersFunctionIPs
IPs returns all known ips
pkg/util/addr/addr.go:136
↓ 1 callersFunctionIn
(arr []string, val string)
pkg/util/array/array.go:5
↓ 1 callersMethodIncr
Incr incr atomic uint32
pkg/util/atomic/uint32.go:23
↓ 1 callersFunctionInfoF
(format string, args ...interface{})
pkg/logger/logger.go:42
↓ 1 callersFunctionInit
(ctx context.Context, option *Options)
pkg/client/redis/redis.go:21
↓ 1 callersFunctionInit
(option *Options)
pkg/model/model.go:30
↓ 1 callersFunctionInit
(option *Options)
pkg/tracer/tracer.go:28
↓ 1 callersFunctionInit
(flags ...flag.Flag)
cmd/hello/boot/init.go:23
↓ 1 callersMethodIntE
(name string)
pkg/bootstrap/flag/flag.go:101
↓ 1 callersFunctionIsLocal
IsLocal tells us whether an ip is local
pkg/util/addr/addr.go:40
↓ 1 callersMethodListJob
()
pkg/scheduler/job.go:127
↓ 1 callersMethodMacAuth
id / ts / nonce / ext / mac
pkg/oauth2/server/request.go:159
↓ 1 callersFunctionMd5File
(path string)
pkg/util/crypto/crypto.go:75
↓ 1 callersFunctionMerge
(opts *Options)
pkg/logger/options.go:102
↓ 1 callersMethodMonitor
()
internal/agent/core/process.go:61
↓ 1 callersFunctionNewAuthorize
()
pkg/oauth2/server/generates/authorize.go:13
↓ 1 callersFunctionNewBaseAccess
()
pkg/oauth2/server/generates/base.go:13
↓ 1 callersFunctionNewClient
()
pkg/network/tcp/client.go:15
↓ 1 callersFunctionNewClient
()
internal/agent/client.go:20
↓ 1 callersFunctionNewEncoder
()
pkg/config/encoder/toml/toml.go:30
↓ 1 callersFunctionNewEncoder
()
pkg/config/encoder/hcl/hcl.go:23
↓ 1 callersFunctionNewEngine
(ec EngineContext)
pkg/bootstrap/boot.go:30
↓ 1 callersFunctionNewEtcd
(options *Options)
pkg/config/etcd/etcd.go:45
↓ 1 callersFunctionNewFileRouter
(manager *core.Manager)
internal/agent/router/tcpclient/fileRouter.go:16
↓ 1 callersFunctionNewManager
(savePath string)
internal/agent/core/manager.go:34
↓ 1 callersFunctionNewOptions
(opts ...Option)
pkg/client/etcdv3/options.go:25
↓ 1 callersFunctionNewProcess
(binPath string)
internal/agent/core/process.go:38
↓ 1 callersFunctionNewRegistry
(opts *registry.Options, client *etcdv3.Client)
pkg/registry/etcd/registry.go:21
↓ 1 callersFunctionNewServer
()
pkg/network/tcp/server.go:22
↓ 1 callersFunctionNewServer
(option api.Option)
pkg/server/gin/server.go:18
↓ 1 callersFunctionNewServer
https://github.com/fullstorydev/grpcui
pkg/server/grpc/server.go:18
↓ 1 callersFunctionNewServer
()
internal/agent/server.go:17
↓ 1 callersFunctionNewStore
(path string)
pkg/store/buntdb/buntdb.go:15
↓ 1 callersFunctionNewTokenSource
(ctx context.Context, opt *Options, t *Token)
pkg/oauth2/client/source.go:85
↓ 1 callersFunctionNewWatcher
(watchers ...registry.Watcher)
pkg/registry/multi/watcher.go:12
↓ 1 callersFunctionNewWebsocket
()
pkg/network/websocket/server.go:29
↓ 1 callersMethodPack
()
internal/agent/msg/msg.go:118
↓ 1 callersMethodPack
()
internal/agent/msg/msg.go:161
↓ 1 callersFunctionParse
(prefixes []string)
pkg/config/env/env.go:13
↓ 1 callersFunctionParse
(fs *fg.Set, prefixes []string)
pkg/config/flag/flag.go:12
↓ 1 callersFunctionParseConfig
(fs *flags.Set)
cmd/hello/boot/engine/config.go:37
↓ 1 callersMethodPasswordCredentialsToken
(ctx context.Context, username, password string)
pkg/oauth2/client/oauth2.go:62
↓ 1 callersMethodPostHandle
(req *Request)
pkg/network/common/router.go:6
↓ 1 callersMethodPreHandle
(req *Request)
pkg/network/common/router.go:4
↓ 1 callersMethodPrint
用来写入日志
pkg/model/model.go:26
← previousnext →201–300 of 883, ranked by callers