block

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 20, 2021 License: Apache-2.0 Imports: 29 Imported by: 26

Documentation

Overview

Package block is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SortFetchBlockResultByTimeAscending 

func SortFetchBlockResultByTimeAscending(results []FetchBlockResult)

SortFetchBlockResultByTimeAscending sorts fetch block results in time ascending order

Types

type DatabaseBlock 

type DatabaseBlock interface {
	// StartTime returns the start time of the block.
	StartTime() xtime.UnixNano

	// BlockSize returns the duration of the block.
	BlockSize() time.Duration

	// SetLastReadTime sets the last read time of the block.
	SetLastReadTime(value xtime.UnixNano)

	// LastReadTime returns the last read time of the block.
	LastReadTime() xtime.UnixNano

	// Len returns the block length.
	Len() int

	// Checksum returns the block checksum.
	Checksum() (uint32, error)

	// Stream returns the encoded byte stream.
	Stream(blocker context.Context) (xio.BlockReader, error)

	// Merge will merge the current block with the specified block
	// when this block is read. Note: calling this twice
	// will simply overwrite the target for the block to merge with
	// rather than merging three blocks together.
	Merge(other DatabaseBlock) error

	// HasMergeTarget returns whether the block requires multiple blocks to be
	// merged during Stream().
	HasMergeTarget() bool

	// WasRetrievedFromDisk returns whether the block was retrieved from storage.
	WasRetrievedFromDisk() bool

	// Reset resets the block start time, duration, and the segment.
	Reset(
		startTime xtime.UnixNano,
		blockSize time.Duration,
		segment ts.Segment,
		nsCtx namespace.Context,
	)

	// ResetFromDisk resets the block start time, duration, segment, and id.
	ResetFromDisk(
		startTime xtime.UnixNano,
		blockSize time.Duration,
		segment ts.Segment,
		id ident.ID,
		nsCtx namespace.Context,
	)

	// Discard closes the block, but returns the (unfinalized) segment.
	Discard() ts.Segment

	// Close closes the block.
	Close()

	// CloseIfFromDisk atomically checks if the disk was retrieved from disk, and
	// if so, closes it. It is meant as a layered protection for the WiredList
	// which should only close blocks that were retrieved from disk.
	CloseIfFromDisk() bool

	// SetOnEvictedFromWiredList sets the owner of the block
	SetOnEvictedFromWiredList(OnEvictedFromWiredList)

	// OnEvictedFromWiredList returns the owner of the block
	OnEvictedFromWiredList() OnEvictedFromWiredList
	// contains filtered or unexported methods
}

DatabaseBlock is the interface for a DatabaseBlock

func NewDatabaseBlock 

func NewDatabaseBlock(
	start xtime.UnixNano,
	blockSize time.Duration,
	segment ts.Segment,
	opts Options,
	nsCtx namespace.Context,
) DatabaseBlock

NewDatabaseBlock creates a new DatabaseBlock instance.

type DatabaseBlockAllocate 

type DatabaseBlockAllocate func() DatabaseBlock

DatabaseBlockAllocate allocates a database block for a pool.

type DatabaseBlockPool 

type DatabaseBlockPool interface {
	// Init initializes the pool.
	Init(alloc DatabaseBlockAllocate)

	// Get provides a database block from the pool.
	Get() DatabaseBlock

	// Put returns a database block to the pool.
	Put(block DatabaseBlock)
}

DatabaseBlockPool provides a pool for database blocks.

func NewDatabaseBlockPool 

func NewDatabaseBlockPool(opts pool.ObjectPoolOptions) DatabaseBlockPool

NewDatabaseBlockPool creates a new pool for database blocks.

type DatabaseBlockRetriever 

type DatabaseBlockRetriever interface {
	io.Closer

	// CacheShardIndices will pre-parse the indexes for given shards
	// to improve times when streaming a block.
	CacheShardIndices(shards []uint32) error

	// Stream will stream a block for a given shard, id and start.
	Stream(
		ctx context.Context,
		shard uint32,
		id ident.ID,
		blockStart xtime.UnixNano,
		onRetrieve OnRetrieveBlock,
		nsCtx namespace.Context,
	) (xio.BlockReader, error)

	// StreamWideEntry will stream the wide entry for a given ID within
	// a block, yielding a wide entry if it is available in the shard.
	StreamWideEntry(
		ctx context.Context,
		shard uint32,
		id ident.ID,
		blockStart xtime.UnixNano,
		filter schema.WideEntryFilter,
		nsCtx namespace.Context,
	) (StreamedWideEntry, error)

	// AssignShardSet assigns the given shard set to this retriever.
	AssignShardSet(shardSet sharding.ShardSet)
}

DatabaseBlockRetriever is a block retriever.

type DatabaseBlockRetrieverManager 

type DatabaseBlockRetrieverManager interface {
	// Retriever provides the DatabaseBlockRetriever for the given namespace.
	Retriever(
		nsMetadata namespace.Metadata,
		shardSet sharding.ShardSet,
	) (DatabaseBlockRetriever, error)
}

DatabaseBlockRetrieverManager creates and holds block retrievers for different namespaces.

func NewDatabaseBlockRetrieverManager 

func NewDatabaseBlockRetrieverManager(
	newDatabaseBlockRetrieverFn NewDatabaseBlockRetrieverFn,
) DatabaseBlockRetrieverManager

NewDatabaseBlockRetrieverManager creates a new manager for constructing and providing existing database block retrievers

type DatabaseSeriesBlocks 

type DatabaseSeriesBlocks interface {
	// Len returns the number of blocks contained in the collection.
	Len() int

	// AddBlock adds a data block.
	AddBlock(block DatabaseBlock)

	// AddSeries adds a raw series.
	AddSeries(other DatabaseSeriesBlocks)

	// MinTime returns the min time of the blocks contained.
	MinTime() xtime.UnixNano

	// MaxTime returns the max time of the blocks contained.
	MaxTime() xtime.UnixNano

	// BlockAt returns the block at a given time if any.
	BlockAt(t xtime.UnixNano) (DatabaseBlock, bool)

	// AllBlocks returns all the blocks in the series.
	AllBlocks() map[xtime.UnixNano]DatabaseBlock

	// RemoveBlockAt removes the block at a given time if any.
	RemoveBlockAt(t xtime.UnixNano)

	// RemoveAll removes all blocks.
	RemoveAll()

	// Reset resets the DatabaseSeriesBlocks so they can be re-used
	Reset()

	// Close closes all the blocks.
	Close()
}

DatabaseSeriesBlocks represents a collection of data blocks.

func NewDatabaseSeriesBlocks 

func NewDatabaseSeriesBlocks(capacity int) DatabaseSeriesBlocks

NewDatabaseSeriesBlocks creates a databaseSeriesBlocks instance.

type DatabaseShardBlockRetriever 

type DatabaseShardBlockRetriever interface {
	// Stream will stream a block for a given id and start.
	Stream(
		ctx context.Context,
		id ident.ID,
		blockStart xtime.UnixNano,
		onRetrieve OnRetrieveBlock,
		nsCtx namespace.Context,
	) (xio.BlockReader, error)

	// StreamWideEntry will stream the wide entry for a given ID within
	// a block, yielding a wide entry if available.
	StreamWideEntry(
		ctx context.Context,
		id ident.ID,
		blockStart xtime.UnixNano,
		filter schema.WideEntryFilter,
		nsCtx namespace.Context,
	) (StreamedWideEntry, error)
}

DatabaseShardBlockRetriever is a block retriever bound to a shard.

func NewDatabaseShardBlockRetriever 

func NewDatabaseShardBlockRetriever(
	shard uint32,
	r DatabaseBlockRetriever,
) DatabaseShardBlockRetriever

NewDatabaseShardBlockRetriever creates a new shard database block retriever given an existing database block retriever

type DatabaseShardBlockRetrieverManager 

type DatabaseShardBlockRetrieverManager interface {
	// ShardRetriever provides the DatabaseShardBlockRetriever for the given shard.
	ShardRetriever(shard uint32) DatabaseShardBlockRetriever
}

DatabaseShardBlockRetrieverManager creates and holds shard block retrievers binding shards to an existing retriever.

func NewDatabaseShardBlockRetrieverManager 

func NewDatabaseShardBlockRetrieverManager(
	r DatabaseBlockRetriever,
) DatabaseShardBlockRetrieverManager

NewDatabaseShardBlockRetrieverManager creates and holds shard block retrievers binding shards to an existing retriever.

type FetchBlockMetadataResult 

type FetchBlockMetadataResult struct {
	Start    xtime.UnixNano
	Size     int64
	Checksum *uint32
	LastRead xtime.UnixNano
	Err      error
}

FetchBlockMetadataResult captures the block start time, the block size, and any errors encountered

func NewFetchBlockMetadataResult 

func NewFetchBlockMetadataResult(
	start xtime.UnixNano,
	size int64,
	checksum *uint32,
	lastRead xtime.UnixNano,
	err error,
) FetchBlockMetadataResult

NewFetchBlockMetadataResult creates a new fetch block metadata result.

type FetchBlockMetadataResults 

type FetchBlockMetadataResults interface {
	// Add adds a result to the slice
	Add(res FetchBlockMetadataResult)

	// Results returns the result slice
	Results() []FetchBlockMetadataResult

	// SortByTimeAscending sorts the results in time ascending order
	Sort()

	// Reset resets the results
	Reset()

	// Close performs cleanup
	Close()
}

FetchBlockMetadataResults captures a collection of FetchBlockMetadataResult

func NewFetchBlockMetadataResults 

func NewFetchBlockMetadataResults() FetchBlockMetadataResults

NewFetchBlockMetadataResults creates a non-pooled fetchBlockMetadataResults

