repair

type CopyFn func(ident.ID) ident.ID

type EqualsFn func(ident.ID, ident.ID) bool

type FinalizeFn func(ident.ID)

type HashFn func(ident.ID) MapHash

type HostBlockMetadata struct {
	Host     topology.Host
	Size     int64
	Checksum *uint32
}

type HostBlockMetadataSlice interface {
	// Add adds the metadata to the slice
	Add(metadata HostBlockMetadata)

	// Metadata returns the metadata slice
	Metadata() []HostBlockMetadata

	// Reset resets the metadata slice
	Reset()

	// Close performs cleanup
	Close()
}

type HostBlockMetadataSlicePool interface {
	// Get returns a hostBlockMetadata slice
	Get() HostBlockMetadataSlice

	// Put puts a hostBlockMetadata slice back to pool
	Put(m HostBlockMetadataSlice)
}

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

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

type MapHash uint64

type MapOptions struct {
	InitialSize int
	KeyCopyPool pool.BytesPool
}

type MetadataComparisonResult struct {
	// NumSeries returns the total number of series
	NumSeries int64

	// NumBlocks returns the total number of blocks
	NumBlocks int64

	// SizeResult returns the size differences
	SizeDifferences ReplicaSeriesMetadata

	// ChecksumDifferences returns the checksum differences
	ChecksumDifferences ReplicaSeriesMetadata
}

type Options interface {
	// SetAdminClient sets the admin client
	SetAdminClient(value client.AdminClient) Options

	// AdminClient returns the admin client
	AdminClient() client.AdminClient

	// SetRepairConsistencyLevel sets the repair read level consistency
	// for which to repair shards with
	SetRepairConsistencyLevel(value topology.ReadConsistencyLevel) Options

	// RepairConsistencyLevel returns the repair read level consistency
	// for which to repair shards with
	RepairConsistencyLevel() topology.ReadConsistencyLevel

	// SetRepairShardConcurrency sets the concurrency in which to repair shards with
	SetRepairShardConcurrency(value int) Options

	// RepairShardConcurrency returns the concurrency in which to repair shards with
	RepairShardConcurrency() int

	// SetRepairInterval sets the repair interval
	SetRepairInterval(value time.Duration) Options

	// RepairInterval returns the repair interval
	RepairInterval() time.Duration

	// SetRepairTimeOffset sets the repair time offset
	SetRepairTimeOffset(value time.Duration) Options

	// RepairTimeOffset returns the repair time offset
	RepairTimeOffset() time.Duration

	// SetRepairJitter sets the repair time jitter
	SetRepairTimeJitter(value time.Duration) Options

	// RepairTimeJitter returns the repair time jitter
	RepairTimeJitter() time.Duration

	// SetRepairCheckInterval sets the repair check interval
	SetRepairCheckInterval(value time.Duration) Options

	// RepairCheckInterval returns the repair check interval
	RepairCheckInterval() time.Duration

	// SetRepairThrottle sets the repair throttle
	SetRepairThrottle(value time.Duration) Options

	// RepairThrottle returns the repair throttle
	RepairThrottle() time.Duration

	// SetRepairMaxRetries sets the max number of retries for a block start
	SetRepairMaxRetries(value int) Options

	// MaxRepairRetries returns the max number of retries for a block start
	RepairMaxRetries() int

	// SetHostBlockMetadataSlicePool sets the hostBlockMetadataSlice pool
	SetHostBlockMetadataSlicePool(value HostBlockMetadataSlicePool) Options

	// HostBlockMetadataSlicePool returns the hostBlockMetadataSlice pool
	HostBlockMetadataSlicePool() HostBlockMetadataSlicePool

	// Validate checks if the options are valid
	Validate() error
}

type ReplicaBlockMetadata interface {
	// Start is the start time of a block
	Start() time.Time

	// Metadata returns the metadata from all hosts
	Metadata() []HostBlockMetadata

	// Add adds a metadata from a host
	Add(metadata HostBlockMetadata)

	// Close performs cleanup
	Close()
}

type ReplicaBlocksMetadata interface {
	// NumBlocks returns the total number of blocks
	NumBlocks() int64

	// Blocks returns the blocks metadata
	Blocks() map[xtime.UnixNano]ReplicaBlockMetadata

	// Add adds a block metadata
	Add(block ReplicaBlockMetadata)

	// GetOrAdd returns the blocks metadata for a start time, creating one if it doesn't exist
	GetOrAdd(start time.Time, p HostBlockMetadataSlicePool) ReplicaBlockMetadata

	// Close performs cleanup
	Close()
}

type ReplicaMetadataComparer interface {
	// AddLocalMetadata adds metadata from local host
	AddLocalMetadata(origin topology.Host, localIter block.FilteredBlocksMetadataIter) error

	// AddPeerMetadata adds metadata from peers
	AddPeerMetadata(peerIter client.PeerBlockMetadataIter) error

	// Compare returns the metadata differences between local host and peers
	Compare() MetadataComparisonResult

	// Finalize performs cleanup during close
	Finalize()
}

type ReplicaSeriesBlocksMetadata struct {
	ID       ident.ID
	Metadata ReplicaBlocksMetadata
}

type ReplicaSeriesMetadata interface {
	// NumSeries returns the total number of series
	NumSeries() int64

	// NumBlocks returns the total number of blocks
	NumBlocks() int64

	// Series returns the series metadata
	Series() *Map

	// GetOrAdd returns the series metadata for an id, creating one if it doesn't exist
	GetOrAdd(id ident.ID) ReplicaBlocksMetadata

	// Close performs cleanup
	Close()
}

type SetUnsafeOptions struct {
	NoCopyKey     bool
	NoFinalizeKey bool
}