Documentation
¶
Index ¶
Constants ¶
View Source
const ( ErrOutOfOrderEntry = "out of order entry %s was received before entries: %v\n" ErrEntryNotReceivedWs = "websocket failed to receive entry %v within %f seconds\n" ErrEntryNotReceived = "failed to receive entry %v within %f seconds\n" ErrSpotCheckEntryNotReceived = "failed to find entry %v in Loki when spot check querying %v after it was written\n" ErrDuplicateEntry = "received a duplicate entry for ts %v\n" ErrUnexpectedEntry = "received an unexpected entry with ts %v\n" DebugWebsocketMissingEntry = "websocket missing entry: %v\n" DebugQueryResult = "confirmation query result: %v\n" DebugEntryFound = "missing websocket entry %v was found %v seconds after it was originally sent\n" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Comparator ¶
type Comparator struct {
// contains filtered or unexported fields
}
func NewComparator ¶
func NewComparator(writer io.Writer, wait time.Duration, maxWait time.Duration, pruneInterval time.Duration, spotCheckInterval, spotCheckMax, spotCheckQueryRate, spotCheckWait time.Duration, metricTestInterval time.Duration, metricTestRange time.Duration, writeInterval time.Duration, buckets int, sentChan chan time.Time, receivedChan chan time.Time, reader reader.LokiReader, confirmAsync bool) *Comparator
func (*Comparator) Size ¶
func (c *Comparator) Size() int
func (*Comparator) Stop ¶
func (c *Comparator) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.