forked from twitchscience/kinsumer
-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathnoopstatreceiver.go
More file actions
25 lines (17 loc) · 901 Bytes
/
noopstatreceiver.go
File metadata and controls
25 lines (17 loc) · 901 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
// Copyright (c) 2016 Twitch Interactive
package kinsumer
import "time"
// NoopStatReceiver is a statreceiver that doesn't do anything, use it if you do not want to collect
// stats, or as a base if you want to just collect a subset of stats
type NoopStatReceiver struct {
}
// Checkpoint implementation that doesn't do anything
func (*NoopStatReceiver) Checkpoint() {}
// EventToClient implementation that doesn't do anything
func (*NoopStatReceiver) EventToClient(inserted, retrieved time.Time) {}
// EventsFromKinesis implementation that doesn't do anything
func (*NoopStatReceiver) EventsFromKinesis(num int, shardID string, lag time.Duration) {}
// RecordsInMemory implementation that doesn't do anything
func (*NoopStatReceiver) RecordsInMemory(count int64) {}
// RecordsInMemoryBytes implementation that doesn't do anything
func (*NoopStatReceiver) RecordsInMemoryBytes(bytes int64) {}