type FetchBlockMetadataResultsPool 

type FetchBlockMetadataResultsPool interface {
	// Get returns an FetchBlockMetadataResults
	Get() FetchBlockMetadataResults

	// Put puts an FetchBlockMetadataResults back to pool
	Put(res FetchBlockMetadataResults)
}

FetchBlockMetadataResultsPool provides a pool for fetchBlockMetadataResults

func NewFetchBlockMetadataResultsPool 

func NewFetchBlockMetadataResultsPool(opts pool.ObjectPoolOptions, capacity int) FetchBlockMetadataResultsPool

NewFetchBlockMetadataResultsPool creates a new fetchBlockMetadataResultsPool

type FetchBlockResult 

type FetchBlockResult struct {
	Start      xtime.UnixNano
	FirstWrite xtime.UnixNano
	Blocks     []xio.BlockReader
	Err        error
}

FetchBlockResult captures the block start time, the readers for the underlying streams, the corresponding checksum and any errors encountered.

func NewFetchBlockResult 

func NewFetchBlockResult(
	start xtime.UnixNano,
	blocks []xio.BlockReader,
	err error,
) FetchBlockResult

NewFetchBlockResult creates a new fetch block result

type FetchBlocksMetadataOptions 

type FetchBlocksMetadataOptions struct {
	IncludeSizes     bool
	IncludeChecksums bool
	IncludeLastRead  bool
	OnlyDisk         bool
}

FetchBlocksMetadataOptions are options used when fetching blocks metadata.

type FetchBlocksMetadataResult 

type FetchBlocksMetadataResult struct {
	ID     ident.ID
	Tags   ident.TagIterator
	Blocks FetchBlockMetadataResults
}

FetchBlocksMetadataResult captures the fetch results for multiple blocks.

func NewFetchBlocksMetadataResult 

func NewFetchBlocksMetadataResult(
	id ident.ID,
	tags ident.TagIterator,
	blocks FetchBlockMetadataResults,
) FetchBlocksMetadataResult

NewFetchBlocksMetadataResult creates new database blocks metadata

type FetchBlocksMetadataResults 

type FetchBlocksMetadataResults interface {
	// Add adds a result to the slice
	Add(res FetchBlocksMetadataResult)

	// Results returns the result slice
	Results() []FetchBlocksMetadataResult

	// Reset resets the results
	Reset()

	// Close performs cleanup
	Close()
}

FetchBlocksMetadataResults captures a collection of FetchBlocksMetadataResult

func NewFetchBlocksMetadataResults 

func NewFetchBlocksMetadataResults() FetchBlocksMetadataResults

NewFetchBlocksMetadataResults creates a non-pooled FetchBlocksMetadataResults

type FetchBlocksMetadataResultsPool 

type FetchBlocksMetadataResultsPool interface {
	// Get returns an fetchBlocksMetadataResults
	Get() FetchBlocksMetadataResults

	// Put puts an fetchBlocksMetadataResults back to pool
	Put(res FetchBlocksMetadataResults)
}

FetchBlocksMetadataResultsPool provides a pool for fetchBlocksMetadataResults

func NewFetchBlocksMetadataResultsPool 

func NewFetchBlocksMetadataResultsPool(opts pool.ObjectPoolOptions, capacity int) FetchBlocksMetadataResultsPool

NewFetchBlocksMetadataResultsPool creates a new fetchBlocksMetadataResultsPool

type FilteredBlocksMetadataIter 

type FilteredBlocksMetadataIter interface {
	// Next returns the next item if available
	Next() bool

	// Current returns the current id and block metadata
	Current() (ident.ID, Metadata)

	//  Error returns an error if encountered
	Err() error
}

FilteredBlocksMetadataIter iterates over a list of blocks metadata results with filtering applied

func NewFilteredBlocksMetadataIter 

func NewFilteredBlocksMetadataIter(
	res FetchBlocksMetadataResults,
) FilteredBlocksMetadataIter

NewFilteredBlocksMetadataIter creates a new filtered blocks metadata iterator, there's no pooling of the tags returned currently. Only the repair process uses this currently which is unoptimized.

type HashableLeaseDescriptor added in v1.0.0 

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

HashableLeaseDescriptor is a lease descriptor that can be used as a map key.

func NewHashableLeaseDescriptor added in v1.0.0 

func NewHashableLeaseDescriptor(descriptor LeaseDescriptor) HashableLeaseDescriptor

HashableLeaseDescriptor transforms LeaseDescriptor into a HashableLeaseDescriptor.

type LeaseDescriptor added in v0.10.0 

type LeaseDescriptor struct {
	Namespace  ident.ID
	Shard      uint32
	BlockStart xtime.UnixNano
}

LeaseDescriptor describes a lease (like an ID).

type LeaseManager added in v0.10.0 

type LeaseManager interface {
	// RegisterLeaser registers the leaser to receive UpdateOpenLease()
	// calls when leases need to be updated.
	RegisterLeaser(leaser Leaser) error
	// UnregisterLeaser unregisters the leaser from receiving UpdateOpenLease()
	// calls.
	UnregisterLeaser(leaser Leaser) error
	// OpenLease opens a lease.
	OpenLease(
		leaser Leaser,
		descriptor LeaseDescriptor,
		state LeaseState,
	) error
	// OpenLatestLease opens a lease for the latest LeaseState for a given
	// LeaseDescriptor.
	OpenLatestLease(leaser Leaser, descriptor LeaseDescriptor) (LeaseState, error)
	// UpdateOpenLeases propagate a call to UpdateOpenLease() to each registered
	// leaser.
	UpdateOpenLeases(
		descriptor LeaseDescriptor,
		state LeaseState,
	) (UpdateLeasesResult, error)
	// SetLeaseVerifier sets the LeaseVerifier (for delayed initialization).
	SetLeaseVerifier(leaseVerifier LeaseVerifier) error
}

LeaseManager is a manager of block leases and leasers.

func NewLeaseManager added in v0.10.0 

func NewLeaseManager(verifier LeaseVerifier) LeaseManager

NewLeaseManager creates a new lease manager with a provided lease verifier (to ensure leases are valid when made).

type LeaseState added in v0.10.0 

type LeaseState struct {
	Volume int
}

LeaseState is the current state of a lease which can be requested to be updated.

type LeaseVerifier added in v0.10.0 

type LeaseVerifier interface {
	// VerifyLease is called to determine if the requested lease is valid.
	VerifyLease(
		descriptor LeaseDescriptor,
		state LeaseState,
	) error

	// LatestState returns the latest LeaseState for a given descriptor.
	LatestState(descriptor LeaseDescriptor) (LeaseState, error)
}

LeaseVerifier verifies that a lease is valid.

type Leaser added in v0.10.0 

type Leaser interface {
	// UpdateOpenLease is called on the Leaser when the latest state
	// has changed and the leaser needs to update their lease. The leaser
	// should update its state (releasing any resources as necessary and
	// optionally acquiring new ones related to the updated lease) accordingly,
	// but it should *not* call LeaseManager.OpenLease() with the provided
	// descriptor and state.
	//
	// UpdateOpenLease will never be called concurrently on the same Leaser. Each
	// call to UpdateOpenLease() must return before the next one will begin.
	UpdateOpenLease(
		descriptor LeaseDescriptor,
		state LeaseState,
	) (UpdateOpenLeaseResult, error)
}

Leaser is a block leaser.

type Metadata 

type Metadata struct {
	ID       ident.ID
	Tags     ident.Tags
	Start    xtime.UnixNano
	Size     int64
	Checksum *uint32
	LastRead xtime.UnixNano
}

Metadata captures block metadata

func NewMetadata 

func NewMetadata(
	id ident.ID,
	tags ident.Tags,
	start xtime.UnixNano,
	size int64,
	checksum *uint32,
	lastRead xtime.UnixNano,
) Metadata

NewMetadata creates a new block metadata

func (*Metadata) Finalize 

func (m *Metadata) Finalize()

Finalize will finalize the ID and Tags on the metadata.

type MockDatabaseBlock 

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

MockDatabaseBlock is a mock of DatabaseBlock interface.

func NewMockDatabaseBlock 

func NewMockDatabaseBlock(ctrl *gomock.Controller) *MockDatabaseBlock

NewMockDatabaseBlock creates a new mock instance.

func (*MockDatabaseBlock) BlockSize 

func (m *MockDatabaseBlock) BlockSize() time.Duration

BlockSize mocks base method.

func (*MockDatabaseBlock) Checksum 

func (m *MockDatabaseBlock) Checksum() (uint32, error)

Checksum mocks base method.

func (*MockDatabaseBlock) Close 

func (m *MockDatabaseBlock) Close()

Close mocks base method.

func (*MockDatabaseBlock) CloseIfFromDisk added in v0.4.2 

func (m *MockDatabaseBlock) CloseIfFromDisk() bool

CloseIfFromDisk mocks base method.

func (*MockDatabaseBlock) Discard added in v0.4.0 

func (m *MockDatabaseBlock) Discard() ts.Segment

Discard mocks base method.

func (*MockDatabaseBlock) EXPECT 

func (m *MockDatabaseBlock) EXPECT() *MockDatabaseBlockMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseBlock) HasMergeTarget added in v0.3.0 

func (m *MockDatabaseBlock) HasMergeTarget() bool

HasMergeTarget mocks base method.

func (*MockDatabaseBlock) LastReadTime 

func (m *MockDatabaseBlock) LastReadTime() time0.UnixNano

LastReadTime mocks base method.

func (*MockDatabaseBlock) Len 

func (m *MockDatabaseBlock) Len() int

Len mocks base method.

func (*MockDatabaseBlock) Merge 

func (m *MockDatabaseBlock) Merge(other DatabaseBlock) error

Merge mocks base method.

