sync2

type Batcher ¶

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

Batcher delays concurrent operations for a configurable interval in order to batch them up or otherwise clock their operation to run concurrently.

It is implemented as a channel of int32s. Each waiter blocks on the channel from which it gets a sequentially increasing batch ID when the timer elapses.

Hence a waiter is delayed for at most the batch interval.

func NewBatcher(interval time.Duration) *Batcher

func (b *Batcher) Wait() int

type Consolidator ¶

type Consolidator interface {
	Create(string) (PendingResult, bool)
	Items() []ConsolidatorCacheItem
	Record(query string)
}

Consolidator consolidates duplicate queries from executing simulaneously and shares results between them.

func NewConsolidator() Consolidator

type ConsolidatorCache ¶

type ConsolidatorCache struct {
	*cache.LRUCache[*ccount]
}

ConsolidatorCache is a thread-safe object used for counting how often recent queries have been consolidated. It is also used by the txserializer package to count how often transactions have been queued and had to wait because they targeted the same row (range).

func NewConsolidatorCache(capacity int64) *ConsolidatorCache

func (cc *ConsolidatorCache) Items() []ConsolidatorCacheItem

func (cc *ConsolidatorCache) Record(query string)

type ConsolidatorCacheItem ¶

type ConsolidatorCacheItem struct {
	Query string
	Count int64
}

ConsolidatorCacheItem is a wrapper for the items in the consolidator cache

type FakeConsolidator ¶ added in v0.17.0

type FakeConsolidator struct {
	// CreateCalls can be used to inspect Create calls.
	CreateCalls []string
	// CreateReturns can be used to inspect Create return values.
	CreateReturns []*FakeConsolidatorCreateReturn
	// CreateReturnCreated pre-configures the return value of Create calls.
	CreateReturn *FakeConsolidatorCreateReturn
	// RecordCalls can be usd to inspect Record calls.
	RecordCalls []string
}

FakeConsolidator satisfies the Consolidator interface and can be used to mock how Vitess interacts with the Consolidator.

func NewFakeConsolidator() *FakeConsolidator

func (fc *FakeConsolidator) Create(sql string) (PendingResult, bool)

func (fc *FakeConsolidator) Items() []ConsolidatorCacheItem

func (fc *FakeConsolidator) Record(sql string)

type FakeConsolidatorCreateReturn ¶ added in v0.17.0

type FakeConsolidatorCreateReturn struct {
	// PendingResult contains the PendingResult return value of a call to
	// FakeConsolidator.Create.
	PendingResult
	// PendingResult contains the Created return value of a call to
	// FakeConsolidator.Create.
	Created bool
}

FakeConsolidatorCreateReturn wraps the two return values of a call to FakeConsolidator.Create.

type FakePendingResult ¶ added in v0.17.0

type FakePendingResult struct {
	// BroadcastCalls can be used to inspect Broadcast calls.
	BroadcastCalls int
	// WaitCalls can be used to inspect Wait calls.
	WaitCalls int
	// contains filtered or unexported fields
}

FakePendingResult satisfies the PendingResult interface and can be used to mock how Vitess interacts with the Consolidator.

func (fr *FakePendingResult) Broadcast()

func (fr *FakePendingResult) Err() error

func (fr *FakePendingResult) Result() *sqltypes.Result

func (fr *FakePendingResult) SetErr(err error)

func (fr *FakePendingResult) SetResult(result *sqltypes.Result)

func (fr *FakePendingResult) Wait()

type PendingResult ¶ added in v0.17.0

type PendingResult interface {
	Broadcast()
	Err() error
	SetErr(error)
	SetResult(*sqltypes.Result)
	Result() *sqltypes.Result
	Wait()
}

PendingResult is a wrapper for result of a query.