Functions — github.com/8xmx8/GuTikTok

hub / github.com/8xmx8/GuTikTok / functions

Functions1,182 in github.com/8xmx8/GuTikTok

⨍ Functions 1,182◇ Types & classes 222

↓ 222 callersFunctionSetSpanError

(span trace.Span, err error)

src/utils/logging/logging.go:106

↓ 106 callersFunctionLogService

(name string)

src/utils/logging/logging.go:100

↓ 102 callersMethodStart

()

src/storage/cached/ticker.go:16

↓ 76 callersFunctionSetSpanWithHostname

(span trace.Span)

src/utils/logging/logging.go:116

↓ 43 callersMethodRender

(w http.ResponseWriter)

src/web/utils/json.go:20

↓ 37 callersMethodString

()

src/rpc/user/user.pb.go:278

↓ 36 callersFunctionrequest

(ctx context.Context, c *GorseClient, method, url string, body Body)

src/extra/gorse/client.go:207

↓ 19 callersMethodGetUserExistInformation

(ctx context.Context, in *UserExistRequest, opts ...grpc.CallOption)

src/rpc/user/user_grpc.pb.go:31

↓ 16 callersFunctionfailOnError

(err error, msg string)

src/services/msgconsumer/main.go:31

↓ 14 callersFunctionfile_relation_proto_rawDescGZIP

()

src/rpc/relation/relation.pb.go:968

↓ 13 callersFunctionRegisterConsul

(name string, port string)

src/utils/consul/register.go:26

↓ 13 callersMethodSet

(key string, value string)

src/utils/rabbitmq/otel.go:18

↓ 13 callersFunctionSetTraceProvider

(name string)

src/extra/tracing/otel.go:20

↓ 13 callersFunctionexitOnError

(err error)

src/services/videoprocessor/main.go:32

↓ 12 callersFunctionNewRelationServiceClient

(cc grpc.ClientConnInterface)

src/rpc/relation/relation_grpc.pb.go:50

↓ 12 callersFunctionfile_favorite_proto_rawDescGZIP

()

src/rpc/favorite/favorite.pb.go:838

↓ 11 callersMethodNew

()

src/services/auth/handler.go:46

↓ 11 callersFunctionfailOnError

输出

src/services/message/handler.go:49

↓ 10 callersFunctionBuildMQConnAddr

()

src/utils/rabbitmq/mq.go:8

↓ 10 callersFunctionInitPyroscope

(appName string)

src/extra/profiling/analyzer.go:13

↓ 10 callersFunctionNewUserServiceClient

(cc grpc.ClientConnInterface)

src/rpc/user/user_grpc.pb.go:38

↓ 9 callersMethodActionComment

(ctx context.Context, in *ActionCommentRequest, opts ...grpc.CallOption)

src/rpc/comment/comment_grpc.pb.go:31

↓ 9 callersFunctionGet

Get 读取字符串缓存, 其中找到了返回 True，没找到返回 False，异常也返回 False

src/storage/cached/cache.go:143

↓ 9 callersMethodGetUserInfo

(ctx context.Context, in *UserRequest, opts ...grpc.CallOption)

src/rpc/user/user_grpc.pb.go:30

↓ 9 callersFunctionfile_feed_proto_rawDescGZIP

()

src/rpc/feed/feed.pb.go:723

↓ 8 callersMethodQueryVideoExisted

(ctx context.Context, in *VideoExistRequest, opts ...grpc.CallOption)

src/rpc/feed/feed_grpc.pb.go:36

↓ 8 callersFunctionWrite

Write 写入字符串缓存，如果 state 为 false 则只写入 Local Memory

src/storage/cached/cache.go:214

↓ 8 callersFunctionexitOnError

(err error)

src/services/event/main.go:20

↓ 8 callersFunctionfile_comment_proto_rawDescGZIP

()

src/rpc/comment/comment.pb.go:645

↓ 7 callersFunctionExtractAMQPHeaders

(ctx context.Context, headers map[string]interface{})

src/utils/rabbitmq/otel.go:40

↓ 7 callersMethodFollow

