faketikv

Documentation

Index

• type Client
  • func NewClient(pdAddr string, tag string) (Client, <-chan *pdpb.RegionHeartbeatResponse, error)
• type ClusterInfo
  • func NewClusterInfo(pdAddr string, conf *cases.Conf) (*ClusterInfo, error)
  • func (c *ClusterInfo) AddTask(task Task)
  • func (c *ClusterInfo) GetBootstrapInfo() (*metapb.Store, *metapb.Region, error)
• type Config
• type Driver
  • func NewDriver(addr string, confName string) *Driver
  • func (d *Driver) AddNode(id uint64)
  • func (d *Driver) Check() bool
  • func (d *Driver) DeleteNode()
  • func (d *Driver) Prepare() error
  • func (d *Driver) Stop()
  • func (d *Driver) Tick()
  • func (d *Driver) TickCount() int64
• type Event
• type EventRunner
  • func NewEventRunner(events []cases.EventInner) *EventRunner
  • func (er *EventRunner) Tick(tick int64, cs *ClusterInfo)
• type Node
  • func NewNode(id uint64, addr string, pdAddr string) (*Node, error)
  • func (n *Node) AddTask(task Task)
  • func (n *Node) GetState() NodeState
  • func (n *Node) Start() error
  • func (n *Node) Stop()
  • func (n *Node) Tick()
• type NodeState
• type ReadFlowOnRegion
  • func (w *ReadFlowOnRegion) Run(tick int64, cs *ClusterInfo) bool
• type Task
• type WriteFlowOnRegion
  • func (w *WriteFlowOnRegion) Run(tick int64, cs *ClusterInfo) bool
• type WriteFlowOnSpot
  • func (w *WriteFlowOnSpot) Run(tick int64, cs *ClusterInfo) bool

Types

type Client

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()
}

Client is a PD (Placement Driver) client. It should not be used after calling Close().

func NewClient

func NewClient(pdAddr string, tag string) (Client, <-chan *pdpb.RegionHeartbeatResponse, error)

NewClient creates a PD client.

type ClusterInfo

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

ClusterInfo records all cluster information.

func NewClusterInfo

func NewClusterInfo(pdAddr string, conf *cases.Conf) (*ClusterInfo, error)

NewClusterInfo creates the initialized cluster with config.

func (*ClusterInfo) AddTask

func (c *ClusterInfo) AddTask(task Task)

AddTask adds task in specify node.

func (*ClusterInfo) GetBootstrapInfo

func (c *ClusterInfo) GetBootstrapInfo() (*metapb.Store, *metapb.Region, error)

GetBootstrapInfo returns a valid bootstrap store and region.

type Config

type Config struct {
}

Config is the faketikv configuration.

type Driver

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

Driver promotes the cluster status change.

func NewDriver

func NewDriver(addr string, confName string) *Driver

NewDriver returns a driver.

func (*Driver) AddNode

func (d *Driver) AddNode(id uint64)

AddNode adds new node.

func (*Driver) Check

func (d *Driver) Check() bool

Check checks if the simulation is completed.

func (*Driver) DeleteNode

func (d *Driver) DeleteNode()

DeleteNode deletes a node.

func (*Driver) Prepare

func (d *Driver) Prepare() error

Prepare initializes cluster information, bootstraps cluster and starts nodes.

func (*Driver) Stop

func (d *Driver) Stop()

Stop stops all nodes.

func (*Driver) Tick

func (d *Driver) Tick()

Tick invokes nodes' Tick.

func (*Driver) TickCount

func (d *Driver) TickCount() int64

TickCount returns the simulation's tick count.

type Event

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

Event that affect the status of the cluster

type EventRunner

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

EventRunner includes all events

func NewEventRunner

func NewEventRunner(events []cases.EventInner) *EventRunner

NewEventRunner news a event runner

func (*EventRunner) Tick

func (er *EventRunner) Tick(tick int64, cs *ClusterInfo)

Tick ticks the event run

type Node

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

Node simulates a TiKV.

func NewNode

func NewNode(id uint64, addr string, pdAddr string) (*Node, error)

NewNode returns a Node.

func (*Node) AddTask

func (n *Node) AddTask(task Task)

AddTask adds task in this node.

func (*Node) GetState

func (n *Node) GetState() NodeState

GetState returns current node state.

func (*Node) Start

func (n *Node) Start() error

Start starts the node.

func (*Node) Stop

func (n *Node) Stop()

Stop stops this node.

func (*Node) Tick

func (n *Node) Tick()

Tick steps node status change.

type NodeState

type NodeState int

NodeState node's state.

const (
	Up NodeState = iota
	Down
	LossConnect
	Block
)

some state

type ReadFlowOnRegion

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

ReadFlowOnRegion reads bytes in some region

func (*ReadFlowOnRegion) Run

func (w *ReadFlowOnRegion) Run(tick int64, cs *ClusterInfo) bool

Run implements the event interface

type Task

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

Task running in node.

type WriteFlowOnRegion

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

WriteFlowOnRegion writes bytes in some region

func (*WriteFlowOnRegion) Run

func (w *WriteFlowOnRegion) Run(tick int64, cs *ClusterInfo) bool

Run implements the event interface

type WriteFlowOnSpot

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

WriteFlowOnSpot writes bytes in some range

func (*WriteFlowOnSpot) Run

func (w *WriteFlowOnSpot) Run(tick int64, cs *ClusterInfo) bool

Run implements the event interface