MCPcopy Create free account

hub / github.com/clrxbl/blockgametracker / functions

Functions65 in github.com/clrxbl/blockgametracker

⨍ Functions 65◇ Types & classes 11
↓ 5 callersFunctionGetEnv
(key, fallback string)
internal/config/config.go:96
↓ 5 callersMethodList
List returns spooled file paths sorted oldest-first.
internal/queue/spool.go:48
↓ 5 callersMethodWrite
Write persists a batch atomically as <unix_nanos>-<rand>.fb. The filename timestamp is used to drain oldest-first.
internal/queue/spool.go:28
↓ 4 callersMethodLoad
(path string)
internal/config/config.go:36
↓ 3 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:35
↓ 3 callersFunctionNewSpool
(dir string)
internal/queue/spool.go:19
↓ 3 callersMethoddrain
(ctx context.Context)
internal/queue/loop.go:68
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:35
↓ 2 callersMethodPush
Push sends a single message to the queue. The body is base64-encoded and sent with content_type=bytes so the consumer receives the raw flatbuffers pay
internal/queue/client.go:42
↓ 2 callersFunctionQueryAll
QueryAll pings every enabled server across both editions concurrently and returns all successful results. Failed pings are logged and omitted.
internal/ping/ping.go:116
↓ 2 callersMethodRead
(path string)
internal/queue/spool.go:68
↓ 2 callersMethodSnapshot
()
internal/config/config.go:30
↓ 2 callersMethodtick
(ctx context.Context)
internal/queue/loop.go:45
↓ 1 callersFunctionApplyToGauge
ApplyToGauge resets the gauge and writes one sample per result, matching the labels emitted by the original scrape-triggered exporter.
internal/ping/metrics.go:17
↓ 1 callersMethodDelete
(path string)
internal/queue/spool.go:72
↓ 1 callersFunctionEncodeBatch
EncodeBatch builds a flatbuffers PingBatch root containing the given results.
internal/queue/encode.go:22
↓ 1 callersFunctionNewClient
(accountID, queueID, token string)
internal/queue/client.go:24
↓ 1 callersFunctionNewStore
()
internal/config/config.go:28
↓ 1 callersMethodRun
Run blocks until ctx is cancelled. Each tick pings all enabled servers, pushes the batch, and (on success) drains up to DrainPerTick spooled batches i
internal/queue/loop.go:26
↓ 1 callersMethodWatch
(path string)
internal/config/config.go:56
↓ 1 callersFunctionbuildProducer
(store *config.Store)
main.go:72
↓ 1 callersFunctionplatformFor
(edition string)
internal/queue/encode.go:10
↓ 1 callersFunctionqueryOne
(edition, name, queryHostname string)
internal/ping/ping.go:44
MethodAsName
()
blockgametracker_protocol/ping/Ping.go:97
MethodAsNumber
()
blockgametracker_protocol/ping/Ping.go:84
FunctionFinishPingBatchBuffer
(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:20
FunctionFinishPingBuffer
(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:20
FunctionFinishSizePrefixedPingBatchBuffer
(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:31
FunctionFinishSizePrefixedPingBuffer
(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:31
FunctionGetRootAsPing
(buf []byte, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:13
FunctionGetRootAsPingBatch
(buf []byte, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:13
FunctionGetSizePrefixedRootAsPing
(buf []byte, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:24
FunctionGetSizePrefixedRootAsPingBatch
(buf []byte, offset flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:24
MethodMutateAsNumber
(n uint32)
blockgametracker_protocol/ping/Ping.go:93
MethodMutatePlatform
(n Platform)
blockgametracker_protocol/ping/Ping.go:80
MethodMutatePlayerCount
(n uint32)
blockgametracker_protocol/ping/Ping.go:114
MethodMutateTime
(n uint64)
blockgametracker_protocol/ping/Ping.go:52
FunctionPingAddAsName
(builder *flatbuffers.Builder, asName flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:137
FunctionPingAddAsNumber
(builder *flatbuffers.Builder, asNumber uint32)
blockgametracker_protocol/ping/Ping.go:133
FunctionPingAddPlatform
(builder *flatbuffers.Builder, platform Platform)
blockgametracker_protocol/ping/Ping.go:130
FunctionPingAddPlayerCount
(builder *flatbuffers.Builder, playerCount uint32)
blockgametracker_protocol/ping/Ping.go:140
FunctionPingAddServer
(builder *flatbuffers.Builder, server flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:124
FunctionPingAddServerAddress
(builder *flatbuffers.Builder, serverAddress flatbuffers.UOffsetT)
blockgametracker_protocol/ping/Ping.go:127
FunctionPingAddTime
(builder *flatbuffers.Builder, time uint64)
blockgametracker_protocol/ping/Ping.go:121
FunctionPingBatchAddPings
(builder *flatbuffers.Builder, pings flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:78
FunctionPingBatchAddSource
(builder *flatbuffers.Builder, source flatbuffers.UOffsetT)
blockgametracker_protocol/ping/PingBatch.go:75
FunctionPingBatchEnd
(builder *flatbuffers.Builder)
blockgametracker_protocol/ping/PingBatch.go:84
FunctionPingBatchStart
(builder *flatbuffers.Builder)
blockgametracker_protocol/ping/PingBatch.go:72
FunctionPingBatchStartPingsVector
(builder *flatbuffers.Builder, numElems int)
blockgametracker_protocol/ping/PingBatch.go:81
FunctionPingEnd
(builder *flatbuffers.Builder)
blockgametracker_protocol/ping/Ping.go:144
FunctionPingStart
(builder *flatbuffers.Builder)
blockgametracker_protocol/ping/Ping.go:118
MethodPings
(obj *Ping, j int)
blockgametracker_protocol/ping/PingBatch.go:52
MethodPingsLength
()
blockgametracker_protocol/ping/PingBatch.go:64
MethodPlatform
()
blockgametracker_protocol/ping/Ping.go:72
MethodPlayerCount
()
blockgametracker_protocol/ping/Ping.go:105
MethodServer
()
blockgametracker_protocol/ping/Ping.go:56
MethodServerAddress
()
blockgametracker_protocol/ping/Ping.go:64
MethodSource
()
blockgametracker_protocol/ping/PingBatch.go:44
MethodString
()
blockgametracker_protocol/ping/Platform.go:27
MethodTable
()
blockgametracker_protocol/ping/Ping.go:40
MethodTable
()
blockgametracker_protocol/ping/PingBatch.go:40
FunctionTestDrainAfterSuccessfulPush
(t *testing.T)
internal/queue/spool_drain_test.go:11
FunctionTestDrainStopsOnFailureToPreserveOrder
(t *testing.T)
internal/queue/spool_drain_test.go:68
MethodTime
()
blockgametracker_protocol/ping/Ping.go:44
Functionmain
()
main.go:22