gossipCluster

package

Go to main page

Versions in this module

v0

v0.16.25

Aug 7, 2023

v0.16.24

Jan 12, 2022

v0.16.23

Jan 12, 2022

v0.16.22

Jan 2, 2022

v0.16.21

Dec 28, 2021

v0.16.20

Dec 28, 2021

v0.16.19

Dec 26, 2021

v0.16.18

Dec 26, 2021

v0.16.17

Dec 26, 2021

v0.16.16

Dec 26, 2021

v0.16.15

Dec 14, 2021

v0.16.14

Dec 12, 2021

v0.16.13

Dec 12, 2021

v0.16.12

Dec 12, 2021

v0.16.11

Dec 11, 2021

v0.16.10

Dec 9, 2021

v0.16.9

Dec 8, 2021

v0.16.8

Dec 2, 2021

v0.16.7

Dec 1, 2021

v0.16.6

Dec 1, 2021

v0.16.5

Nov 26, 2021

v0.16.4

Nov 25, 2021

v0.16.3

Nov 24, 2021

v0.16.2

Nov 23, 2021

v0.16.1

Nov 23, 2021

v0.16.0

Nov 23, 2021

v0.15.4

Nov 17, 2021

v0.15.3

Nov 17, 2021

v0.15.2

Nov 17, 2021

v0.15.1

Nov 4, 2021

v0.15.0

Nov 4, 2021

v0.14.36

Nov 4, 2021

v0.14.35

Nov 3, 2021

v0.14.34

Nov 3, 2021

v0.14.33

Oct 31, 2021

v0.14.32

Oct 31, 2021

v0.14.31

Oct 28, 2021

v0.14.30

Oct 28, 2021

v0.14.29

Oct 28, 2021

v0.14.28

Oct 28, 2021

v0.14.27

Oct 27, 2021

v0.14.26

Oct 27, 2021

v0.14.25

Oct 26, 2021

v0.14.24

Oct 26, 2021

v0.14.23

Oct 26, 2021

v0.14.22

Oct 26, 2021

v0.14.21

Oct 26, 2021

v0.14.20

Oct 25, 2021

v0.14.19

Oct 20, 2021

v0.14.18

Oct 19, 2021

v0.14.17

Oct 17, 2021

v0.14.16

Oct 16, 2021

v0.14.15

Oct 9, 2021

v0.14.14

Oct 9, 2021

v0.14.13

Oct 8, 2021

v0.14.12

Oct 1, 2021

v0.14.11

Oct 1, 2021

v0.14.10

Sep 29, 2021

v0.14.9

Sep 29, 2021

v0.14.8

Sep 26, 2021

v0.14.7

Sep 14, 2021

v0.14.6

Sep 14, 2021

v0.14.5

Sep 12, 2021

v0.14.4

Sep 12, 2021

v0.14.3

Sep 12, 2021

v0.14.2

Sep 10, 2021

v0.14.1

Sep 9, 2021

v0.14.0

Sep 9, 2021

v0.12.57

Sep 8, 2021

v0.12.56

Sep 7, 2021

v0.12.55

Sep 7, 2021

v0.12.54

Sep 7, 2021

v0.12.53

Sep 7, 2021

v0.12.52

Sep 7, 2021

v0.12.51

Sep 7, 2021

v0.12.50

Sep 7, 2021

v0.12.49

Sep 7, 2021

v0.12.48

Sep 6, 2021

v0.12.47

Sep 6, 2021

v0.12.46

Sep 6, 2021

v0.12.45

Sep 5, 2021

v0.12.44

Sep 5, 2021

v0.12.43

Sep 5, 2021

v0.12.42

Sep 5, 2021

v0.12.41

Sep 3, 2021

v0.12.40

Sep 2, 2021

v0.12.39

Sep 2, 2021

Changes in this version

type Config

+ Logger log.Logger

v0.12.38

Sep 2, 2021

v0.12.37

Sep 2, 2021

v0.12.36

Sep 2, 2021

v0.12.35

Sep 2, 2021

v0.12.34

Sep 1, 2021

v0.12.33

Sep 1, 2021

v0.12.32

Sep 1, 2021

