topology

Documentation

Index

• Variables
• func IsSingleNode(shards map[string][]string) bool
• type Cluster
  • func (c *Cluster) Name() string
  • func (c *Cluster) SingleNode() bool
• type ShardHostMap
• type Topology
  • func NewTopology(clusterName string, singleNode bool) *Topology
  • func ResolveTopology(params model.ChSinkParams, lgr log.Logger) (*Topology, error)
  • func (t *Topology) ClusterName() string
  • func (t *Topology) SingleNode() bool

Variables

var ErrNoCluster = xerrors.New("no clusters found in system.clusters table")

Functions

func IsSingleNode

func IsSingleNode(shards map[string][]string) bool

Types

type Cluster

type Cluster struct {
	Topology Topology
	Shards   ShardHostMap
}

func (*Cluster) Name

func (c *Cluster) Name() string

func (*Cluster) SingleNode

func (c *Cluster) SingleNode() bool

type ShardHostMap

type ShardHostMap map[int][]string

type Topology

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

func NewTopology

func NewTopology(clusterName string, singleNode bool) *Topology

func ResolveTopology

func ResolveTopology(params model.ChSinkParams, lgr log.Logger) (*Topology, error)

func (*Topology) ClusterName

func (t *Topology) ClusterName() string

func (*Topology) SingleNode

func (t *Topology) SingleNode() bool