test

Documentation

Index

• type Harness
  • func NewHarness(t *testing.T, n int) *Harness
  • func NewHarnessWithPort(t *testing.T, n int, basePort int) *Harness
  • func (h *Harness) AddNodeToCluster(leaderId int, newId int)
  • func (h *Harness) CheckAppend(c *kvclient.KVClient, key, value string) (string, bool)
  • func (h *Harness) CheckCAS(c *kvclient.KVClient, key, compare, value string) (string, bool)
  • func (h *Harness) CheckGet(c *kvclient.KVClient, key string, wantValue string)
  • func (h *Harness) CheckGetNotFound(c *kvclient.KVClient, key string)
  • func (h *Harness) CheckGetTimesOut(c *kvclient.KVClient, key string)
  • func (h *Harness) CheckPeerList(id int, wantPeers []int)
  • func (h *Harness) CheckPut(c *kvclient.KVClient, key, value string) (string, bool)
  • func (h *Harness) CheckPutWithLease(c *kvclient.KVClient, key, value string, leaseID int64) (string, bool)
  • func (h *Harness) CheckSingleLeader() int
  • func (h *Harness) CrashService(id int)
  • func (h *Harness) DelayNextHTTPResponseFromService(id int)
  • func (h *Harness) DisconnectServiceFromPeers(id int)
  • func (h *Harness) NewClient() *kvclient.KVClient
  • func (h *Harness) NewClientSingleService(id int) *kvclient.KVClient
  • func (h *Harness) NewClientWithRandomAddrsOrder() *kvclient.KVClient
  • func (h *Harness) ReconnectServiceToPeers(id int)
  • func (h *Harness) RemoveNodeFromCluster(leaderId int, targetId int)
  • func (h *Harness) RestartService(id int)
  • func (h *Harness) Shutdown()

Types

type Harness

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

func NewHarness

func NewHarness(t *testing.T, n int) *Harness

func NewHarnessWithPort

func NewHarnessWithPort(t *testing.T, n int, basePort int) *Harness

func (*Harness) AddNodeToCluster

func (h *Harness) AddNodeToCluster(leaderId int, newId int)

func (*Harness) CheckAppend

func (h *Harness) CheckAppend(c *kvclient.KVClient, key, value string) (string, bool)

func (*Harness) CheckCAS

func (h *Harness) CheckCAS(c *kvclient.KVClient, key, compare, value string) (string, bool)

func (*Harness) CheckGet

func (h *Harness) CheckGet(c *kvclient.KVClient, key string, wantValue string)

func (*Harness) CheckGetNotFound

func (h *Harness) CheckGetNotFound(c *kvclient.KVClient, key string)

func (*Harness) CheckGetTimesOut

func (h *Harness) CheckGetTimesOut(c *kvclient.KVClient, key string)

func (*Harness) CheckPeerList

func (h *Harness) CheckPeerList(id int, wantPeers []int)

func (*Harness) CheckPut

func (h *Harness) CheckPut(c *kvclient.KVClient, key, value string) (string, bool)

func (*Harness) CheckPutWithLease

func (h *Harness) CheckPutWithLease(c *kvclient.KVClient, key, value string, leaseID int64) (string, bool)

func (*Harness) CheckSingleLeader

func (h *Harness) CheckSingleLeader() int

func (*Harness) CrashService

func (h *Harness) CrashService(id int)

func (*Harness) DelayNextHTTPResponseFromService

func (h *Harness) DelayNextHTTPResponseFromService(id int)

func (*Harness) DisconnectServiceFromPeers

func (h *Harness) DisconnectServiceFromPeers(id int)

func (*Harness) NewClient

func (h *Harness) NewClient() *kvclient.KVClient

func (*Harness) NewClientSingleService

func (h *Harness) NewClientSingleService(id int) *kvclient.KVClient

func (*Harness) NewClientWithRandomAddrsOrder

func (h *Harness) NewClientWithRandomAddrsOrder() *kvclient.KVClient

func (*Harness) ReconnectServiceToPeers

func (h *Harness) ReconnectServiceToPeers(id int)

func (*Harness) RemoveNodeFromCluster

func (h *Harness) RemoveNodeFromCluster(leaderId int, targetId int)

func (*Harness) RestartService

func (h *Harness) RestartService(id int)

func (*Harness) Shutdown

func (h *Harness) Shutdown()