dnservice

Documentation

Index

• Constants
• func Check(idAlloc util.IDAllocator, cfg hakeeper.Config, cluster pb.ClusterInfo, ...) []*operator.Operator
• type ShardMapper

Constants

const (
	DnStoreCapacity = 32
)

Functions

func Check

func Check(
	idAlloc util.IDAllocator,
	cfg hakeeper.Config,
	cluster pb.ClusterInfo,
	dnState pb.DNState,
	user pb.TaskTableUser,
	currTick uint64,
) []*operator.Operator

Check checks dn state and generate operator for expired dn store. The less shard ID, the higher priority. NB: the returned order should be deterministic.

Types

type ShardMapper

type ShardMapper interface {
	// contains filtered or unexported methods
}

ShardMapper used to get log shard ID for dn shard