kvrpc

Documentation

Index

• type Batch
  • func AppendBatches(batches []Batch, regionID locate.RegionVerID, groupKeys [][]byte, ...) []Batch
  • func AppendKeyBatches(batches []Batch, regionID locate.RegionVerID, groupKeys [][]byte, limit int) []Batch
• type BatchResult

Types

type Batch

type Batch struct {
	RegionID locate.RegionVerID
	Keys     [][]byte
	Values   [][]byte
	TTLs     []uint64
}

Batch is part of the mutation set that will be sent to tikv in a request.

func AppendBatches

func AppendBatches(batches []Batch, regionID locate.RegionVerID, groupKeys [][]byte, keyToValue map[string][]byte, keyToTTL map[string]uint64, limit int) []Batch

AppendBatches divides the mutation to be requested into Batches so that the size of each batch is approximately the same as the given limit.

func AppendKeyBatches

func AppendKeyBatches(batches []Batch, regionID locate.RegionVerID, groupKeys [][]byte, limit int) []Batch

AppendKeyBatches divides the mutation to be requested into Batches, ensuring that the count of keys of each Batch is not greater than the given limit.

type BatchResult

type BatchResult struct {
	*tikvrpc.Response
	Error error
}

BatchResult wraps a Batch request's server response or an error.