localtestcluster

type InitSenderFn ¶

type InitSenderFn func(
	nodeDesc *roachpb.NodeDescriptor,
	tracer opentracing.Tracer,
	clock *hlc.Clock,
	latency time.Duration,
	stores client.Sender,
	stopper *stop.Stopper,
	gossip *gossip.Gossip,
) client.Sender

InitSenderFn is a callback used to initiate the txn coordinator (we don't do it directly from this package to avoid a dependency on kv).

type LocalTestCluster ¶

type LocalTestCluster struct {
	Manual            *hlc.ManualClock
	Clock             *hlc.Clock
	Gossip            *gossip.Gossip
	Eng               engine.Engine
	Store             *storage.Store
	DBContext         *client.DBContext
	DB                *client.DB
	RangeRetryOptions *retry.Options
	Stores            *storage.Stores
	Sender            client.Sender
	Stopper           *stop.Stopper
	Latency           time.Duration // sleep for each RPC sent
	// contains filtered or unexported fields
}

A LocalTestCluster encapsulates an in-memory instantiation of a cockroach node with a single store using a local sender. Example usage of a LocalTestCluster follows:

s := &LocalTestCluster{}
s.Start(t, testutils.NewNodeTestBaseContext(),
        kv.InitSenderForLocalTestCluster)
defer s.Stop()

Note that the LocalTestCluster is different from server.TestCluster in that although it uses a distributed sender, there is no RPC traffic.

func (ltc *LocalTestCluster) Start(t util.Tester, baseCtx *base.Context, initSender InitSenderFn)

func (ltc *LocalTestCluster) Stop()