shardctl

Documentation

Index

• Constants
• type Clerk
  • func MakeClerk(servers []pb.ShardctlClient) *Clerk
  • func (ck *Clerk) Join(servers []*pb.Group)
  • func (ck *Clerk) Leave(gids []int64)
  • func (ck *Clerk) Move(shard int64, gid int64)
  • func (ck *Clerk) Query(num int64) *pb.Config
• type ClientConfig
• type Config
  • func NewConfig(pbConfig *pb.Config) *Config
  • func (cfg *Config) Gids() []int64
  • func (cfg *Config) Join(newGroups []*pb.Group)
  • func (cfg *Config) Leave(gids []int64)
  • func (cfg *Config) Reshard()
• type OpType
• type ShardCtl
  • func StartServer(servers []string, me uint64, persister *raft.Persister) *ShardCtl
  • func (sc *ShardCtl) Execute(ctx context.Context, args *pb.Args) (reply *pb.Reply, err error)
  • func (sc *ShardCtl) Kill()
  • func (sc *ShardCtl) Monitor(action func(), timeout time.Duration)

Constants

const (
	ErrWrongLeader string = "ErrWrongLeader"
	OK             string = "OK"
)

const NShards = 1024

const RequestTimeout = 5 * 200 * time.Millisecond

Types

type Clerk

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

func MakeClerk

func MakeClerk(servers []pb.ShardctlClient) *Clerk

func (*Clerk) Join

func (ck *Clerk) Join(servers []*pb.Group)

func (*Clerk) Leave

func (ck *Clerk) Leave(gids []int64)

func (*Clerk) Move

func (ck *Clerk) Move(shard int64, gid int64)

func (*Clerk) Query

func (ck *Clerk) Query(num int64) *pb.Config

type ClientConfig

type ClientConfig struct {
	RequestTimeout time.Duration
	RetryIntervals []time.Duration

	// Retry infinitely when Retries <0
	Retries int
}

type Config

type Config struct {
	Num    int64
	Shards [NShards]int64
	Groups map[int64]*pb.Group
}

func NewConfig

func NewConfig(pbConfig *pb.Config) *Config

func (*Config) Gids

func (cfg *Config) Gids() []int64

func (*Config) Join

func (cfg *Config) Join(newGroups []*pb.Group)

func (*Config) Leave

func (cfg *Config) Leave(gids []int64)

func (*Config) Reshard

func (cfg *Config) Reshard()

type OpType

type OpType string

type ShardCtl

type ShardCtl struct {
	SessionMap *session.SessionMap

	AppliedIndex uint64
	// contains filtered or unexported fields
}

func StartServer

func StartServer(servers []string, me uint64, persister *raft.Persister) *ShardCtl

StartServer servers[] contains the ports of the set of servers that will cooperate via Raft to form the fault-tolerant shardctl service. "me" is the index of the current server in servers[].

func (*ShardCtl) Execute

func (sc *ShardCtl) Execute(ctx context.Context, args *pb.Args) (reply *pb.Reply, err error)

func (*ShardCtl) Kill

func (sc *ShardCtl) Kill()

Kill the tester calls Kill() when a ShardCtl instance won't be needed again. you are not required to do anything in Kill(), but it might be convenient to (for example) turn off debug output from this instance.

func (*ShardCtl) Monitor

func (sc *ShardCtl) Monitor(action func(), timeout time.Duration)