MCPcopy Create free account

hub / github.com/badoo/lsd / functions

Functions325 in github.com/badoo/lsd

⨍ Functions 325◇ Types & classes 62
↓ 1 callersMethodGetPerCategorySettings
()
proto/lsd-config.pb.go:140
↓ 1 callersMethodGetPeriodicScanInterval
()
proto/lsd-config.pb.go:343
↓ 1 callersMethodGetRequestTimeout
()
proto/lsd-config.pb.go:385
↓ 1 callersMethodGetServerConfig
()
proto/lsd-config.pb.go:69
↓ 1 callersMethodGetUsageCheckInterval
()
proto/lsd-config.pb.go:315
↓ 1 callersMethodGetWeight
()
proto/lsd-config.pb.go:371
↓ 1 callersMethodIsEmpty
()
internal/client/offsets/db.go:67
↓ 1 callersMethodIsFree
(ino uint64)
internal/client/usage/checker.go:25
↓ 1 callersMethodListen
()
internal/client/category/listener.go:61
↓ 1 callersMethodMarshalTo
(data []byte)
proto/lsd.pb.go:373
↓ 1 callersMethodMarshalTo
(data []byte)
proto/lsd.pb.go:406
↓ 1 callersMethodMarshalTo
(data []byte)
proto/lsd.pb.go:507
↓ 1 callersMethodMarshalTo
(data []byte)
proto/lsd.pb.go:542
↓ 1 callersFunctionNewNetworkRouter
(offsetsDb *offsets.Db, trafficManager *traffic.Manager, config *lsdProto.LsdConfigClientConfigT)
internal/client/network_router.go:17
↓ 1 callersMethodPrepare
()
internal/server/category/plain_writer.go:18
↓ 1 callersMethodRequestNewEvents
(rctx gpbrpc.RequestT, request *RequestNewEvents)
proto/lsd.gpbrpc.go:95
↓ 1 callersMethodRotate
(rotated after write, error)
internal/server/category/plain_writer.go:20
↓ 1 callersMethodSetBacklogSize
(size int64)
internal/traffic/manager.go:52
↓ 1 callersMethodSetOffset
(ino uint64, offset uint64)
internal/client/offsets/db.go:81
↓ 1 callersMethodSize
()
proto/lsd.pb.go:261
↓ 1 callersMethodSize
()
proto/lsd.pb.go:276
↓ 1 callersMethodSize
()
proto/lsd.pb.go:319
↓ 1 callersMethodSize
()
proto/lsd.pb.go:334
↓ 1 callersMethodStart
()
internal/client/network/balancer.go:97
↓ 1 callersMethodStop
()
internal/client/network/balancer.go:113
↓ 1 callersFunctionUnescapeLine
(line []byte)
util/writer.go:105
↓ 1 callersMethodUnwatch
(ino uint64)
internal/client/usage/checker.go:38
↓ 1 callersFunctionWatch
Watch starts to look through category's files and sends full file names that are ready to be processed to outChan if error occurs, Watch exits immedia
util/watcher.go:27
↓ 1 callersMethodWrite
(eventBytes []byte)
util/writer.go:38
↓ 1 callersMethodaccumulateBatch
()
internal/client/network/upstream.go:37
↓ 1 callersMethodadd
(name string)
internal/client/backlog.go:18
↓ 1 callersFunctioncheckClient
(config *lsd.LsdConfigClientConfigT, backlogSize int)
internal/health/check.go:157
↓ 1 callersFunctioncheckOffsets
(events []*lsdProto.RequestNewEventsEventT, offsets []*lsdProto.ResponseOffsetsOffsetT)
internal/client/network/upstream.go:180
↓ 1 callersFunctioncheckServer
(config *lsd.LsdConfigServerConfigT)
internal/health/check.go:229
↓ 1 callersMethodcleanInOperationMap
()
util/watcher.go:174
↓ 1 callersMethodclearEmptyQueues
()
internal/client/network/balancer.go:325
↓ 1 callersMethodconfirmEvent
(offsetsDb *offsets.Db, event *lsdProto.ResponseOffsetsOffsetT)
internal/client/network/balancer.go:263
↓ 1 callersMethodcreateCategoryDir
()
internal/server/category/chunked_writer.go:120
↓ 1 callersMethodcreateCurrentSymlink
()
internal/server/category/chunked_writer.go:272
↓ 1 callersMethodcurrentReceiver
()
internal/client/network/balancer.go:377
↓ 1 callersFunctiondeleteUsedFiles
(procDir string, result map[uint64]bool)
internal/client/usage/files_linux.go:49
↓ 1 callersFunctiondoDelete
(name string)
internal/server/hdfs/transfer.go:133
↓ 1 callersFunctiondoUpload
(u *uploader, name string)
internal/server/hdfs/transfer.go:116
↓ 1 callersFunctionensureDirExists
(dirPath string)
util/writer.go:109
↓ 1 callersFunctionescapeLine
does same as PHP's addcslashes($message, "\\\n") for compatibility with badoo PHP library
util/writer.go:101
↓ 1 callersMethodfindLastChunk
()
internal/server/category/chunked_writer.go:70
↓ 1 callersMethodflush
()
internal/client/backlog.go:33
↓ 1 callersMethodflushBacklogLoop
()
internal/client/fs_router.go:233
↓ 1 callersFunctiongcd
(x, y uint64)
internal/client/network/weight.go:3
↓ 1 callersFunctiongetBacklogSize
(isUp bool, daemonConfig *badoo_config.ServiceConfigDaemonConfigT)
internal/health/check.go:128
↓ 1 callersMethodgetListenCh
(cat string)
internal/server/handler.go:162
↓ 1 callersMethodgetOrigFilePath
()
internal/client/category/event.go:43
↓ 1 callersMethodgetOutChanForCategory
(category string)
internal/client/network_router.go:107
↓ 1 callersMethodgetSettingsForCategory
(name string)
internal/server/handler.go:151
↓ 1 callersMethodgetUpstreamList
()
internal/client/network/balancer.go:127
↓ 1 callersMethodgetValidOffsetDbEntry
(event *Event)
internal/client/category/listener.go:228
↓ 1 callersMethodincrement
()
internal/server/category/chunk.go:51
↓ 1 callersFunctionisDaemonUp
(listenRows []*badoo_config.ServiceConfigDaemonConfigTListenT)
internal/health/check.go:104
↓ 1 callersMethodisNewerThan
(otherCi *chunkInfo)
internal/server/category/chunk.go:41
↓ 1 callersMethodlistenLoop
(categoryName string, settings category.Settings, inCh chan *category.Event)
internal/server/handler.go:243
↓ 1 callersMethodmainLoop
()
internal/client/fs_router.go:107
↓ 1 callersMethodmainLoop
(offsetsDb *offsets.Db)
internal/client/network/balancer.go:163
↓ 1 callersMethodmaybeCleanFile
(request cleanRequest)
internal/client/category/listener.go:360
↓ 1 callersMethodmaybeDecompressEvent
(ev *lsd.RequestNewEventsEventT)
internal/server/handler.go:191
↓ 1 callersMethodmaybeRotate
(event Event, info *fileInfo)
internal/client/category/listener.go:297
↓ 1 callersFunctionmaybeRunSubCommand
()
lsd.go:53
↓ 1 callersMethodmaybeStartWatching
(absolutePath string)
internal/client/fs_router.go:208
↓ 1 callersFunctionnewBacklog
()
internal/client/backlog.go:7
↓ 1 callersFunctionnewEventReader
(fp *os.File, isExclusive bool)
internal/client/category/reader.go:12
↓ 1 callersFunctionnewFsRouter
(config *lsdProto.LsdConfigClientConfigT, tm *traffic.Manager, netRouter *NetworkRouter, offsetsDb *offsets.Db
internal/client/fs_router.go:31
↓ 1 callersFunctionnewUploader
(hostname, user, namenode, dstDir, tmpDir string)
internal/server/hdfs/uploader.go:24
↓ 1 callersFunctionnormalizeWeights
(r []*upstream)
internal/client/network/weight.go:10
↓ 1 callersFunctionparseFileName
(categoryName, fileName string)
internal/server/category/chunk.go:13
↓ 1 callersMethodperiodicScanLoop
()
internal/client/fs_router.go:256
↓ 1 callersMethodprocessEvents
(categoryName string, settings category.Settings, inCh chan *category.Event)
internal/server/handler.go:268
↓ 1 callersMethodprocessNewEvent
(event Event)
internal/client/category/listener.go:143
↓ 1 callersMethodreadBytes
(bufReader *bufio.Reader, isFinal bool)
internal/client/category/reader.go:27
↓ 1 callersFunctionreadFile
(ctx context.Context, filename string, buf *bufio.Reader, linesCh chan []byte)
util/reader.go:51
↓ 1 callersMethodreadLines
(readBuffer *bufio.Reader, isFinal bool)
internal/client/category/file_info.go:24
↓ 1 callersMethodregisterEvent
(event *Event)
internal/client/category/listener.go:169
↓ 1 callersMethodresetUpstream
()
internal/client/network/balancer.go:381
↓ 1 callersMethodsaveOffsetsLoop
()
internal/client/client.go:93
↓ 1 callersMethodsendChanges
(info *fileInfo, event Event)
internal/client/category/listener.go:265
↓ 1 callersMethodsendLoop
(trafficManager *traffic.Manager)
internal/client/network/upstream.go:94
↓ 1 callersMethodsize
()
internal/client/backlog.go:26
↓ 1 callersFunctionsozLsd
(x uint64)
proto/lsd.pb.go:360
↓ 1 callersMethodstart
()
internal/client/fs_router.go:82
↓ 1 callersFunctiontransferCategory
(categoryPath string, numWorkers int, shouldDelete bool, u *uploader)
internal/server/hdfs/transfer.go:85
↓ 1 callersMethodtransferLoop
()
internal/client/network/balancer.go:135
↓ 1 callersMethodupdateTrafficStatsLoop
()
internal/client/client.go:85
↓ 1 callersMethodupload
(sourcePath string)
internal/server/hdfs/uploader.go:51
↓ 1 callersMethodusageCheckLoop
()
internal/client/fs_router.go:245
↓ 1 callersMethodwatch
()
util/watcher.go:65
FunctionCheck
()
internal/health/check.go:60
MethodClose
()
internal/server/category/chunked_writer.go:228
MethodClose
()
internal/server/category/plain_writer.go:118
MethodClose
()
internal/server/category/settings.go:89
MethodDispatch
(rctx gpbrpc.RequestT, abstract_service interface{})
proto/lsd.gpbrpc.go:98
MethodEncode
(ev *lsdProto.RequestNewEventsEventT)
internal/client/network/encoder.go:20
MethodEncode
compresses event if enabled and not already compressed modifies event in place
internal/client/network/encoder.go:28
← previousnext →101–200 of 325, ranked by callers