(ctx context.Context, in *RelationActionRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:36

↓ 7 callersMethodGet

(key string)

src/utils/rabbitmq/otel.go:10

↓ 7 callersFunctionNewFeedServiceClient

(cc grpc.ClientConnInterface)

src/rpc/feed/feed_grpc.pb.go:44

↓ 7 callersFunctionTagDelete

TagDelete 删除字符串缓存

src/storage/cached/cache.go:229

↓ 7 callersFunctionexitOnError

(err error)

src/services/publish/handler.go:43

↓ 7 callersFunctiongetOrCreateCache

(name string)

src/storage/cached/cache.go:241

↓ 6 callersMethodChatAction

(ctx context.Context, in *ActionRequest, opts ...grpc.CallOption)

src/rpc/chat/chat_grpc.pb.go:31

↓ 6 callersFunctionInjectAMQPHeaders

(ctx context.Context)

src/utils/rabbitmq/otel.go:34

↓ 6 callersFunctionNewPublishServiceClient

(cc grpc.ClientConnInterface)

src/rpc/publish/publish_grpc.pb.go:40

↓ 6 callersMethodQueryVideos

(ctx context.Context, in *QueryVideosRequest, opts ...grpc.CallOption)

src/rpc/feed/feed_grpc.pb.go:35

↓ 6 callersFunctionfile_auth_proto_rawDescGZIP

()

src/rpc/auth/auth.pb.go:448

↓ 6 callersFunctionfile_publish_proto_rawDescGZIP

()

src/rpc/publish/publish.pb.go:435

↓ 6 callersFunctionsetups1

()

test/rpc/like_test.go:17

↓ 5 callersMethodCountComment

(ctx context.Context, in *CountCommentRequest, opts ...grpc.CallOption)

src/rpc/comment/comment_grpc.pb.go:33

↓ 5 callersMethodCountFollowList

(ctx context.Context, in *CountFollowListRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:39

↓ 5 callersMethodCountFollowerList

(ctx context.Context, in *CountFollowerListRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:41

↓ 5 callersMethodCreateVideo

(ctx context.Context, in *CreateVideoRequest, opts ...grpc.CallOption)

src/rpc/publish/publish_grpc.pb.go:31

↓ 5 callersMethodGetFriendList

(ctx context.Context, in *FriendListRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:42

↓ 5 callersFunctionGetLocalPath

(ctx context.Context, fileName string)

src/storage/file/provider.go:32

↓ 5 callersFunctionGetWithFunc

GetWithFunc 从缓存中获取字符串，如果不存在调用 Func 函数获取

src/storage/cached/cache.go:188

↓ 5 callersMethodIsFollow

(ctx context.Context, in *IsFollowRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:43

↓ 5 callersMethodRegister

(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption)

src/rpc/auth/auth_grpc.pb.go:32

↓ 5 callersMethodUnfollow

(ctx context.Context, in *RelationActionRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:37

↓ 5 callersFunctionUpload

(ctx context.Context, fileName string, content io.Reader)

src/storage/file/provider.go:28

↓ 5 callersFunctionerrorHandler

errorHandler If `requeue` is false, it will just `Nack` it. If `requeue` is true, it will try to re-publish it.

src/services/videoprocessor/summary.go:128

↓ 5 callersFunctionfile_chat_proto_rawDescGZIP

()

src/rpc/chat/chat.pb.go:416

↓ 5 callersFunctionfile_user_proto_rawDescGZIP

()

src/rpc/user/user.pb.go:456

↓ 4 callersMethodChat

(ctx context.Context, in *ChatRequest, opts ...grpc.CallOption)

src/rpc/chat/chat_grpc.pb.go:30

↓ 4 callersMethodCountFavorite

(ctx context.Context, in *CountFavoriteRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:37

↓ 4 callersMethodCountUserFavorite

(ctx context.Context, in *CountUserFavoriteRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:38

↓ 4 callersMethodCountUserTotalFavorited

(ctx context.Context, in *CountUserTotalFavoritedRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:39

↓ 4 callersMethodCountVideo

(ctx context.Context, in *CountVideoRequest, opts ...grpc.CallOption)

src/rpc/publish/publish_grpc.pb.go:33

↓ 4 callersMethodFavoriteAction

(ctx context.Context, in *FavoriteRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:34

↓ 4 callersMethodFavoriteList

(ctx context.Context, in *FavoriteListRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:35

↓ 4 callersMethodGetFollowList

(ctx context.Context, in *FollowListRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:38

↓ 4 callersMethodGetFollowerList

(ctx context.Context, in *FollowerListRequest, opts ...grpc.CallOption)

src/rpc/relation/relation_grpc.pb.go:40

↓ 4 callersMethodGetID

()

src/storage/cached/cache.go:28

↓ 4 callersMethodGetRecommendInformation

(ctx context.Context, in *RecommendRequest, opts ...grpc.CallOption)

src/rpc/recommend/recommand_grpc.pb.go:30

↓ 4 callersMethodIsFavorite

(ctx context.Context, in *IsFavoriteRequest, opts ...grpc.CallOption)

src/rpc/favorite/favorite_grpc.pb.go:36

↓ 4 callersMethodListComment

(ctx context.Context, in *ListCommentRequest, opts ...grpc.CallOption)

src/rpc/comment/comment_grpc.pb.go:32

↓ 4 callersMethodListVideo

(ctx context.Context, in *ListVideoRequest, opts ...grpc.CallOption)

src/rpc/publish/publish_grpc.pb.go:32

↓ 4 callersMethodListVideos

(ctx context.Context, in *ListFeedRequest, opts ...grpc.CallOption)

src/rpc/feed/feed_grpc.pb.go:34

↓ 4 callersMethodLogin

(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption)

src/rpc/auth/auth_grpc.pb.go:33

↓ 4 callersFunctionNewAuthServiceClient

(cc grpc.ClientConnInterface)

src/rpc/auth/auth_grpc.pb.go:40

↓ 4 callersFunctionNewChatServiceClient

(cc grpc.ClientConnInterface)

src/rpc/chat/chat_grpc.pb.go:38

↓ 4 callersFunctionNewCommentServiceClient

(cc grpc.ClientConnInterface)

src/rpc/comment/comment_grpc.pb.go:40

↓ 4 callersFunctionNewFavoriteServiceClient

(cc grpc.ClientConnInterface)

src/rpc/favorite/favorite_grpc.pb.go:46

↓ 4 callersFunctionPtr

(a T)

src/utils/ptr/ptr.go:3

↓ 4 callersFunctionPublishAuditEvent

(ctx context.Context, action *models2.Action, channel *amqp.Channel)

src/utils/audit/publish.go:34

↓ 4 callersFunctionfile_recommand_proto_rawDescGZIP

()

src/rpc/recommend/recommand.pb.go:312

↓ 3 callersMethodAuthenticate

(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption)

src/rpc/auth/auth_grpc.pb.go:31

↓ 3 callersMethodCheck

(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption)

src/rpc/health/check_grpc.pb.go:30

↓ 3 callersMethodError

(ctx context.Context, s string, i ...interface{})

src/utils/logging/gorm.go:34

↓ 3 callersMethodInfo

(ctx context.Context, s string, i ...interface{})

src/utils/logging/gorm.go:22

↓ 3 callersMethodListVideosByRecommend

(ctx context.Context, in *ListFeedRequest, opts ...grpc.CallOption)

src/rpc/feed/feed_grpc.pb.go:33

↓ 3 callersMethodNew

()

src/services/relation/handler.go:61

↓ 3 callersMethodNew

()

src/services/feed/handler.go:55

↓ 3 callersMethodNew

()

src/services/comment/handler.go:59

↓ 3 callersMethodNew

()

src/services/favorite/handler.go:47

↓ 3 callersFunctionNewRecommendServiceClient

(cc grpc.ClientConnInterface)

src/rpc/recommend/recommand_grpc.pb.go:38

↓ 3 callersMethodRegisterRecommendUser

(ctx context.Context, in *RecommendRegisterRequest, opts ...grpc.CallOption)

src/rpc/recommend/recommand_grpc.pb.go:31

↓ 3 callersFunctionerrorHandler

(channel *amqp.Channel, d amqp.Delivery, requeue bool, logger *logrus.Entry, span *trace.Span)

src/services/msgconsumer/main.go:491

↓ 3 callersFunctionexitOnError

(err error)

src/services/feed/handler.go:49

↓ 3 callersFunctionexitOnError

Maximum RateComment query amount

src/services/comment/handler.go:40

↓ 3 callersFunctionexitOnError

(err error)

src/services/favorite/handler.go:41

↓ 3 callersFunctionfile_check_proto_rawDescGZIP

()

src/rpc/health/check.pb.go:209

↓ 3 callersFunctionisUserExist

(ctx context.Context, actorID uint32, userID uint32, span trace.Span, logger *logrus.Entry)

src/services/relation/handler.go:1270

↓ 3 callersFunctionqueryDetailed

(ctx context.Context, logger *logrus.Entry, actorId uint32, videos []*models.Video)

src/services/feed/handler.go:510

↓ 2 callersFunctionCloseMQConn

()

src/services/message/handler.go:155

↓ 2 callersFunctionDeclareAuditExchange

(channel *amqp.Channel)

src/utils/audit/publish.go:21

next →1–100 of 1,182, ranked by callers