func (*MockDatabaseBlock) OnEvictedFromWiredList 

func (m *MockDatabaseBlock) OnEvictedFromWiredList() OnEvictedFromWiredList

OnEvictedFromWiredList mocks base method.

func (*MockDatabaseBlock) Reset 

func (m *MockDatabaseBlock) Reset(startTime time0.UnixNano, blockSize time.Duration, segment ts.Segment, nsCtx namespace.Context)

Reset mocks base method.

func (*MockDatabaseBlock) ResetFromDisk added in v0.4.8 

func (m *MockDatabaseBlock) ResetFromDisk(startTime time0.UnixNano, blockSize time.Duration, segment ts.Segment, id ident.ID, nsCtx namespace.Context)

ResetFromDisk mocks base method.

func (*MockDatabaseBlock) SetLastReadTime 

func (m *MockDatabaseBlock) SetLastReadTime(value time0.UnixNano)

SetLastReadTime mocks base method.

func (*MockDatabaseBlock) SetOnEvictedFromWiredList 

func (m *MockDatabaseBlock) SetOnEvictedFromWiredList(arg0 OnEvictedFromWiredList)

SetOnEvictedFromWiredList mocks base method.

func (*MockDatabaseBlock) StartTime 

func (m *MockDatabaseBlock) StartTime() time0.UnixNano

StartTime mocks base method.

func (*MockDatabaseBlock) Stream 

func (m *MockDatabaseBlock) Stream(blocker context.Context) (xio.BlockReader, error)

Stream mocks base method.

func (*MockDatabaseBlock) WasRetrievedFromDisk 

func (m *MockDatabaseBlock) WasRetrievedFromDisk() bool

WasRetrievedFromDisk mocks base method.

type MockDatabaseBlockMockRecorder 

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

MockDatabaseBlockMockRecorder is the mock recorder for MockDatabaseBlock.

func (*MockDatabaseBlockMockRecorder) BlockSize 

func (mr *MockDatabaseBlockMockRecorder) BlockSize() *gomock.Call

BlockSize indicates an expected call of BlockSize.

func (*MockDatabaseBlockMockRecorder) Checksum 

func (mr *MockDatabaseBlockMockRecorder) Checksum() *gomock.Call

Checksum indicates an expected call of Checksum.

func (*MockDatabaseBlockMockRecorder) Close 

func (mr *MockDatabaseBlockMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDatabaseBlockMockRecorder) CloseIfFromDisk added in v0.4.2 

func (mr *MockDatabaseBlockMockRecorder) CloseIfFromDisk() *gomock.Call

CloseIfFromDisk indicates an expected call of CloseIfFromDisk.

func (*MockDatabaseBlockMockRecorder) Discard added in v0.4.0 

func (mr *MockDatabaseBlockMockRecorder) Discard() *gomock.Call

Discard indicates an expected call of Discard.

func (*MockDatabaseBlockMockRecorder) HasMergeTarget added in v0.3.0 

func (mr *MockDatabaseBlockMockRecorder) HasMergeTarget() *gomock.Call

HasMergeTarget indicates an expected call of HasMergeTarget.

func (*MockDatabaseBlockMockRecorder) LastReadTime 

func (mr *MockDatabaseBlockMockRecorder) LastReadTime() *gomock.Call

LastReadTime indicates an expected call of LastReadTime.

func (*MockDatabaseBlockMockRecorder) Len 

func (mr *MockDatabaseBlockMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockDatabaseBlockMockRecorder) Merge 

func (mr *MockDatabaseBlockMockRecorder) Merge(other interface{}) *gomock.Call

Merge indicates an expected call of Merge.

func (*MockDatabaseBlockMockRecorder) OnEvictedFromWiredList 

func (mr *MockDatabaseBlockMockRecorder) OnEvictedFromWiredList() *gomock.Call

OnEvictedFromWiredList indicates an expected call of OnEvictedFromWiredList.

func (*MockDatabaseBlockMockRecorder) Reset 

func (mr *MockDatabaseBlockMockRecorder) Reset(startTime, blockSize, segment, nsCtx interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockDatabaseBlockMockRecorder) ResetFromDisk added in v0.4.8 

func (mr *MockDatabaseBlockMockRecorder) ResetFromDisk(startTime, blockSize, segment, id, nsCtx interface{}) *gomock.Call

ResetFromDisk indicates an expected call of ResetFromDisk.

func (*MockDatabaseBlockMockRecorder) SetLastReadTime 

func (mr *MockDatabaseBlockMockRecorder) SetLastReadTime(value interface{}) *gomock.Call

SetLastReadTime indicates an expected call of SetLastReadTime.

func (*MockDatabaseBlockMockRecorder) SetOnEvictedFromWiredList 

func (mr *MockDatabaseBlockMockRecorder) SetOnEvictedFromWiredList(arg0 interface{}) *gomock.Call

SetOnEvictedFromWiredList indicates an expected call of SetOnEvictedFromWiredList.

func (*MockDatabaseBlockMockRecorder) StartTime 

func (mr *MockDatabaseBlockMockRecorder) StartTime() *gomock.Call

StartTime indicates an expected call of StartTime.

func (*MockDatabaseBlockMockRecorder) Stream 

func (mr *MockDatabaseBlockMockRecorder) Stream(blocker interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockDatabaseBlockMockRecorder) WasRetrievedFromDisk 

func (mr *MockDatabaseBlockMockRecorder) WasRetrievedFromDisk() *gomock.Call

WasRetrievedFromDisk indicates an expected call of WasRetrievedFromDisk.

type MockDatabaseBlockPool 

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

MockDatabaseBlockPool is a mock of DatabaseBlockPool interface.

func NewMockDatabaseBlockPool 

func NewMockDatabaseBlockPool(ctrl *gomock.Controller) *MockDatabaseBlockPool

NewMockDatabaseBlockPool creates a new mock instance.

func (*MockDatabaseBlockPool) EXPECT 

func (m *MockDatabaseBlockPool) EXPECT() *MockDatabaseBlockPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseBlockPool) Get 

func (m *MockDatabaseBlockPool) Get() DatabaseBlock

Get mocks base method.

func (*MockDatabaseBlockPool) Init 

func (m *MockDatabaseBlockPool) Init(alloc DatabaseBlockAllocate)

Init mocks base method.

func (*MockDatabaseBlockPool) Put 

func (m *MockDatabaseBlockPool) Put(block DatabaseBlock)

Put mocks base method.

type MockDatabaseBlockPoolMockRecorder 

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

MockDatabaseBlockPoolMockRecorder is the mock recorder for MockDatabaseBlockPool.

func (*MockDatabaseBlockPoolMockRecorder) Get 

func (mr *MockDatabaseBlockPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockDatabaseBlockPoolMockRecorder) Init 

func (mr *MockDatabaseBlockPoolMockRecorder) Init(alloc interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockDatabaseBlockPoolMockRecorder) Put 

func (mr *MockDatabaseBlockPoolMockRecorder) Put(block interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockDatabaseBlockRetriever 

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

MockDatabaseBlockRetriever is a mock of DatabaseBlockRetriever interface.

func NewMockDatabaseBlockRetriever 

func NewMockDatabaseBlockRetriever(ctrl *gomock.Controller) *MockDatabaseBlockRetriever

NewMockDatabaseBlockRetriever creates a new mock instance.

func (*MockDatabaseBlockRetriever) AssignShardSet added in v0.15.0 

func (m *MockDatabaseBlockRetriever) AssignShardSet(shardSet sharding.ShardSet)

AssignShardSet mocks base method.

func (*MockDatabaseBlockRetriever) CacheShardIndices 

func (m *MockDatabaseBlockRetriever) CacheShardIndices(shards []uint32) error

CacheShardIndices mocks base method.

func (*MockDatabaseBlockRetriever) Close added in v1.2.0 

func (m *MockDatabaseBlockRetriever) Close() error

Close mocks base method.

func (*MockDatabaseBlockRetriever) EXPECT 

func (m *MockDatabaseBlockRetriever) EXPECT() *MockDatabaseBlockRetrieverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseBlockRetriever) Stream 

func (m *MockDatabaseBlockRetriever) Stream(ctx context.Context, shard uint32, id ident.ID, blockStart time0.UnixNano, onRetrieve OnRetrieveBlock, nsCtx namespace.Context) (xio.BlockReader, error)

Stream mocks base method.

func (*MockDatabaseBlockRetriever) StreamWideEntry added in v1.0.1 

func (m *MockDatabaseBlockRetriever) StreamWideEntry(ctx context.Context, shard uint32, id ident.ID, blockStart time0.UnixNano, filter schema.WideEntryFilter, nsCtx namespace.Context) (StreamedWideEntry, error)

StreamWideEntry mocks base method.

type MockDatabaseBlockRetrieverManager 

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

MockDatabaseBlockRetrieverManager is a mock of DatabaseBlockRetrieverManager interface.

func NewMockDatabaseBlockRetrieverManager 

func NewMockDatabaseBlockRetrieverManager(ctrl *gomock.Controller) *MockDatabaseBlockRetrieverManager

NewMockDatabaseBlockRetrieverManager creates a new mock instance.

func (*MockDatabaseBlockRetrieverManager) EXPECT 

func (m *MockDatabaseBlockRetrieverManager) EXPECT() *MockDatabaseBlockRetrieverManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseBlockRetrieverManager) Retriever 

func (m *MockDatabaseBlockRetrieverManager) Retriever(nsMetadata namespace.Metadata, shardSet sharding.ShardSet) (DatabaseBlockRetriever, error)

Retriever mocks base method.

type MockDatabaseBlockRetrieverManagerMockRecorder 

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

MockDatabaseBlockRetrieverManagerMockRecorder is the mock recorder for MockDatabaseBlockRetrieverManager.

