MCPcopy Create free account
hub / github.com/cortexproject/cortex / NewPusherAppendable

Function NewPusherAppendable

pkg/ruler/compat.go:145–153  ·  view source on GitHub ↗
(pusher Pusher, userID string, limits RulesLimits, totalWrites, failedWrites prometheus.Counter)

Source from the content-addressed store, hash-verified

143}
144
145func NewPusherAppendable(pusher Pusher, userID string, limits RulesLimits, totalWrites, failedWrites prometheus.Counter) *PusherAppendable {
146 return &PusherAppendable{
147 pusher: pusher,
148 userID: userID,
149 rulesLimits: limits,
150 totalWrites: totalWrites,
151 failedWrites: failedWrites,
152 }
153}
154
155// Appender returns a storage.Appender
156func (t *PusherAppendable) Appender(ctx context.Context) storage.Appender {

Callers 3

TestPusherAppendableFunction · 0.85
TestPusherErrorsFunction · 0.85

Calls

no outgoing calls

Tested by 2

TestPusherAppendableFunction · 0.68
TestPusherErrorsFunction · 0.68