gossipCluster

Documentation

Index

• Variables
• type Cluster
  • func New(dataPath string, cfg Config) *Cluster
  • func (c *Cluster) Addr() string
  • func (c *Cluster) Join(addr ...string) (int, error)
  • func (c *Cluster) MemberByHash(h uint64) cluster.Member
  • func (c *Cluster) MemberByID(serverID string) cluster.Member
  • func (c *Cluster) Members() []cluster.Member
  • func (c *Cluster) MembersByReplicaSet(replicaSets ...uint64) []cluster.Member
  • func (c *Cluster) ReplicaSet() uint64
  • func (c *Cluster) ServerID() []byte
  • func (c *Cluster) SetGatewayAddrs(hostPorts []string) error
  • func (c *Cluster) SetTunnelAddrs(hostPorts []string) error
  • func (c *Cluster) Shutdown()
  • func (c *Cluster) Start()
  • func (c *Cluster) Subscribe(d cluster.Delegate)
  • func (c *Cluster) TotalReplicas() int
• type Config
• type Member
  • func (m *Member) Dial() (net.Conn, error)
  • func (m *Member) GatewayAddr() []string
  • func (m *Member) Merge(en *rony.EdgeNode)
  • func (m *Member) Proto(p *rony.Edge) *rony.Edge
  • func (m *Member) ReplicaSet() uint64
  • func (m *Member) ServerID() string
  • func (m *Member) TunnelAddr() []string

Variables

var (
	ErrNoTunnelAddrs = errors.New("tunnel address does not found")
)

Types

type Cluster

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

func New

func New(dataPath string, cfg Config) *Cluster

func (*Cluster) Addr

func (c *Cluster) Addr() string

func (*Cluster) Join

func (c *Cluster) Join(addr ...string) (int, error)

func (*Cluster) MemberByHash

func (c *Cluster) MemberByHash(h uint64) cluster.Member

func (*Cluster) MemberByID

func (c *Cluster) MemberByID(serverID string) cluster.Member

func (*Cluster) Members

func (c *Cluster) Members() []cluster.Member

func (*Cluster) MembersByReplicaSet

func (c *Cluster) MembersByReplicaSet(replicaSets ...uint64) []cluster.Member

func (*Cluster) ReplicaSet

func (c *Cluster) ReplicaSet() uint64

func (*Cluster) ServerID

func (c *Cluster) ServerID() []byte

func (*Cluster) SetGatewayAddrs

func (c *Cluster) SetGatewayAddrs(hostPorts []string) error

func (*Cluster) SetTunnelAddrs

func (c *Cluster) SetTunnelAddrs(hostPorts []string) error

func (*Cluster) Shutdown

func (c *Cluster) Shutdown()

func (*Cluster) Start

func (c *Cluster) Start()

func (*Cluster) Subscribe

func (c *Cluster) Subscribe(d cluster.Delegate)

func (*Cluster) TotalReplicas

func (c *Cluster) TotalReplicas() int

type Config

type Config struct {
	ServerID   []byte
	Bootstrap  bool
	ReplicaSet uint64
	GossipPort int
}

type Member

type Member struct {
	ClusterAddr net.IP
	ClusterPort uint16
	// contains filtered or unexported fields
}

func (*Member) Dial

func (m *Member) Dial() (net.Conn, error)

func (*Member) GatewayAddr

func (m *Member) GatewayAddr() []string

func (*Member) Merge

func (m *Member) Merge(en *rony.EdgeNode)

func (*Member) Proto

func (m *Member) Proto(p *rony.Edge) *rony.Edge

func (*Member) ReplicaSet

func (m *Member) ReplicaSet() uint64

func (*Member) ServerID

func (m *Member) ServerID() string

func (*Member) TunnelAddr

func (m *Member) TunnelAddr() []string