func (*MockDatabaseBlockRetrieverManagerMockRecorder) Retriever 

func (mr *MockDatabaseBlockRetrieverManagerMockRecorder) Retriever(nsMetadata, shardSet interface{}) *gomock.Call

Retriever indicates an expected call of Retriever.

type MockDatabaseBlockRetrieverMockRecorder 

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

MockDatabaseBlockRetrieverMockRecorder is the mock recorder for MockDatabaseBlockRetriever.

func (*MockDatabaseBlockRetrieverMockRecorder) AssignShardSet added in v0.15.0 

func (mr *MockDatabaseBlockRetrieverMockRecorder) AssignShardSet(shardSet interface{}) *gomock.Call

AssignShardSet indicates an expected call of AssignShardSet.

func (*MockDatabaseBlockRetrieverMockRecorder) CacheShardIndices 

func (mr *MockDatabaseBlockRetrieverMockRecorder) CacheShardIndices(shards interface{}) *gomock.Call

CacheShardIndices indicates an expected call of CacheShardIndices.

func (*MockDatabaseBlockRetrieverMockRecorder) Close added in v1.2.0 

func (mr *MockDatabaseBlockRetrieverMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDatabaseBlockRetrieverMockRecorder) Stream 

func (mr *MockDatabaseBlockRetrieverMockRecorder) Stream(ctx, shard, id, blockStart, onRetrieve, nsCtx interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockDatabaseBlockRetrieverMockRecorder) StreamWideEntry added in v1.0.1 

func (mr *MockDatabaseBlockRetrieverMockRecorder) StreamWideEntry(ctx, shard, id, blockStart, filter, nsCtx interface{}) *gomock.Call

StreamWideEntry indicates an expected call of StreamWideEntry.

type MockDatabaseSeriesBlocks 

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

MockDatabaseSeriesBlocks is a mock of DatabaseSeriesBlocks interface.

func NewMockDatabaseSeriesBlocks 

func NewMockDatabaseSeriesBlocks(ctrl *gomock.Controller) *MockDatabaseSeriesBlocks

NewMockDatabaseSeriesBlocks creates a new mock instance.

func (*MockDatabaseSeriesBlocks) AddBlock 

func (m *MockDatabaseSeriesBlocks) AddBlock(block DatabaseBlock)

AddBlock mocks base method.

func (*MockDatabaseSeriesBlocks) AddSeries 

func (m *MockDatabaseSeriesBlocks) AddSeries(other DatabaseSeriesBlocks)

AddSeries mocks base method.

func (*MockDatabaseSeriesBlocks) AllBlocks 

func (m *MockDatabaseSeriesBlocks) AllBlocks() map[time0.UnixNano]DatabaseBlock

AllBlocks mocks base method.

func (*MockDatabaseSeriesBlocks) BlockAt 

func (m *MockDatabaseSeriesBlocks) BlockAt(t time0.UnixNano) (DatabaseBlock, bool)

BlockAt mocks base method.

func (*MockDatabaseSeriesBlocks) Close 

func (m *MockDatabaseSeriesBlocks) Close()

Close mocks base method.

func (*MockDatabaseSeriesBlocks) EXPECT 

func (m *MockDatabaseSeriesBlocks) EXPECT() *MockDatabaseSeriesBlocksMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseSeriesBlocks) Len 

func (m *MockDatabaseSeriesBlocks) Len() int

Len mocks base method.

func (*MockDatabaseSeriesBlocks) MaxTime 

func (m *MockDatabaseSeriesBlocks) MaxTime() time0.UnixNano

MaxTime mocks base method.

func (*MockDatabaseSeriesBlocks) MinTime 

func (m *MockDatabaseSeriesBlocks) MinTime() time0.UnixNano

MinTime mocks base method.

func (*MockDatabaseSeriesBlocks) RemoveAll 

func (m *MockDatabaseSeriesBlocks) RemoveAll()

RemoveAll mocks base method.

func (*MockDatabaseSeriesBlocks) RemoveBlockAt 

func (m *MockDatabaseSeriesBlocks) RemoveBlockAt(t time0.UnixNano)

RemoveBlockAt mocks base method.

func (*MockDatabaseSeriesBlocks) Reset 

func (m *MockDatabaseSeriesBlocks) Reset()

Reset mocks base method.

type MockDatabaseSeriesBlocksMockRecorder 

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

MockDatabaseSeriesBlocksMockRecorder is the mock recorder for MockDatabaseSeriesBlocks.

func (*MockDatabaseSeriesBlocksMockRecorder) AddBlock 

func (mr *MockDatabaseSeriesBlocksMockRecorder) AddBlock(block interface{}) *gomock.Call

AddBlock indicates an expected call of AddBlock.

func (*MockDatabaseSeriesBlocksMockRecorder) AddSeries 

func (mr *MockDatabaseSeriesBlocksMockRecorder) AddSeries(other interface{}) *gomock.Call

AddSeries indicates an expected call of AddSeries.

func (*MockDatabaseSeriesBlocksMockRecorder) AllBlocks 

func (mr *MockDatabaseSeriesBlocksMockRecorder) AllBlocks() *gomock.Call

AllBlocks indicates an expected call of AllBlocks.

func (*MockDatabaseSeriesBlocksMockRecorder) BlockAt 

func (mr *MockDatabaseSeriesBlocksMockRecorder) BlockAt(t interface{}) *gomock.Call

BlockAt indicates an expected call of BlockAt.

func (*MockDatabaseSeriesBlocksMockRecorder) Close 

func (mr *MockDatabaseSeriesBlocksMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDatabaseSeriesBlocksMockRecorder) Len 

func (mr *MockDatabaseSeriesBlocksMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockDatabaseSeriesBlocksMockRecorder) MaxTime 

func (mr *MockDatabaseSeriesBlocksMockRecorder) MaxTime() *gomock.Call

MaxTime indicates an expected call of MaxTime.

func (*MockDatabaseSeriesBlocksMockRecorder) MinTime 

func (mr *MockDatabaseSeriesBlocksMockRecorder) MinTime() *gomock.Call

MinTime indicates an expected call of MinTime.

func (*MockDatabaseSeriesBlocksMockRecorder) RemoveAll 

func (mr *MockDatabaseSeriesBlocksMockRecorder) RemoveAll() *gomock.Call

RemoveAll indicates an expected call of RemoveAll.

func (*MockDatabaseSeriesBlocksMockRecorder) RemoveBlockAt 

func (mr *MockDatabaseSeriesBlocksMockRecorder) RemoveBlockAt(t interface{}) *gomock.Call

RemoveBlockAt indicates an expected call of RemoveBlockAt.

func (*MockDatabaseSeriesBlocksMockRecorder) Reset 

func (mr *MockDatabaseSeriesBlocksMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset.

type MockDatabaseShardBlockRetriever 

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

MockDatabaseShardBlockRetriever is a mock of DatabaseShardBlockRetriever interface.

func NewMockDatabaseShardBlockRetriever 

func NewMockDatabaseShardBlockRetriever(ctrl *gomock.Controller) *MockDatabaseShardBlockRetriever

NewMockDatabaseShardBlockRetriever creates a new mock instance.

func (*MockDatabaseShardBlockRetriever) EXPECT 

func (m *MockDatabaseShardBlockRetriever) EXPECT() *MockDatabaseShardBlockRetrieverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseShardBlockRetriever) Stream 

func (m *MockDatabaseShardBlockRetriever) Stream(ctx context.Context, id ident.ID, blockStart time0.UnixNano, onRetrieve OnRetrieveBlock, nsCtx namespace.Context) (xio.BlockReader, error)

Stream mocks base method.

func (*MockDatabaseShardBlockRetriever) StreamWideEntry added in v1.0.1 

func (m *MockDatabaseShardBlockRetriever) StreamWideEntry(ctx context.Context, id ident.ID, blockStart time0.UnixNano, filter schema.WideEntryFilter, nsCtx namespace.Context) (StreamedWideEntry, error)

StreamWideEntry mocks base method.

type MockDatabaseShardBlockRetrieverManager 

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

MockDatabaseShardBlockRetrieverManager is a mock of DatabaseShardBlockRetrieverManager interface.

func NewMockDatabaseShardBlockRetrieverManager 

func NewMockDatabaseShardBlockRetrieverManager(ctrl *gomock.Controller) *MockDatabaseShardBlockRetrieverManager

NewMockDatabaseShardBlockRetrieverManager creates a new mock instance.

func (*MockDatabaseShardBlockRetrieverManager) EXPECT 

func (m *MockDatabaseShardBlockRetrieverManager) EXPECT() *MockDatabaseShardBlockRetrieverManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabaseShardBlockRetrieverManager) ShardRetriever 

func (m *MockDatabaseShardBlockRetrieverManager) ShardRetriever(shard uint32) DatabaseShardBlockRetriever

ShardRetriever mocks base method.

type MockDatabaseShardBlockRetrieverManagerMockRecorder 

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

MockDatabaseShardBlockRetrieverManagerMockRecorder is the mock recorder for MockDatabaseShardBlockRetrieverManager.

func (*MockDatabaseShardBlockRetrieverManagerMockRecorder) ShardRetriever 

func (mr *MockDatabaseShardBlockRetrieverManagerMockRecorder) ShardRetriever(shard interface{}) *gomock.Call

ShardRetriever indicates an expected call of ShardRetriever.

type MockDatabaseShardBlockRetrieverMockRecorder 

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

MockDatabaseShardBlockRetrieverMockRecorder is the mock recorder for MockDatabaseShardBlockRetriever.

func (*MockDatabaseShardBlockRetrieverMockRecorder) Stream 

