faketikv

type Client interface {
	GetClusterID(ctx context.Context) uint64
	AllocID(ctx context.Context) (uint64, error)
	Bootstrap(ctx context.Context, store *metapb.Store, region *metapb.Region) error
	PutStore(ctx context.Context, store *metapb.Store) error
	StoreHeartbeat(ctx context.Context, stats *pdpb.StoreStats) error
	RegionHeartbeat(ctx context.Context, region *core.RegionInfo) error
	Close()
}

type ClusterInfo struct {
	*core.RegionsInfo
	Nodes map[uint64]*Node
	// contains filtered or unexported fields
}

type Config struct {
}

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

type Event interface {
	Run(tick int64, cs *ClusterInfo) bool
}

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

type Node struct {
	*metapb.Store
	sync.RWMutex
	// contains filtered or unexported fields
}

type NodeState int

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

type Task interface {
	Desc() string
	RegionID() uint64
	Step(cluster *ClusterInfo)
	TargetStoreID() uint64
	IsFinished() bool
}

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

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