buffer

Documentation

Index

• type BufferingTest
  • func (bt *BufferingTest) Test(t *testing.T)
• type QueryEngine
• type VTGateBufferingStats

Types

type BufferingTest

type BufferingTest struct {
	Assert   func(t *testing.T, shard string, stats *VTGateBufferingStats)
	Failover func(t *testing.T, cluster *cluster.LocalProcessCluster, keyspace string, reads, writes QueryEngine)

	ReserveConn bool
	SlowQueries bool

	VSchema         string
	VtGateExtraArgs []string
	// contains filtered or unexported fields
}

func (*BufferingTest) Test

func (bt *BufferingTest) Test(t *testing.T)

type QueryEngine

type QueryEngine interface {
	ExpectQueries(count int)
}

type VTGateBufferingStats

type VTGateBufferingStats struct {
	BufferLastRequestsInFlightMax map[string]int
	HealthcheckPrimaryPromoted    map[string]int
	BufferFailoverDurationSumMs   map[string]int
	BufferRequestsBuffered        map[string]int
	BufferStops                   map[string]int
}