simulator

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

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 Connection struct {
	Nodes map[uint64]*Node
	// contains filtered or unexported fields
}

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

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

type Event interface {
	Run(raft *RaftEngine, tickCount int64) bool
}

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

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

type RaftEngine struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

type SimConfig struct {
	// tick
	SimTickInterval typeutil.Duration `toml:"sim-tick-interval"`
	// store
	StoreCapacityGB    uint64 `toml:"store-capacity"`
	StoreAvailableGB   uint64 `toml:"store-available"`
	StoreIOMBPerSecond int64  `toml:"store-io-per-second"`
	StoreVersion       string `toml:"store-version"`
	// server
	ServerConfig *config.Config `toml:"server"`
}

type Task interface {
	Desc() string
	RegionID() uint64
	Step(r *RaftEngine)
	IsFinished() bool
}

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

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