v0.12.31

Aug 4, 2021

v0.12.30

Aug 4, 2021

Changes in this version

type Config

+ AdvertisedIP string

+ AdvertisedPort int

+ GossipIP string

v0.12.29

Aug 3, 2021

v0.12.28

Aug 3, 2021

v0.12.27

Aug 3, 2021

v0.12.26

Aug 3, 2021

v0.12.25

Aug 3, 2021

v0.12.24

Aug 2, 2021

v0.12.23

Aug 2, 2021

v0.12.22

Aug 1, 2021

v0.12.21

Aug 1, 2021

v0.12.20

Aug 1, 2021

v0.12.19

Jul 26, 2021

v0.12.18

Jul 26, 2021

v0.12.17

Jul 25, 2021

v0.12.16

Jul 24, 2021

v0.12.15

Jul 21, 2021

Changes in this version

type Cluster

+ func (c *Cluster) Leave() error

v0.12.14

Jul 20, 2021

v0.12.13

Jul 19, 2021

v0.12.12

Jul 18, 2021

v0.12.11

Jul 18, 2021

v0.12.10

Jul 18, 2021

v0.12.9

Jul 18, 2021

v0.12.8

Jul 17, 2021

v0.12.7

Jul 16, 2021

v0.12.6

Jul 16, 2021

v0.12.5

Jul 15, 2021

v0.12.4

Jul 15, 2021

v0.12.3

Jul 15, 2021

v0.12.2

Jul 15, 2021

v0.12.1

Jul 15, 2021

v0.12.0

Jul 14, 2021

v0.11.4

Jul 11, 2021

v0.11.3

Jul 11, 2021

v0.11.2

Jul 8, 2021

v0.11.1

Jul 8, 2021

v0.11.0

Jul 7, 2021

v0.10.6

Jul 6, 2021

v0.10.5

Jul 5, 2021

v0.10.4

Jul 4, 2021

v0.10.3

Jul 4, 2021

v0.10.2

Jul 3, 2021

v0.10.1

Jul 3, 2021

v0.10.0

Jul 3, 2021

v0.9.0

Jul 2, 2021

v0.8.7

Jun 30, 2021

v0.8.6

Jun 30, 2021

v0.8.5

Jun 30, 2021

v0.8.4

Jun 30, 2021

v0.8.3

Jun 9, 2021

v0.8.2

Jun 9, 2021

v0.8.1

May 22, 2021

v0.8.0

May 21, 2021

v0.7.6

May 18, 2021

v0.7.5

May 18, 2021

v0.7.4

May 18, 2021

Changes in this version

type Cluster

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

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

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

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

v0.7.3

May 17, 2021

Changes in this version

type Member

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

v0.7.2

May 17, 2021

Changes in this version

type Cluster

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

v0.7.1

May 16, 2021

Changes in this version

type Config

+ FSM raft.FSM

+ Store store.Store

v0.7.0

May 11, 2021

v0.6.57

May 5, 2021

v0.6.56

May 5, 2021

v0.6.55

May 5, 2021

v0.6.54

May 5, 2021

v0.6.53

May 3, 2021

v0.6.52

Apr 28, 2021

v0.6.51

Apr 28, 2021

v0.6.50

Apr 27, 2021

v0.6.49

Apr 22, 2021

v0.6.48

Apr 22, 2021

v0.6.47

Apr 22, 2021

v0.6.46

Apr 22, 2021

v0.6.45

Apr 22, 2021

v0.6.44

Apr 22, 2021

v0.6.43

Apr 22, 2021

v0.6.42

Apr 22, 2021

v0.6.41

Apr 22, 2021

v0.6.40

Apr 22, 2021

v0.6.39

Apr 21, 2021

v0.6.38

Apr 21, 2021

v0.6.37

Apr 21, 2021

v0.6.36

Apr 14, 2021

v0.6.35

Apr 13, 2021

v0.6.34

Apr 12, 2021

v0.6.33

Apr 5, 2021

v0.6.32

Apr 5, 2021

v0.6.31

Apr 1, 2021

v0.6.30

Apr 1, 2021

v0.6.29

Mar 31, 2021

v0.6.28

