Functions — github.com/26597925/EastCloud

hub / github.com/26597925/EastCloud / functions

Functions883 in github.com/26597925/EastCloud

⨍ Functions 883◇ Types & classes 220

↓ 72 callersFunctionError

(args ...interface{})

pkg/logger/logger.go:62

↓ 46 callersMethodString

()

pkg/logger/options.go:33

↓ 44 callersMethodGet

(ctx context.Context, key string)

pkg/store/store.go:9

↓ 43 callersFunctionInfo

(args ...interface{})

pkg/logger/logger.go:38

↓ 41 callersMethodError

()

pkg/broker/broker.go:25

↓ 39 callersMethodClose

()

pkg/store/store.go:13

↓ 38 callersMethodSet

(ctx context.Context, key string, value string, expire time.Duration)

pkg/store/store.go:10

↓ 22 callersMethodAdd

Add add atomic int32

pkg/util/atomic/int64.go:28

↓ 18 callersMethodStart

()

pkg/server/api/server.go:11

↓ 17 callersMethodGetData

()

pkg/network/common/router.go:23

↓ 17 callersMethodGetMsgID

()

pkg/network/common/router.go:27

↓ 16 callersMethodEncode

(interface{})

pkg/config/encoder/encoder.go:4

↓ 15 callersMethodString

()

pkg/oauth2/api/oauth2.go:14

↓ 15 callersMethodWriteString

(buff *bytes.Buffer, str string)

internal/agent/msg/msg.go:77

↓ 14 callersMethodRead

(data interface{})

pkg/config/etcd/etcd.go:155

↓ 12 callersMethodSendMsg

(msgId byte, data []byte)

pkg/network/tcp/client.go:41

↓ 11 callersMethodDelete

(ctx context.Context, key string)

pkg/store/store.go:11

↓ 11 callersMethodRegister

(option api.Option)

pkg/registry/registry.go:10

↓ 9 callersMethodClose

()

pkg/broker/broker.go:7

↓ 9 callersMethodGetConnection

()

pkg/network/common/router.go:19

↓ 9 callersMethodInfo

(args ...interface{})

pkg/logger/logger.go:21

↓ 9 callersMethodString

(name string)

pkg/bootstrap/flag/flag.go:96

↓ 8 callersMethodAddRouter

(msgId byte, router common.IRouter)

pkg/network/tcp/server.go:96

↓ 8 callersMethodBuild

()

pkg/client/grpc/options.go:41

↓ 8 callersMethodNext

()

pkg/config/api/api.go:14

↓ 8 callersMethodRemoteAddr

()

pkg/network/common/connection.go:82

↓ 8 callersMethodStop

()

pkg/config/api/api.go:15

↓ 7 callersMethodGetPrefix

(ctx context.Context, prefix string)

pkg/client/etcdv3/etcd.go:55

↓ 7 callersMethodPut

(val string)

pkg/config/etcd/etcd.go:143

↓ 7 callersMethodReadString

(dataBuff *bytes.Reader)

internal/agent/msg/msg.go:81

↓ 7 callersMethodWatch

()

pkg/registry/registry.go:14

↓ 7 callersMethodgetPrefix

()

pkg/oauth2/server/stores/token.go:119

↓ 6 callersMethodDecode

([]byte, interface{})

pkg/config/encoder/encoder.go:5

↓ 6 callersMethodFatal

(args ...interface{})

pkg/logger/logger.go:29

↓ 6 callersFunctionGetConfig

()

cmd/hello/boot/engine/context.go:70

↓ 6 callersMethodGetDataLen

()

pkg/network/common/message.go:17

↓ 6 callersMethodLen

()

pkg/network/common/connmanager.go:49

↓ 6 callersMethodParse

()

pkg/bootstrap/flag/flag.go:37

↓ 6 callersMethodRedirect

(uri string)

pkg/oauth2/server/response.go:13

↓ 6 callersMethodStop

()

pkg/bootstrap/signal/signal.go:6

↓ 6 callersFunctionnewDataPack

(maxPacketSize uint32)

pkg/network/tcp/datapack.go:13

↓ 6 callersFunctionremoveConn

(conn *poolConn)

pkg/client/grpc/grpc_pool.go:194

↓ 5 callersMethodBasePack

(dataBuff *bytes.Buffer)

internal/agent/msg/msg.go:89

↓ 5 callersMethodBaseUnpack

(dataBuff *bytes.Reader)

internal/agent/msg/msg.go:100

↓ 5 callersMethodDeregister

(sv *Service)

pkg/registry/registry.go:11

↓ 5 callersMethodGetConnMgr

()

pkg/network/tcp/server.go:100

↓ 5 callersMethodGetValue

(ctx context.Context, key string)

pkg/client/etcdv3/etcd.go:42

↓ 5 callersMethodIncr

Incr incr atomic int64

pkg/util/atomic/int64.go:23

↓ 5 callersMethodLog

(level Level, args ...interface{})

pkg/logger/zap.go:108

↓ 5 callersMethodLogf

(level Level, format string, args ...interface{})

pkg/logger/zap.go:131

↓ 5 callersMethodLookup

(name string)

pkg/bootstrap/flag/flag.go:60

↓ 5 callersMethodNewRegistry

()

pkg/client/etcdv3/etcd.go:183

↓ 5 callersMethodPublish

