MCPcopy
hub / github.com/prometheus/prometheus / Store

Method Store

storage/remote/queue_manager.go:411–411  ·  view source on GitHub ↗

Store stores the given samples in the remote storage.

(ctx context.Context, req []byte, retryAttempt int)

Source from the content-addressed store, hash-verified

409type WriteClient interface {
410 // Store stores the given samples in the remote storage.
411 Store(ctx context.Context, req []byte, retryAttempt int) (WriteResponseStats, error)
412 // Name uniquely identifies the remote storage.
413 Name() string
414 // Endpoint is the remote read or write endpoint for the storage client.

Callers 15

TestStoreHTTPErrorHandlingFunction · 0.95
TestClientRetryAfterFunction · 0.95
TestClientCustomHeadersFunction · 0.95
BenchmarkCompactionFromOOOHeadFunction · 0.65
DefaultHeadOptionsFunction · 0.65
NewHeadFunction · 0.65
resetInMemoryStateMethod · 0.65
InitMethod · 0.65
loadMmappedChunksMethod · 0.65
ApplyConfigMethod · 0.65
SetOutOfOrderTimeWindowMethod · 0.65
SetMinValidTimeMethod · 0.65

Implementers 5

TestWriteClientstorage/remote/queue_manager_test.go
TestBlockingWriteClientstorage/remote/queue_manager_test.go
NopWriteClientstorage/remote/queue_manager_test.go
MockWriteClientstorage/remote/queue_manager_test.go
Clientstorage/remote/client.go

Calls

no outgoing calls

Tested by 15

TestStoreHTTPErrorHandlingFunction · 0.76
TestClientRetryAfterFunction · 0.76
TestClientCustomHeadersFunction · 0.76
BenchmarkCompactionFromOOOHeadFunction · 0.52
TestHeadOptionsUseXOR2FloatEncodingFunction · 0.52
TestQuerierShouldNotFailIfOOOCompactionOccursAfterRetrievingQuerierFunction · 0.52
TestQuerierShouldNotFailIfOOOCompactionOccursAfterSelectingFunction · 0.52
TestQuerierShouldNotFailIfOOOCompactionOccursAfterRetrievingIteratorsFunction · 0.52
TestAbortBlockCompactionsFunction · 0.52
TestCompactStaleHead_EvictedSeriesRecordKeptInCheckpointFunction · 0.52
newTestHeadDefaultOptionsFunction · 0.52
BenchmarkLoadWLsFunction · 0.52