Mar 30, 2021

v0.6.27

Mar 29, 2021

v0.6.26

Mar 29, 2021

v0.6.25

Mar 29, 2021

v0.6.24

Mar 29, 2021

v0.6.23

Mar 19, 2021

v0.6.22

Mar 17, 2021

v0.6.21

Mar 17, 2021

v0.6.20

Mar 16, 2021

v0.6.19

Mar 14, 2021

v0.6.18

Mar 14, 2021

v0.6.17

Mar 14, 2021

v0.6.16

Mar 14, 2021

Changes in this version

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

type Member

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

+ func (m *Member) TunnelConn() (net.Conn, error)

v0.6.15

Mar 13, 2021

v0.6.14

Mar 13, 2021

v0.6.13

Mar 13, 2021

v0.6.12

Mar 13, 2021

v0.6.11

Mar 12, 2021

v0.6.10

Mar 9, 2021

v0.6.9

Mar 7, 2021

v0.6.8

Mar 7, 2021

v0.6.7

Mar 4, 2021

v0.6.6

Mar 4, 2021

v0.6.5

Mar 4, 2021

v0.6.4

Mar 4, 2021

v0.6.3

Mar 4, 2021

v0.6.2

Mar 3, 2021

v0.6.1

Mar 3, 2021

v0.6.0

Mar 3, 2021

v0.5.29

Mar 2, 2021

v0.5.28

Mar 2, 2021

v0.5.27

Mar 2, 2021

v0.5.26

Mar 2, 2021

v0.5.25

Mar 1, 2021

v0.5.24

Mar 1, 2021

v0.5.23

Feb 28, 2021

v0.5.22

Feb 27, 2021

v0.5.21

Feb 27, 2021

v0.5.20

Feb 27, 2021

Changes in this version

+ var ErrKeyNotFound = errors.New("not found")

+ type BadgerStore struct

+ func (b *BadgerStore) DeleteRange(min, max uint64) error

+ func (b *BadgerStore) FirstIndex() (uint64, error)

+ func (b *BadgerStore) Get(key []byte) ([]byte, error)

+ func (b *BadgerStore) GetLog(index uint64, log *raft.Log) error

+ func (b *BadgerStore) GetUint64(key []byte) (uint64, error)

+ func (b *BadgerStore) LastIndex() (uint64, error)

+ func (b *BadgerStore) Set(key []byte, val []byte) error

+ func (b *BadgerStore) SetUint64(key []byte, val uint64) error

+ func (b *BadgerStore) StoreLog(log *raft.Log) error

+ func (b *BadgerStore) StoreLogs(logs []*raft.Log) error

type Cluster

+ func (c *Cluster) RaftEnabled() bool

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

+ func (c *Cluster) TotalReplicas() int

type Member

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

v0.1.8

Jan 6, 2021

Changes in this version

+ type Cluster struct

+ func New(cfg Config) *Cluster

+ func (c *Cluster) Addr() string

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

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

+ func (c *Cluster) RaftApply(cmd []byte) raft.ApplyFuture

+ func (c *Cluster) RaftConfigs() raft.ConfigurationFuture

+ func (c *Cluster) RaftLeaderID() string

+ func (c *Cluster) RaftMembers(replicaSet uint64) []cluster.Member

+ func (c *Cluster) RaftState() raft.RaftState

+ func (c *Cluster) ReplicaSet() uint64

+ func (c *Cluster) SetGatewayAddrs(addrs []string) error

+ func (c *Cluster) Shutdown()

+ func (c *Cluster) Start()

+ type Config struct

+ Bootstrap bool

+ DataPath string

+ GossipPort int

+ Mode cluster.Mode

+ RaftPort int

+ ReplicaSet uint64

+ ServerID []byte

+ type Member struct

+ ClusterAddr net.IP

+ ClusterPort uint16

+ ShardRange [2]uint32

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

+ func (m *Member) Proto(p *rony.NodeInfo) *rony.NodeInfo

+ func (m *Member) RaftPort() int

+ func (m *Member) RaftState() rony.RaftState

+ func (m *Member) ReplicaSet() uint64

+ func (m *Member) ServerID() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL