metrics

type ChangelogReader struct {
	Events

	ChangelogRowEventsWritten   *Counter
	ChangelogAlterTableEvents   *Counter
	ChangelogQueryEventsWritten *Counter
	ChangelogUnhandledEvents    *Counter

	TimeToEncounter *Timer

	NumTablesIngesting *Counter

	Errors *Counter

	LockLost *Counter
}

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

type Events struct {
	NumWorkers    *ProcessCounter
	EventsRead    *Counter
	EventsWritten *Counter
	BytesRead     *Counter
	BytesWritten  *Counter
	BatchSize     *Timer

	ReadLatency    *Timer
	ProduceLatency *Timer
}

type FilePipeMetrics struct {
	BytesWritten *Counter
	BytesRead    *Counter
	FilesCreated *Counter
	FilesOpened  *Counter
	FilesClosed  *Counter // == FilesCreated
}

type ProcessCounter struct {
	MStarted  *Counter
	MFinished *Counter
	MRunning  *Counter

	Started  int64
	Finished int64
}

type Snapshot struct {
	Events
	Errors      *Counter
	Duration    *Timer
	SizeRead    *Counter
	SizeWritten *Counter
	ThrottledUs *Counter
}

type State struct {
	NumTablesRegistered *Counter

	Sync         *ProcessCounter
	SyncDuration *Timer

	TableReg         *ProcessCounter
	TableRegDuration *Timer

	TableDereg         *ProcessCounter
	TableDeregDuration *Timer

	SyncErrors *Counter
}

type Streamer struct {
	Events
	TimeInBuffer *Timer
	Errors       *Counter
	LockLost     *Counter
}

type TallyConfiguration struct {
	Address  string
	Interval time.Duration
}

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

type Validation struct {
	NumValidations           *ProcessCounter
	ValidationRowsProcessed  *Counter
	ValidatedInsertEvents    *Counter
	ValidatedDeleteEvents    *Counter
	ValidatedSchemaEvents    *Counter
	ValidationFailed         *Counter
	ValidationSuccess        *Counter
	ValidationSuccessBatch   *Counter
	ValidationSchemaErrors   *Counter
	ValidationEventTypeError *Counter
	SnapshotBase             *Snapshot
	SnapshotRef              *Snapshot
}