Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StoreGossiper ¶
type StoreGossiper struct {
// contains filtered or unexported fields
}
StoreGossiper allows tests to push storeDescriptors into gossip and synchronize on their callbacks. There can only be one storeGossiper used per gossip instance.
func NewStoreGossiper ¶
func NewStoreGossiper(g *gossip.Gossip) *StoreGossiper
NewStoreGossiper creates a store gossiper for use by tests. It adds the callback to gossip.
func (*StoreGossiper) GossipStores ¶
func (sg *StoreGossiper) GossipStores(storeDescs []*roachpb.StoreDescriptor, t *testing.T)
GossipStores queues up a list of stores to gossip and blocks until each one is gossiped before returning.
func (*StoreGossiper) GossipWithFunction ¶
func (sg *StoreGossiper) GossipWithFunction(storeIDs []roachpb.StoreID, gossipFn func())
GossipWithFunction calls gossipFn and blocks until gossip callbacks have fired on each of the stores specified by storeIDs.
Source Files
Click to show internal directories.
Click to hide internal directories.