func (mr *MockDatabaseShardBlockRetrieverMockRecorder) Stream(ctx, id, blockStart, onRetrieve, nsCtx interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockDatabaseShardBlockRetrieverMockRecorder) StreamWideEntry added in v1.0.1 

func (mr *MockDatabaseShardBlockRetrieverMockRecorder) StreamWideEntry(ctx, id, blockStart, filter, nsCtx interface{}) *gomock.Call

StreamWideEntry indicates an expected call of StreamWideEntry.

type MockFetchBlockMetadataResults 

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

MockFetchBlockMetadataResults is a mock of FetchBlockMetadataResults interface.

func NewMockFetchBlockMetadataResults 

func NewMockFetchBlockMetadataResults(ctrl *gomock.Controller) *MockFetchBlockMetadataResults

NewMockFetchBlockMetadataResults creates a new mock instance.

func (*MockFetchBlockMetadataResults) Add 

func (m *MockFetchBlockMetadataResults) Add(res FetchBlockMetadataResult)

Add mocks base method.

func (*MockFetchBlockMetadataResults) Close 

func (m *MockFetchBlockMetadataResults) Close()

Close mocks base method.

func (*MockFetchBlockMetadataResults) EXPECT 

func (m *MockFetchBlockMetadataResults) EXPECT() *MockFetchBlockMetadataResultsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFetchBlockMetadataResults) Reset 

func (m *MockFetchBlockMetadataResults) Reset()

Reset mocks base method.

func (*MockFetchBlockMetadataResults) Results 

func (m *MockFetchBlockMetadataResults) Results() []FetchBlockMetadataResult

Results mocks base method.

func (*MockFetchBlockMetadataResults) Sort 

func (m *MockFetchBlockMetadataResults) Sort()

Sort mocks base method.

type MockFetchBlockMetadataResultsMockRecorder 

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

MockFetchBlockMetadataResultsMockRecorder is the mock recorder for MockFetchBlockMetadataResults.

func (*MockFetchBlockMetadataResultsMockRecorder) Add 

func (mr *MockFetchBlockMetadataResultsMockRecorder) Add(res interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockFetchBlockMetadataResultsMockRecorder) Close 

func (mr *MockFetchBlockMetadataResultsMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockFetchBlockMetadataResultsMockRecorder) Reset 

func (mr *MockFetchBlockMetadataResultsMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset.

func (*MockFetchBlockMetadataResultsMockRecorder) Results 

func (mr *MockFetchBlockMetadataResultsMockRecorder) Results() *gomock.Call

Results indicates an expected call of Results.

func (*MockFetchBlockMetadataResultsMockRecorder) Sort 

func (mr *MockFetchBlockMetadataResultsMockRecorder) Sort() *gomock.Call

Sort indicates an expected call of Sort.

type MockFetchBlockMetadataResultsPool 

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

MockFetchBlockMetadataResultsPool is a mock of FetchBlockMetadataResultsPool interface.

func NewMockFetchBlockMetadataResultsPool 

func NewMockFetchBlockMetadataResultsPool(ctrl *gomock.Controller) *MockFetchBlockMetadataResultsPool

NewMockFetchBlockMetadataResultsPool creates a new mock instance.

func (*MockFetchBlockMetadataResultsPool) EXPECT 

func (m *MockFetchBlockMetadataResultsPool) EXPECT() *MockFetchBlockMetadataResultsPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFetchBlockMetadataResultsPool) Get 

func (m *MockFetchBlockMetadataResultsPool) Get() FetchBlockMetadataResults

Get mocks base method.

func (*MockFetchBlockMetadataResultsPool) Put 

func (m *MockFetchBlockMetadataResultsPool) Put(res FetchBlockMetadataResults)

Put mocks base method.

type MockFetchBlockMetadataResultsPoolMockRecorder 

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

MockFetchBlockMetadataResultsPoolMockRecorder is the mock recorder for MockFetchBlockMetadataResultsPool.

func (*MockFetchBlockMetadataResultsPoolMockRecorder) Get 

func (mr *MockFetchBlockMetadataResultsPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockFetchBlockMetadataResultsPoolMockRecorder) Put 

func (mr *MockFetchBlockMetadataResultsPoolMockRecorder) Put(res interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockFetchBlocksMetadataResults 

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

MockFetchBlocksMetadataResults is a mock of FetchBlocksMetadataResults interface.

func NewMockFetchBlocksMetadataResults 

func NewMockFetchBlocksMetadataResults(ctrl *gomock.Controller) *MockFetchBlocksMetadataResults

NewMockFetchBlocksMetadataResults creates a new mock instance.

func (*MockFetchBlocksMetadataResults) Add 

func (m *MockFetchBlocksMetadataResults) Add(res FetchBlocksMetadataResult)

Add mocks base method.

func (*MockFetchBlocksMetadataResults) Close 

func (m *MockFetchBlocksMetadataResults) Close()

Close mocks base method.

func (*MockFetchBlocksMetadataResults) EXPECT 

func (m *MockFetchBlocksMetadataResults) EXPECT() *MockFetchBlocksMetadataResultsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFetchBlocksMetadataResults) Reset 

func (m *MockFetchBlocksMetadataResults) Reset()

Reset mocks base method.

func (*MockFetchBlocksMetadataResults) Results 

func (m *MockFetchBlocksMetadataResults) Results() []FetchBlocksMetadataResult

Results mocks base method.

type MockFetchBlocksMetadataResultsMockRecorder 

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

MockFetchBlocksMetadataResultsMockRecorder is the mock recorder for MockFetchBlocksMetadataResults.

func (*MockFetchBlocksMetadataResultsMockRecorder) Add 

func (mr *MockFetchBlocksMetadataResultsMockRecorder) Add(res interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockFetchBlocksMetadataResultsMockRecorder) Close 

func (mr *MockFetchBlocksMetadataResultsMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockFetchBlocksMetadataResultsMockRecorder) Reset 

func (mr *MockFetchBlocksMetadataResultsMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset.

func (*MockFetchBlocksMetadataResultsMockRecorder) Results 

func (mr *MockFetchBlocksMetadataResultsMockRecorder) Results() *gomock.Call

Results indicates an expected call of Results.

type MockFetchBlocksMetadataResultsPool 

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

MockFetchBlocksMetadataResultsPool is a mock of FetchBlocksMetadataResultsPool interface.

func NewMockFetchBlocksMetadataResultsPool 

func NewMockFetchBlocksMetadataResultsPool(ctrl *gomock.Controller) *MockFetchBlocksMetadataResultsPool

NewMockFetchBlocksMetadataResultsPool creates a new mock instance.

func (*MockFetchBlocksMetadataResultsPool) EXPECT 

func (m *MockFetchBlocksMetadataResultsPool) EXPECT() *MockFetchBlocksMetadataResultsPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFetchBlocksMetadataResultsPool) Get 

func (m *MockFetchBlocksMetadataResultsPool) Get() FetchBlocksMetadataResults

Get mocks base method.

func (*MockFetchBlocksMetadataResultsPool) Put 

func (m *MockFetchBlocksMetadataResultsPool) Put(res FetchBlocksMetadataResults)

Put mocks base method.

type MockFetchBlocksMetadataResultsPoolMockRecorder 

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

MockFetchBlocksMetadataResultsPoolMockRecorder is the mock recorder for MockFetchBlocksMetadataResultsPool.

func (*MockFetchBlocksMetadataResultsPoolMockRecorder) Get 

func (mr *MockFetchBlocksMetadataResultsPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockFetchBlocksMetadataResultsPoolMockRecorder) Put 

func (mr *MockFetchBlocksMetadataResultsPoolMockRecorder) Put(res interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockFilteredBlocksMetadataIter 

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

MockFilteredBlocksMetadataIter is a mock of FilteredBlocksMetadataIter interface.

func NewMockFilteredBlocksMetadataIter 

func NewMockFilteredBlocksMetadataIter(ctrl *gomock.Controller) *MockFilteredBlocksMetadataIter

NewMockFilteredBlocksMetadataIter creates a new mock instance.

func (*MockFilteredBlocksMetadataIter) Current 

func (m *MockFilteredBlocksMetadataIter) Current() (ident.ID, Metadata)

Current mocks base method.

func (*MockFilteredBlocksMetadataIter) EXPECT 

func (m *MockFilteredBlocksMetadataIter) EXPECT() *MockFilteredBlocksMetadataIterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFilteredBlocksMetadataIter) Err 

func (m *MockFilteredBlocksMetadataIter) Err() error

Err mocks base method.

func (*MockFilteredBlocksMetadataIter) Next 

func (m *MockFilteredBlocksMetadataIter) Next() bool

Next mocks base method.

type MockFilteredBlocksMetadataIterMockRecorder 

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

MockFilteredBlocksMetadataIterMockRecorder is the mock recorder for MockFilteredBlocksMetadataIter.

func (*MockFilteredBlocksMetadataIterMockRecorder) Current 

func (mr *MockFilteredBlocksMetadataIterMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockFilteredBlocksMetadataIterMockRecorder) Err 

func (mr *MockFilteredBlocksMetadataIterMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockFilteredBlocksMetadataIterMockRecorder) Next 

func (mr *MockFilteredBlocksMetadataIterMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

type MockLeaseManager added in v0.10.0 

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

MockLeaseManager is a mock of LeaseManager interface.

func NewMockLeaseManager added in v0.10.0 

func NewMockLeaseManager(ctrl *gomock.Controller) *MockLeaseManager

NewMockLeaseManager creates a new mock instance.

func (*MockLeaseManager) EXPECT added in v0.10.0 

func (m *MockLeaseManager) EXPECT() *MockLeaseManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLeaseManager) OpenLatestLease added in v0.11.0 

