workload

Documentation

Index

• type WorkloadStats
  • func NewWorkloadStats() *WorkloadStats
  • func (s *WorkloadStats) Reset()
• type WriteTracker
  • func NewWriteTracker() *WriteTracker
  • func (t *WriteTracker) Count() int
  • func (t *WriteTracker) RandomKey() gocql.UUID
  • func (t *WriteTracker) TotalWrites() int64
  • func (t *WriteTracker) TrackWrite(key gocql.UUID, timestampUnixNano int64)
  • func (t *WriteTracker) Verify() error
  • func (t *WriteTracker) VerifyAndPrune(sessionA, sessionB cql.Session, minAge time.Duration) (int, error)
  • func (t *WriteTracker) VerifyConsistency(sessionA, sessionB cql.Session) error

Types

type WorkloadStats

type WorkloadStats struct {
	WriteOK        atomic.Int64
	WriteAsync     atomic.Int64 // errors.Is(err, types.ErrWriteAsync)
	WriteDropped   atomic.Int64 // errors.Is(err, types.ErrWriteDropped)
	WriteFailed    atomic.Int64 // all other write errors
	DualClusterErr atomic.Int64 // errors.As(err, *types.DualClusterError)
	ReadOK         atomic.Int64
	ReadFailed     atomic.Int64
}

WorkloadStats tracks error classifications from the traffic generator.

func NewWorkloadStats

func NewWorkloadStats() *WorkloadStats

NewWorkloadStats creates a new WorkloadStats.

func (*WorkloadStats) Reset

func (s *WorkloadStats) Reset()

Reset zeroes all counters.

type WriteTracker

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

WriteTracker tracks successful writes for verification.

func NewWriteTracker

func NewWriteTracker() *WriteTracker

NewWriteTracker creates a new write tracker.

func (*WriteTracker) Count

func (t *WriteTracker) Count() int

Count returns the number of currently tracked writes. This value may decrease when VerifyAndPrune removes old entries. For write volume gates that need a monotonically increasing counter, use TotalWrites instead.

func (*WriteTracker) RandomKey

func (t *WriteTracker) RandomKey() gocql.UUID

RandomKey returns a random key from the tracked writes. Returns a zero UUID if no writes are tracked.

func (*WriteTracker) TotalWrites

func (t *WriteTracker) TotalWrites() int64

TotalWrites returns the total number of writes tracked since creation. Unlike Count, this value never decreases (pruning does not affect it), making it safe for write volume gate checks in scenarios.

func (*WriteTracker) TrackWrite

func (t *WriteTracker) TrackWrite(key gocql.UUID, timestampUnixNano int64)

TrackWrite records a successful write.

func (*WriteTracker) Verify

func (t *WriteTracker) Verify() error

Verify checks if the tracked writes exist in the database. In a real implementation, this would query the database. For now, we'll just return the count of tracked writes.

func (*WriteTracker) VerifyAndPrune

func (t *WriteTracker) VerifyAndPrune(sessionA, sessionB cql.Session, minAge time.Duration) (int, error)

VerifyAndPrune verifies writes older than minAge and removes them to save memory. This is essential for long-running soak tests.

The lock is held only while collecting and deleting stale keys from the map. DB verification queries run after the lock is released so that concurrent TrackWrite and Count calls are not blocked for the duration of the queries.

func (*WriteTracker) VerifyConsistency

func (t *WriteTracker) VerifyConsistency(sessionA, sessionB cql.Session) error

VerifyConsistency checks if all tracked writes exist in both clusters.