testutil

Documentation

Index

• func MustNewTopologyMap(replicas int, assignment map[string][]shard.Shard) topology.Map
• func NewStateSnapshot(hostShardStates HostShardStates) *topology.StateSnapshot
• type HostShardStates
• type TopologyView
  • func NewTopologyView(replicas int, assignment map[string][]shard.Shard) TopologyView
  • func (v TopologyView) Map() (topology.Map, error)

Functions

func MustNewTopologyMap

func MustNewTopologyMap(replicas int, assignment map[string][]shard.Shard) topology.Map

MustNewTopologyMap returns a new topology.Map with provided parameters. It's a utility method to make tests easier to write.

func NewStateSnapshot

func NewStateSnapshot(hostShardStates HostShardStates) *topology.StateSnapshot

NewStateSnapshot creates a new initial topology state snapshot using HostShardStates as input.

Types

type HostShardStates

type HostShardStates map[string][]shard.Shard

HostShardStates is a human-readable way of describing an initial state topology on a host-by-host basis.

type TopologyView

type TopologyView struct {
	Replicas   int
	Assignment map[string][]shard.Shard
}

TopologyView represents a snaphshot view of a topology.Map.

func NewTopologyView

func NewTopologyView(replicas int, assignment map[string][]shard.Shard) TopologyView

NewTopologyView returns a new TopologyView with provided parameters. It's a utility method to make tests easier to write.

func (TopologyView) Map

func (v TopologyView) Map() (topology.Map, error)

Map returns the topology.Map corresponding to a TopologyView.