func (m *MockLeaseManager) OpenLatestLease(leaser Leaser, descriptor LeaseDescriptor) (LeaseState, error)

OpenLatestLease mocks base method.

func (*MockLeaseManager) OpenLease added in v0.10.0 

func (m *MockLeaseManager) OpenLease(leaser Leaser, descriptor LeaseDescriptor, state LeaseState) error

OpenLease mocks base method.

func (*MockLeaseManager) RegisterLeaser added in v0.10.0 

func (m *MockLeaseManager) RegisterLeaser(leaser Leaser) error

RegisterLeaser mocks base method.

func (*MockLeaseManager) SetLeaseVerifier added in v0.10.2 

func (m *MockLeaseManager) SetLeaseVerifier(leaseVerifier LeaseVerifier) error

SetLeaseVerifier mocks base method.

func (*MockLeaseManager) UnregisterLeaser added in v0.10.0 

func (m *MockLeaseManager) UnregisterLeaser(leaser Leaser) error

UnregisterLeaser mocks base method.

func (*MockLeaseManager) UpdateOpenLeases added in v0.10.0 

func (m *MockLeaseManager) UpdateOpenLeases(descriptor LeaseDescriptor, state LeaseState) (UpdateLeasesResult, error)

UpdateOpenLeases mocks base method.

type MockLeaseManagerMockRecorder added in v0.10.0 

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

MockLeaseManagerMockRecorder is the mock recorder for MockLeaseManager.

func (*MockLeaseManagerMockRecorder) OpenLatestLease added in v0.11.0 

func (mr *MockLeaseManagerMockRecorder) OpenLatestLease(leaser, descriptor interface{}) *gomock.Call

OpenLatestLease indicates an expected call of OpenLatestLease.

func (*MockLeaseManagerMockRecorder) OpenLease added in v0.10.0 

func (mr *MockLeaseManagerMockRecorder) OpenLease(leaser, descriptor, state interface{}) *gomock.Call

OpenLease indicates an expected call of OpenLease.

func (*MockLeaseManagerMockRecorder) RegisterLeaser added in v0.10.0 

func (mr *MockLeaseManagerMockRecorder) RegisterLeaser(leaser interface{}) *gomock.Call

RegisterLeaser indicates an expected call of RegisterLeaser.

func (*MockLeaseManagerMockRecorder) SetLeaseVerifier added in v0.10.2 

func (mr *MockLeaseManagerMockRecorder) SetLeaseVerifier(leaseVerifier interface{}) *gomock.Call

SetLeaseVerifier indicates an expected call of SetLeaseVerifier.

func (*MockLeaseManagerMockRecorder) UnregisterLeaser added in v0.10.0 

func (mr *MockLeaseManagerMockRecorder) UnregisterLeaser(leaser interface{}) *gomock.Call

UnregisterLeaser indicates an expected call of UnregisterLeaser.

func (*MockLeaseManagerMockRecorder) UpdateOpenLeases added in v0.10.0 

func (mr *MockLeaseManagerMockRecorder) UpdateOpenLeases(descriptor, state interface{}) *gomock.Call

UpdateOpenLeases indicates an expected call of UpdateOpenLeases.

type MockLeaseVerifier added in v0.10.0 

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

MockLeaseVerifier is a mock of LeaseVerifier interface.

func NewMockLeaseVerifier added in v0.10.0 

func NewMockLeaseVerifier(ctrl *gomock.Controller) *MockLeaseVerifier

NewMockLeaseVerifier creates a new mock instance.

func (*MockLeaseVerifier) EXPECT added in v0.10.0 

func (m *MockLeaseVerifier) EXPECT() *MockLeaseVerifierMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLeaseVerifier) LatestState added in v0.11.0 

func (m *MockLeaseVerifier) LatestState(descriptor LeaseDescriptor) (LeaseState, error)

LatestState mocks base method.

func (*MockLeaseVerifier) VerifyLease added in v0.10.0 

func (m *MockLeaseVerifier) VerifyLease(descriptor LeaseDescriptor, state LeaseState) error

VerifyLease mocks base method.

type MockLeaseVerifierMockRecorder added in v0.10.0 

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

MockLeaseVerifierMockRecorder is the mock recorder for MockLeaseVerifier.

func (*MockLeaseVerifierMockRecorder) LatestState added in v0.11.0 

func (mr *MockLeaseVerifierMockRecorder) LatestState(descriptor interface{}) *gomock.Call

LatestState indicates an expected call of LatestState.

func (*MockLeaseVerifierMockRecorder) VerifyLease added in v0.10.0 

func (mr *MockLeaseVerifierMockRecorder) VerifyLease(descriptor, state interface{}) *gomock.Call

VerifyLease indicates an expected call of VerifyLease.

type MockLeaser added in v0.10.0 

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

MockLeaser is a mock of Leaser interface.

func NewMockLeaser added in v0.10.0 

func NewMockLeaser(ctrl *gomock.Controller) *MockLeaser

NewMockLeaser creates a new mock instance.

func (*MockLeaser) EXPECT added in v0.10.0 

func (m *MockLeaser) EXPECT() *MockLeaserMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLeaser) UpdateOpenLease added in v0.10.0 

func (m *MockLeaser) UpdateOpenLease(descriptor LeaseDescriptor, state LeaseState) (UpdateOpenLeaseResult, error)

UpdateOpenLease mocks base method.

type MockLeaserMockRecorder added in v0.10.0 

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

MockLeaserMockRecorder is the mock recorder for MockLeaser.

func (*MockLeaserMockRecorder) UpdateOpenLease added in v0.10.0 

func (mr *MockLeaserMockRecorder) UpdateOpenLease(descriptor, state interface{}) *gomock.Call

UpdateOpenLease indicates an expected call of UpdateOpenLease.

type MockOnEvictedFromWiredList 

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

MockOnEvictedFromWiredList is a mock of OnEvictedFromWiredList interface.

func NewMockOnEvictedFromWiredList 

func NewMockOnEvictedFromWiredList(ctrl *gomock.Controller) *MockOnEvictedFromWiredList

NewMockOnEvictedFromWiredList creates a new mock instance.

func (*MockOnEvictedFromWiredList) EXPECT 

func (m *MockOnEvictedFromWiredList) EXPECT() *MockOnEvictedFromWiredListMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOnEvictedFromWiredList) OnEvictedFromWiredList 

func (m *MockOnEvictedFromWiredList) OnEvictedFromWiredList(id ident.ID, blockStart time0.UnixNano)

OnEvictedFromWiredList mocks base method.

type MockOnEvictedFromWiredListMockRecorder 

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

MockOnEvictedFromWiredListMockRecorder is the mock recorder for MockOnEvictedFromWiredList.

func (*MockOnEvictedFromWiredListMockRecorder) OnEvictedFromWiredList 

func (mr *MockOnEvictedFromWiredListMockRecorder) OnEvictedFromWiredList(id, blockStart interface{}) *gomock.Call

OnEvictedFromWiredList indicates an expected call of OnEvictedFromWiredList.

type MockOnReadBlock 

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

MockOnReadBlock is a mock of OnReadBlock interface.

func NewMockOnReadBlock 

func NewMockOnReadBlock(ctrl *gomock.Controller) *MockOnReadBlock

NewMockOnReadBlock creates a new mock instance.

func (*MockOnReadBlock) EXPECT 

func (m *MockOnReadBlock) EXPECT() *MockOnReadBlockMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOnReadBlock) OnReadBlock 

func (m *MockOnReadBlock) OnReadBlock(b DatabaseBlock)

OnReadBlock mocks base method.

type MockOnReadBlockMockRecorder 

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

MockOnReadBlockMockRecorder is the mock recorder for MockOnReadBlock.

func (*MockOnReadBlockMockRecorder) OnReadBlock 

func (mr *MockOnReadBlockMockRecorder) OnReadBlock(b interface{}) *gomock.Call

OnReadBlock indicates an expected call of OnReadBlock.

type MockOnRetrieveBlock 

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

MockOnRetrieveBlock is a mock of OnRetrieveBlock interface.

func NewMockOnRetrieveBlock 

func NewMockOnRetrieveBlock(ctrl *gomock.Controller) *MockOnRetrieveBlock

NewMockOnRetrieveBlock creates a new mock instance.

func (*MockOnRetrieveBlock) EXPECT 

func (m *MockOnRetrieveBlock) EXPECT() *MockOnRetrieveBlockMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOnRetrieveBlock) OnRetrieveBlock 

func (m *MockOnRetrieveBlock) OnRetrieveBlock(id ident.ID, tags ident.TagIterator, startTime time0.UnixNano, segment ts.Segment, nsCtx namespace.Context)

OnRetrieveBlock mocks base method.

type MockOnRetrieveBlockMockRecorder 

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

MockOnRetrieveBlockMockRecorder is the mock recorder for MockOnRetrieveBlock.

func (*MockOnRetrieveBlockMockRecorder) OnRetrieveBlock 

func (mr *MockOnRetrieveBlockMockRecorder) OnRetrieveBlock(id, tags, startTime, segment, nsCtx interface{}) *gomock.Call

OnRetrieveBlock indicates an expected call of OnRetrieveBlock.

type MockOptions 

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

MockOptions is a mock of Options interface.

func NewMockOptions 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance.

func (*MockOptions) BytesPool 

func (m *MockOptions) BytesPool() pool.CheckedBytesPool

BytesPool mocks base method.

func (*MockOptions) ClockOptions 

func (m *MockOptions) ClockOptions() clock.Options

ClockOptions mocks base method.

func (*MockOptions) CloseContextWorkers 

func (m *MockOptions) CloseContextWorkers() sync.WorkerPool

CloseContextWorkers mocks base method.

func (*MockOptions) ContextPool 

