Documentation
¶
Index ¶
- func GetBlockWithMultiIBTestSet() (*topology.Graph, map[string]string)
- func GetTreeTestSet(testForLongLabelName bool) (*topology.Graph, map[string]string)
- type Block
- type BlockTopo
- type Config
- type NetworkTopology
- func (nt *NetworkTopology) Generate(wr io.Writer) *httperr.Error
- func (nt *NetworkTopology) GenerateTopologyConfig(wr io.Writer, skeletonOnly bool) ([]*TopologyUnit, *httperr.Error)
- func (nt *NetworkTopology) GetNodeTopologySpec(node string, topologies []*TopologyUnit) (string, *httperr.Error)
- func (nt *NetworkTopology) GetTopologies() ([]*TopologyUnit, *httperr.Error)
- type Switch
- type TopologySpec
- type TopologyUnit
- type TreeTopo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
Plugin string // topology plugin (cluster-wide)
BlockSizes []int
Topologies map[string]*TopologySpec // per-partiton topology settings
}
type NetworkTopology ¶
type NetworkTopology struct {
// contains filtered or unexported fields
}
func NewNetworkTopology ¶
func NewNetworkTopology(graph *topology.Graph, cfg *Config) (*NetworkTopology, error)
func (*NetworkTopology) GenerateTopologyConfig ¶ added in v0.4.0
func (nt *NetworkTopology) GenerateTopologyConfig(wr io.Writer, skeletonOnly bool) ([]*TopologyUnit, *httperr.Error)
func (*NetworkTopology) GetNodeTopologySpec ¶ added in v0.4.0
func (nt *NetworkTopology) GetNodeTopologySpec(node string, topologies []*TopologyUnit) (string, *httperr.Error)
func (*NetworkTopology) GetTopologies ¶ added in v0.4.0
func (nt *NetworkTopology) GetTopologies() ([]*TopologyUnit, *httperr.Error)
GetTopologies returns a list of TopologyUnit for all topologies defined in the config, ordered by topology name.
type TopologySpec ¶
TopologySpec define topology for a partition
type TopologyUnit ¶
Click to show internal directories.
Click to hide internal directories.