gossipCluster

Documentation

Index

• 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) Leave() error
  • func (c *Cluster) MemberByHash(h uint64) rony.ClusterMember
  • func (c *Cluster) MemberByID(serverID string) rony.ClusterMember
  • func (c *Cluster) Members() []rony.ClusterMember
  • func (c *Cluster) MembersByReplicaSet(replicaSets ...uint64) []rony.ClusterMember
  • func (c *Cluster) ReplicaSet() uint64
  • func (c *Cluster) ServerID() string
  • func (c *Cluster) SetGatewayAddrs(hostPorts []string) error
  • func (c *Cluster) SetTunnelAddrs(hostPorts []string) error
  • func (c *Cluster) Shutdown()
  • func (c *Cluster) Start() error
  • func (c *Cluster) Subscribe(d rony.ClusterDelegate)
  • 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 *msg.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

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) Leave

func (c *Cluster) Leave() error

func (*Cluster) MemberByHash

func (c *Cluster) MemberByHash(h uint64) rony.ClusterMember

func (*Cluster) MemberByID

func (c *Cluster) MemberByID(serverID string) rony.ClusterMember

func (*Cluster) Members

func (c *Cluster) Members() []rony.ClusterMember

func (*Cluster) MembersByReplicaSet

func (c *Cluster) MembersByReplicaSet(replicaSets ...uint64) []rony.ClusterMember

func (*Cluster) ReplicaSet

func (c *Cluster) ReplicaSet() uint64

func (*Cluster) ServerID

func (c *Cluster) ServerID() string

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() error

func (*Cluster) Subscribe

func (c *Cluster) Subscribe(d rony.ClusterDelegate)

func (*Cluster) TotalReplicas

func (c *Cluster) TotalReplicas() int

type Config

type Config struct {
	ServerID       []byte
	Bootstrap      bool
	ReplicaSet     uint64
	GossipIP       string
	GossipPort     int
	AdvertisedIP   string
	AdvertisedPort int
	Logger         log.Logger
}

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 *msg.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