func (m *MockOptions) ContextPool() context.Pool

ContextPool mocks base method.

func (*MockOptions) DatabaseBlockAllocSize 

func (m *MockOptions) DatabaseBlockAllocSize() int

DatabaseBlockAllocSize mocks base method.

func (*MockOptions) DatabaseBlockPool 

func (m *MockOptions) DatabaseBlockPool() DatabaseBlockPool

DatabaseBlockPool mocks base method.

func (*MockOptions) EXPECT 

func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOptions) EncoderPool 

func (m *MockOptions) EncoderPool() encoding.EncoderPool

EncoderPool mocks base method.

func (*MockOptions) MultiReaderIteratorPool 

func (m *MockOptions) MultiReaderIteratorPool() encoding.MultiReaderIteratorPool

MultiReaderIteratorPool mocks base method.

func (*MockOptions) ReaderIteratorPool 

func (m *MockOptions) ReaderIteratorPool() encoding.ReaderIteratorPool

ReaderIteratorPool mocks base method.

func (*MockOptions) SegmentReaderPool 

func (m *MockOptions) SegmentReaderPool() xio.SegmentReaderPool

SegmentReaderPool mocks base method.

func (*MockOptions) SetBytesPool 

func (m *MockOptions) SetBytesPool(value pool.CheckedBytesPool) Options

SetBytesPool mocks base method.

func (*MockOptions) SetClockOptions 

func (m *MockOptions) SetClockOptions(value clock.Options) Options

SetClockOptions mocks base method.

func (*MockOptions) SetCloseContextWorkers 

func (m *MockOptions) SetCloseContextWorkers(value sync.WorkerPool) Options

SetCloseContextWorkers mocks base method.

func (*MockOptions) SetContextPool 

func (m *MockOptions) SetContextPool(value context.Pool) Options

SetContextPool mocks base method.

func (*MockOptions) SetDatabaseBlockAllocSize 

func (m *MockOptions) SetDatabaseBlockAllocSize(value int) Options

SetDatabaseBlockAllocSize mocks base method.

func (*MockOptions) SetDatabaseBlockPool 

func (m *MockOptions) SetDatabaseBlockPool(value DatabaseBlockPool) Options

SetDatabaseBlockPool mocks base method.

func (*MockOptions) SetEncoderPool 

func (m *MockOptions) SetEncoderPool(value encoding.EncoderPool) Options

SetEncoderPool mocks base method.

func (*MockOptions) SetMultiReaderIteratorPool 

func (m *MockOptions) SetMultiReaderIteratorPool(value encoding.MultiReaderIteratorPool) Options

SetMultiReaderIteratorPool mocks base method.

func (*MockOptions) SetReaderIteratorPool 

func (m *MockOptions) SetReaderIteratorPool(value encoding.ReaderIteratorPool) Options

SetReaderIteratorPool mocks base method.

func (*MockOptions) SetSegmentReaderPool 

func (m *MockOptions) SetSegmentReaderPool(value xio.SegmentReaderPool) Options

SetSegmentReaderPool mocks base method.

func (*MockOptions) SetWiredList 

func (m *MockOptions) SetWiredList(value *WiredList) Options

SetWiredList mocks base method.

func (*MockOptions) WiredList 

func (m *MockOptions) WiredList() *WiredList

WiredList mocks base method.

type MockOptionsMockRecorder 

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

MockOptionsMockRecorder is the mock recorder for MockOptions.

func (*MockOptionsMockRecorder) BytesPool 

func (mr *MockOptionsMockRecorder) BytesPool() *gomock.Call

BytesPool indicates an expected call of BytesPool.

func (*MockOptionsMockRecorder) ClockOptions 

func (mr *MockOptionsMockRecorder) ClockOptions() *gomock.Call

ClockOptions indicates an expected call of ClockOptions.

func (*MockOptionsMockRecorder) CloseContextWorkers 

func (mr *MockOptionsMockRecorder) CloseContextWorkers() *gomock.Call

CloseContextWorkers indicates an expected call of CloseContextWorkers.

func (*MockOptionsMockRecorder) ContextPool 

func (mr *MockOptionsMockRecorder) ContextPool() *gomock.Call

ContextPool indicates an expected call of ContextPool.

func (*MockOptionsMockRecorder) DatabaseBlockAllocSize 

func (mr *MockOptionsMockRecorder) DatabaseBlockAllocSize() *gomock.Call

DatabaseBlockAllocSize indicates an expected call of DatabaseBlockAllocSize.

func (*MockOptionsMockRecorder) DatabaseBlockPool 

func (mr *MockOptionsMockRecorder) DatabaseBlockPool() *gomock.Call

DatabaseBlockPool indicates an expected call of DatabaseBlockPool.

func (*MockOptionsMockRecorder) EncoderPool 

func (mr *MockOptionsMockRecorder) EncoderPool() *gomock.Call

EncoderPool indicates an expected call of EncoderPool.

func (*MockOptionsMockRecorder) MultiReaderIteratorPool 

func (mr *MockOptionsMockRecorder) MultiReaderIteratorPool() *gomock.Call

MultiReaderIteratorPool indicates an expected call of MultiReaderIteratorPool.

func (*MockOptionsMockRecorder) ReaderIteratorPool 

func (mr *MockOptionsMockRecorder) ReaderIteratorPool() *gomock.Call

ReaderIteratorPool indicates an expected call of ReaderIteratorPool.

func (*MockOptionsMockRecorder) SegmentReaderPool 

func (mr *MockOptionsMockRecorder) SegmentReaderPool() *gomock.Call

SegmentReaderPool indicates an expected call of SegmentReaderPool.

func (*MockOptionsMockRecorder) SetBytesPool 

func (mr *MockOptionsMockRecorder) SetBytesPool(value interface{}) *gomock.Call

SetBytesPool indicates an expected call of SetBytesPool.

func (*MockOptionsMockRecorder) SetClockOptions 

func (mr *MockOptionsMockRecorder) SetClockOptions(value interface{}) *gomock.Call

SetClockOptions indicates an expected call of SetClockOptions.

func (*MockOptionsMockRecorder) SetCloseContextWorkers 

func (mr *MockOptionsMockRecorder) SetCloseContextWorkers(value interface{}) *gomock.Call

SetCloseContextWorkers indicates an expected call of SetCloseContextWorkers.

func (*MockOptionsMockRecorder) SetContextPool 

func (mr *MockOptionsMockRecorder) SetContextPool(value interface{}) *gomock.Call

SetContextPool indicates an expected call of SetContextPool.

func (*MockOptionsMockRecorder) SetDatabaseBlockAllocSize 

func (mr *MockOptionsMockRecorder) SetDatabaseBlockAllocSize(value interface{}) *gomock.Call

SetDatabaseBlockAllocSize indicates an expected call of SetDatabaseBlockAllocSize.

func (*MockOptionsMockRecorder) SetDatabaseBlockPool 

func (mr *MockOptionsMockRecorder) SetDatabaseBlockPool(value interface{}) *gomock.Call

SetDatabaseBlockPool indicates an expected call of SetDatabaseBlockPool.

func (*MockOptionsMockRecorder) SetEncoderPool 

func (mr *MockOptionsMockRecorder) SetEncoderPool(value interface{}) *gomock.Call

SetEncoderPool indicates an expected call of SetEncoderPool.

func (*MockOptionsMockRecorder) SetMultiReaderIteratorPool 

func (mr *MockOptionsMockRecorder) SetMultiReaderIteratorPool(value interface{}) *gomock.Call

SetMultiReaderIteratorPool indicates an expected call of SetMultiReaderIteratorPool.

func (*MockOptionsMockRecorder) SetReaderIteratorPool 

func (mr *MockOptionsMockRecorder) SetReaderIteratorPool(value interface{}) *gomock.Call

SetReaderIteratorPool indicates an expected call of SetReaderIteratorPool.

func (*MockOptionsMockRecorder) SetSegmentReaderPool 

func (mr *MockOptionsMockRecorder) SetSegmentReaderPool(value interface{}) *gomock.Call

SetSegmentReaderPool indicates an expected call of SetSegmentReaderPool.

func (*MockOptionsMockRecorder) SetWiredList 

func (mr *MockOptionsMockRecorder) SetWiredList(value interface{}) *gomock.Call

SetWiredList indicates an expected call of SetWiredList.

func (*MockOptionsMockRecorder) WiredList 

func (mr *MockOptionsMockRecorder) WiredList() *gomock.Call

WiredList indicates an expected call of WiredList.

type MockStreamedWideEntry added in v1.0.1 

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

MockStreamedWideEntry is a mock of StreamedWideEntry interface.

func NewMockStreamedWideEntry added in v1.0.1 

func NewMockStreamedWideEntry(ctrl *gomock.Controller) *MockStreamedWideEntry

NewMockStreamedWideEntry creates a new mock instance.

func (*MockStreamedWideEntry) EXPECT added in v1.0.1 

func (m *MockStreamedWideEntry) EXPECT() *MockStreamedWideEntryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStreamedWideEntry) Finalize added in v1.0.1 

func (m *MockStreamedWideEntry) Finalize()

Finalize mocks base method.

func (*MockStreamedWideEntry) RetrieveWideEntry added in v1.0.1 

func (m *MockStreamedWideEntry) RetrieveWideEntry() (xio.WideEntry, error)

RetrieveWideEntry mocks base method.

type MockStreamedWideEntryMockRecorder added in v1.0.1 

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

MockStreamedWideEntryMockRecorder is the mock recorder for MockStreamedWideEntry.

func (*MockStreamedWideEntryMockRecorder) Finalize added in v1.0.1 

func (mr *MockStreamedWideEntryMockRecorder) Finalize() *gomock.Call

Finalize indicates an expected call of Finalize.

