Interface Pusher

pkg/ruler/compat.go:37–39 · view source on GitHub ↗

Pusher is an ingester server that accepts pushes.

Source from the content-addressed store, hash-verified

35
36	// Pusher is an ingester server that accepts pushes.
37	type Pusher interface {
38	Push(context.Context, cortexpb.WriteRequest) (cortexpb.WriteResponse, error)
39	}
40
41	type PusherAppender struct {
42	failedWrites prometheus.Counter

GenerateTokensMethod · 0.65

CommitMethod · 0.65

mockGprcServerintegration/grpc_server_test.go

Clientintegration/e2ecortex/client.go

Distributorpkg/distributor/distributor.go

mockIngesterpkg/distributor/distributor_test.go

noopIngesterpkg/distributor/distributor_test.go

distributorClientpkg/distributor/distributorpb/distribu

UnimplementedDistributorServerpkg/distributor/distributorpb/distribu

myPusherpkg/cortex/modules_test.go

Ingesterpkg/ingester/ingester.go

IngesterServerMockpkg/ingester/client/cortex_mock_test.g

ingesterClientpkg/ingester/client/ingester.pb.go

UnimplementedIngesterServerpkg/ingester/client/ingester.pb.go

no outgoing calls

no test coverage detected