(topic string, m *Message)

pkg/broker/broker.go:12

↓ 4 callersMethodCreate

(ctx context.Context, token *token.Token)

pkg/oauth2/server/stores/token.go:22

↓ 4 callersMethodDel

(ctx context.Context, prefix string)

pkg/config/etcd/etcd.go:147

↓ 4 callersMethodGetClient

(ctx context.Context, id string)

pkg/oauth2/server/stores/client.go:27

↓ 4 callersMethodGetConnID

()

pkg/network/common/connection.go:78

↓ 4 callersMethodInt

(name string)

pkg/bootstrap/flag/flag.go:110

↓ 4 callersMethodMessage

()

pkg/broker/broker.go:24

↓ 4 callersFunctionNewCmd

(proc *ProcInfo)

pkg/process/process.go:16

↓ 4 callersMethodNewWatchWithPrefixKey

(prefixKey string)

pkg/client/etcdv3/etcd.go:161

↓ 4 callersMethodPack

(msg *common.Message)

pkg/network/tcp/datapack.go:23

↓ 4 callersFunctionRequestToken

(ctx context.Context, opt *Options, v url.Values)

pkg/oauth2/client/token.go:142

↓ 4 callersMethodStartProxy

(types string, name string)

internal/agent/core/process.go:92

↓ 4 callersMethodToken

(ctx context.Context, token * token.Token, isGenRefresh bool)

pkg/oauth2/server/generates/generates.go:14

↓ 4 callersFunctionTrimPreVal

(val string, pre string)

pkg/util/stringext/string.go:22

↓ 4 callersFunctionaddConnAfter

(conn *poolConn, after *poolConn)

pkg/client/grpc/grpc_pool.go:208

↓ 4 callersFunctionerrOut

(status int, info string)

cmd/agent/work/work.go:57

↓ 3 callersMethodAddHandler

(handler Handler)

pkg/scheduler/client.go:40

↓ 3 callersMethodCall

path:/service.Struct/Method

pkg/client/grpc/grpc.go:25

↓ 3 callersMethodClose

()

pkg/network/tcp/client.go:53

↓ 3 callersMethodConsume

(queue, key string, headers amqp.Table, qArgs amqp.Table, autoAck, durableQueue bool)

pkg/broker/rabbitmq/connection.go:65

↓ 3 callersFunctionContextClient

(ctx context.Context)

pkg/oauth2/client/client.go:12

↓ 3 callersMethodDebug

(args ...interface{})

pkg/logger/logger.go:23

↓ 3 callersMethodDoMD5

定义接口 (结构体可以复用) 方法 (请求消息结构体) returns (返回消息结构体) {}

ph/grpc_server/test/test.pb.go:128

↓ 3 callersMethodDoReceive

(request *Request)

pkg/network/common/msghandler.go:24

↓ 3 callersMethodError

(args ...interface{})

pkg/logger/logger.go:27

↓ 3 callersMethodGetDriver

()

pkg/server/api/server.go:18

↓ 3 callersMethodGetIP

()

pkg/server/api/server.go:25

↓ 3 callersMethodGetMsgBuffChan

()

pkg/network/common/connection.go:110

↓ 3 callersMethodGetMsgChan

()

pkg/network/common/connection.go:106

↓ 3 callersMethodGetMsgId

()

pkg/network/common/message.go:21

↓ 3 callersMethodGetName

()

pkg/server/api/server.go:19

↓ 3 callersMethodGetPort

()

pkg/server/api/server.go:26

↓ 3 callersMethodGetServers

()

pkg/bootstrap/boot.go:15

↓ 3 callersFunctionGetServiceContext

()

cmd/hello/boot/engine/context.go:42

↓ 3 callersMethodGracefulStop

(ctx context.Context)

pkg/bootstrap/signal/signal.go:7

↓ 3 callersFunctionNewConnection

(types int, conn net.Conn, connID uint32, maxMsgChanLen uint32, maxPacketSize uint32)

pkg/network/common/connection.go:37

↓ 3 callersFunctionNewMsgHandle

(workerPoolSize uint32, maxWorkerTaskLen uint32)

pkg/network/common/msghandler.go:15

↓ 3 callersMethodNewWheel

(p map[string]interface{}, d time.Duration, f ExecuteHandler)

pkg/util/timer/timingwheel.go:79

↓ 3 callersMethodPack

()

internal/agent/msg/msg.go:227

↓ 3 callersMethodServe

()

pkg/bootstrap/boot.go:62

↓ 3 callersFunctionSetAuthURLParam

(key, value string)

pkg/oauth2/client/options.go:32

↓ 3 callersFunctionSetAuthURLParam

(key, value string)

pkg/oauth2/server/options.go:32

↓ 3 callersMethodSetData

(data []byte)

pkg/network/common/message.go:37

↓ 3 callersMethodStartWorkerPool

()

pkg/network/common/msghandler.go:67

↓ 3 callersMethodToken

()

pkg/oauth2/client/source.go:11

↓ 3 callersMethodType

()

pkg/registry/etcd/registry.go:138

↓ 3 callersMethodUpdate

(ctx context.Context, key, value, oldValue string)

pkg/client/etcdv3/etcd.go:121

↓ 3 callersFunctionWarn

(args ...interface{})

pkg/logger/logger.go:54

next →1–100 of 883, ranked by callers