func (*MockStreamedWideEntryMockRecorder) RetrieveWideEntry added in v1.0.1 

func (mr *MockStreamedWideEntryMockRecorder) RetrieveWideEntry() *gomock.Call

RetrieveWideEntry indicates an expected call of RetrieveWideEntry.

type MockdatabaseBlock 

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

MockdatabaseBlock is a mock of databaseBlock interface.

func NewMockdatabaseBlock 

func NewMockdatabaseBlock(ctrl *gomock.Controller) *MockdatabaseBlock

NewMockdatabaseBlock creates a new mock instance.

func (*MockdatabaseBlock) EXPECT 

func (m *MockdatabaseBlock) EXPECT() *MockdatabaseBlockMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockdatabaseBlockMockRecorder 

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

MockdatabaseBlockMockRecorder is the mock recorder for MockdatabaseBlock.

type NewDatabaseBlockFn 

type NewDatabaseBlockFn func() DatabaseBlock

NewDatabaseBlockFn creates a new database block.

type NewDatabaseBlockRetrieverFn 

type NewDatabaseBlockRetrieverFn func(
	md namespace.Metadata,
	shardSet sharding.ShardSet,
) (DatabaseBlockRetriever, error)

NewDatabaseBlockRetrieverFn is a method for constructing new database block retrievers

type NoopLeaseManager added in v0.10.2 

type NoopLeaseManager struct{}

NoopLeaseManager is a no-op implementation of LeaseManager.

func (*NoopLeaseManager) OpenLatestLease added in v0.11.0 

func (n *NoopLeaseManager) OpenLatestLease(
	leaser Leaser,
	descriptor LeaseDescriptor,
) (LeaseState, error)

func (*NoopLeaseManager) OpenLease added in v0.10.2 

func (n *NoopLeaseManager) OpenLease(
	leaser Leaser,
	descriptor LeaseDescriptor,
	state LeaseState,
) error

func (*NoopLeaseManager) RegisterLeaser added in v0.10.2 

func (n *NoopLeaseManager) RegisterLeaser(leaser Leaser) error

func (*NoopLeaseManager) SetLeaseVerifier added in v0.10.2 

func (n *NoopLeaseManager) SetLeaseVerifier(leaseVerifier LeaseVerifier) error

func (*NoopLeaseManager) UnregisterLeaser added in v0.10.2 

func (n *NoopLeaseManager) UnregisterLeaser(leaser Leaser) error

func (*NoopLeaseManager) UpdateOpenLeases added in v0.10.2 

func (n *NoopLeaseManager) UpdateOpenLeases(
	descriptor LeaseDescriptor,
	state LeaseState,
) (UpdateLeasesResult, error)

type OnEvictedFromWiredList 

type OnEvictedFromWiredList interface {
	// OnEvictedFromWiredList is called when a block is evicted from the wired list.
	OnEvictedFromWiredList(id ident.ID, blockStart xtime.UnixNano)
}

OnEvictedFromWiredList is implemented by a struct that wants to be notified when a block is evicted from the wired list.

type OnReadBlock 

type OnReadBlock interface {
	OnReadBlock(b DatabaseBlock)
}

OnReadBlock is an interface to callback on when a block is read.

type OnRetrieveBlock 

type OnRetrieveBlock interface {
	OnRetrieveBlock(
		id ident.ID,
		tags ident.TagIterator,
		startTime xtime.UnixNano,
		segment ts.Segment,
		nsCtx namespace.Context,
	)
}

OnRetrieveBlock is an interface to callback on when a block is retrieved.

type OnRetrieveBlockFn 

type OnRetrieveBlockFn func(
	id ident.ID,
	tags ident.TagIterator,
	startTime xtime.UnixNano,
	segment ts.Segment,
	nsCtx namespace.Context,
)

OnRetrieveBlockFn is a function implementation for the OnRetrieveBlock interface.

func (OnRetrieveBlockFn) OnRetrieveBlock 

func (fn OnRetrieveBlockFn) OnRetrieveBlock(
	id ident.ID,
	tags ident.TagIterator,
	startTime xtime.UnixNano,
	segment ts.Segment,
	nsCtx namespace.Context,
)

OnRetrieveBlock implements the OnRetrieveBlock interface.

type Options 

type Options interface {
	// SetClockOptions sets the clock options
	SetClockOptions(value clock.Options) Options

	// ClockOptions returns the clock options
	ClockOptions() clock.Options

	// SetDatabaseBlockAllocSize sets the databaseBlockAllocSize
	SetDatabaseBlockAllocSize(value int) Options

	// DatabaseBlockAllocSize returns the databaseBlockAllocSize
	DatabaseBlockAllocSize() int

	// SetCloseContextWorkers sets the workers for closing contexts
	SetCloseContextWorkers(value xsync.WorkerPool) Options

	// CloseContextWorkers returns the workers for closing contexts
	CloseContextWorkers() xsync.WorkerPool

	// SetDatabaseBlockPool sets the databaseBlockPool
	SetDatabaseBlockPool(value DatabaseBlockPool) Options

	// DatabaseBlockPool returns the databaseBlockPool
	DatabaseBlockPool() DatabaseBlockPool

	// SetContextPool sets the contextPool
	SetContextPool(value context.Pool) Options

	// ContextPool returns the contextPool
	ContextPool() context.Pool

	// SetEncoderPool sets the contextPool
	SetEncoderPool(value encoding.EncoderPool) Options

	// EncoderPool returns the contextPool
	EncoderPool() encoding.EncoderPool

	// SetReaderIteratorPool sets the readerIteratorPool
	SetReaderIteratorPool(value encoding.ReaderIteratorPool) Options

	// ReaderIteratorPool returns the readerIteratorPool
	ReaderIteratorPool() encoding.ReaderIteratorPool

	// SetMultiReaderIteratorPool sets the multiReaderIteratorPool
	SetMultiReaderIteratorPool(value encoding.MultiReaderIteratorPool) Options

	// MultiReaderIteratorPool returns the multiReaderIteratorPool
	MultiReaderIteratorPool() encoding.MultiReaderIteratorPool

	// SetSegmentReaderPool sets the contextPool
	SetSegmentReaderPool(value xio.SegmentReaderPool) Options

	// SegmentReaderPool returns the contextPool
	SegmentReaderPool() xio.SegmentReaderPool

	// SetBytesPool sets the bytesPool
	SetBytesPool(value pool.CheckedBytesPool) Options

	// BytesPool returns the bytesPool
	BytesPool() pool.CheckedBytesPool

	// SetWiredList sets the database block wired list
	SetWiredList(value *WiredList) Options

	// WiredList returns the database block wired list
	WiredList() *WiredList
}

Options represents the options for a database block

func NewOptions 

func NewOptions() Options

NewOptions creates new database block options

type ReplicaMetadata 

type ReplicaMetadata struct {
	Metadata

	Host topology.Host
}

ReplicaMetadata captures block metadata along with corresponding peer identifier for a single replica of a block

type RetrievableBlockMetadata 

type RetrievableBlockMetadata struct {
	ID       ident.ID
	Length   int
	Checksum uint32
}

RetrievableBlockMetadata describes a retrievable block.

type StreamedWideEntry added in v1.0.1 

type StreamedWideEntry interface {
	resource.Finalizer

	// RetrieveWideEntry retrieves the collected wide entry.
	RetrieveWideEntry() (xio.WideEntry, error)
}

StreamedWideEntry yields a xio.WideEntry value asynchronously, and any errors encountered during execution. 

var EmptyStreamedWideEntry StreamedWideEntry = emptyWideEntry{}

EmptyStreamedWideEntry is an empty streamed wide entry.

type UpdateLeasesResult added in v0.10.0 

type UpdateLeasesResult struct {
	LeasersUpdatedLease int
	LeasersNoOpenLease  int
}

UpdateLeasesResult is the result of a call to update leases.

type UpdateOpenLeaseResult added in v0.10.0 

type UpdateOpenLeaseResult uint

UpdateOpenLeaseResult is the result of processing an update lease. 

const (
	// UpdateOpenLease is used to communicate a lease updated successfully.
	UpdateOpenLease UpdateOpenLeaseResult = iota
	// NoOpenLease is used to communicate there is no related open lease.
	NoOpenLease
)

type WiredList 

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

WiredList is a database block wired list.

func NewWiredList 

func NewWiredList(opts WiredListOptions) *WiredList

NewWiredList returns a new database block wired list.

func (*WiredList) BlockingUpdate added in v0.4.2 

func (l *WiredList) BlockingUpdate(v DatabaseBlock)

BlockingUpdate places the block into the channel of blocks which are waiting to notify the wired list that they were accessed. All updates must be processed through this channel to force synchronization.

We use a channel and a background processing goroutine to reduce blocking / lock contention.

func (*WiredList) NonBlockingUpdate added in v0.4.2 

func (l *WiredList) NonBlockingUpdate(v DatabaseBlock) bool

NonBlockingUpdate will attempt to put the block in the events channel, but will not block if the channel is full. Used in cases where a blocking update could trigger deadlock with the WiredList itself.

func (*WiredList) SetRuntimeOptions 

func (l *WiredList) SetRuntimeOptions(value runtime.Options)

SetRuntimeOptions sets the current runtime options to be consumed by the wired list

func (*WiredList) Start 

func (l *WiredList) Start() error

Start starts processing the wired list

func (*WiredList) Stop 

func (l *WiredList) Stop() error

Stop stops processing the wired list

type WiredListOptions added in v0.4.2 

type WiredListOptions struct {
	RuntimeOptionsManager runtime.OptionsManager
	InstrumentOptions     instrument.Options
	ClockOptions          clock.Options
	EventsChannelSize     int
}

WiredListOptions is the options struct for the WiredList constructor.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.