sinkcluster

type ClusterCountResult struct {
	Sum           uint64
	ChunkIncluded int64
}

type ClusterCounter struct {
	// contains filtered or unexported fields
}

type ClusterWriter struct {
	// contains filtered or unexported fields
}

type SinkEntry struct {
	RecordingStart time.Time `json:"recordingStart"`
	RecordingEnd   time.Time `json:"recordingEnd"`
	Recorded       []byte    `json:"recorded"`
}

type WriteSyncer interface {
	Sync() error
	io.Writer
}