Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cluster

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 30, 2020

Changes in this version

type Error

+ func (r *Error) HTTPStatusCode() int

type HTTPNode

+ func (n HTTPNode) PostRaw(ctx context.Context, name, path string, body Traceable) (io.ReadCloser, error)

type MockNode

+ func (n MockNode) PostRaw(ctx context.Context, name, path string, body Traceable) (io.ReadCloser, error)

type Node

+ PostRaw func(ctx context.Context, name, path string, body Traceable) (io.ReadCloser, error)

v0

v0.13.1

Nov 28, 2019

v0.13.0

Sep 17, 2019

v0.12.0

May 14, 2019

Changes in this version

+ var GossipSettlePeriod time.Duration

type HTTPNode

+ Mode NodeMode

+ func (n *HTTPNode) SetPartitions(part []int32)

+ func (n *HTTPNode) SetPrimary(primary bool) bool

+ func (n *HTTPNode) SetPriority(prio int) bool

+ func (n *HTTPNode) SetState(state NodeState) bool

+ func (n HTTPNode) HasData() bool

+ type InvalidNodeModeErr string

+ func (e InvalidNodeModeErr) Error() string

type MockNode

+ func (n *MockNode) HasData() bool

type Node

+ HasData func() bool

+ type NodeMode uint8

+ const ModeDev

+ const ModeQuery

+ const ModeShard

+ func NodeModeFromString(mode string) (NodeMode, error)

+ func (i NodeMode) String() string

+ func (n *NodeMode) UnmarshalJSON(b []byte) error

+ func (n NodeMode) MarshalJSON() ([]byte, error)

v0.11.0

Dec 19, 2018

Changes in this version

+ const ModeMulti

+ const ModeSingle

+ var ClusterName string

+ var InsufficientShardsAvailable = NewError(http.StatusServiceUnavailable, errors.New("Insufficient shards available."))

+ var Manager ClusterManager

+ var Mode ModeType

+ var Tracer opentracing.Tracer

+ func ConfigProcess()

+ func ConfigSetup()

+ func Init(name, version string, started time.Time, apiScheme string, apiPort int)

+ func MembersForSpeculativeQuery() (map[int32][]Node, error)

+ func Start()

+ func Stop()

+ type ClusterManager interface

+ GetPartitions func() []int32

+ IsPrimary func() bool

+ IsReady func() bool

+ Join func([]string) (int, error)

+ MemberList func() []Node

+ SetPartitions func([]int32)

+ SetPrimary func(bool)

+ SetPriority func(int)

+ SetReady func()

+ SetState func(NodeState)

+ Start func()

+ Stop func()

+ ThisNode func() Node

+ type Error struct

+ func NewError(code int, err error) *Error

+ func (r *Error) Code() int

+ func (r *Error) Error() string

+ type HTTPNode struct

+ ApiPort int

+ ApiScheme string

+ Name string

+ Partitions []int32

+ Primary bool

+ PrimaryChange time.Time

+ Priority int

+ RemoteAddr string

+ Started time.Time

+ State NodeState

+ StateChange time.Time

+ Updated time.Time

+ Version string

+ func (n HTTPNode) GetName() string

+ func (n HTTPNode) GetPartitions() []int32

+ func (n HTTPNode) GetPriority() int

+ func (n HTTPNode) IsLocal() bool

+ func (n HTTPNode) IsReady() bool

+ func (n HTTPNode) Post(ctx context.Context, name, path string, body Traceable) (ret []byte, err error)

+ func (n HTTPNode) RemoteURL() string

+ type HTTPNodesByName []HTTPNode

+ func (n HTTPNodesByName) Len() int

+ func (n HTTPNodesByName) Less(i, j int) bool

+ func (n HTTPNodesByName) Swap(i, j int)

+ type MemberlistManager struct

+ func NewMemberlistManager(thisNode HTTPNode) *MemberlistManager

+ func (c *MemberlistManager) BroadcastUpdate()

+ func (c *MemberlistManager) GetBroadcasts(overhead, limit int) [][]byte

+ func (c *MemberlistManager) GetPartitions() []int32

+ func (c *MemberlistManager) IsPrimary() bool

+ func (c *MemberlistManager) IsReady() bool

+ func (c *MemberlistManager) Join(peers []string) (int, error)

+ func (c *MemberlistManager) LocalState(join bool) []byte

+ func (c *MemberlistManager) MemberList() []Node

+ func (c *MemberlistManager) MergeRemoteState(buf []byte, join bool)

+ func (c *MemberlistManager) NodeMeta(limit int) []byte

+ func (c *MemberlistManager) NotifyJoin(node *memberlist.Node)

+ func (c *MemberlistManager) NotifyLeave(node *memberlist.Node)

+ func (c *MemberlistManager) NotifyMsg(buf []byte)

+ func (c *MemberlistManager) NotifyUpdate(node *memberlist.Node)

+ func (c *MemberlistManager) SetPartitions(part []int32)

+ func (c *MemberlistManager) SetPrimary(p bool)

+ func (c *MemberlistManager) SetPriority(prio int)

+ func (c *MemberlistManager) SetReady()

+ func (c *MemberlistManager) SetState(state NodeState)

+ func (c *MemberlistManager) Start()

+ func (c *MemberlistManager) Stop()

+ func (c *MemberlistManager) ThisNode() Node

+ type MockClusterManager struct

+ Peers []*MockNode

+ func InitMock() *MockClusterManager

+ func (c *MockClusterManager) GetPartitions() []int32

+ func (c *MockClusterManager) IsPrimary() bool

+ func (c *MockClusterManager) IsReady() bool

+ func (c *MockClusterManager) Join(peers []string) (int, error)

+ func (c *MockClusterManager) MemberList() []Node

+ func (c *MockClusterManager) SetPartitions(partitions []int32)

+ func (c *MockClusterManager) SetPrimary(primary bool)

+ func (c *MockClusterManager) SetPriority(prio int)

+ func (c *MockClusterManager) SetReady()

+ func (c *MockClusterManager) SetReadyIn(t time.Duration)

+ func (c *MockClusterManager) SetState(NodeState)

+ func (c *MockClusterManager) Start()

+ func (c *MockClusterManager) Stop()

+ func (c *MockClusterManager) ThisNode() Node

+ type MockNode struct

+ func NewMockNode(isLocal bool, name string, postResponse []byte) *MockNode

+ func (n *MockNode) GetName() string

+ func (n *MockNode) GetPartitions() []int32

+ func (n *MockNode) GetPriority() int

+ func (n *MockNode) IsLocal() bool

+ func (n *MockNode) IsReady() bool

+ func (n MockNode) Post(ctx context.Context, name, path string, body Traceable) ([]byte, error)

+ type ModeType string

+ type Node interface

+ GetName func() string

+ GetPartitions func() []int32

+ GetPriority func() int

+ IsLocal func() bool

+ IsReady func() bool

+ Post func(context.Context, string, string, Traceable) ([]byte, error)

+ func MembersForQuery() ([]Node, error)

+ type NodeState int

+ const NodeNotReady

+ const NodeReady

+ const NodeUnreachable

+ func NodeStateFromString(s string) NodeState

+ func (i NodeState) String() string

+ func (n *NodeState) UnmarshalJSON(data []byte) error

+ func (n NodeState) MarshalJSON() ([]byte, error)

+ type SingleNodeManager struct

+ func NewSingleNodeManager(thisNode HTTPNode) *SingleNodeManager

+ func (m *SingleNodeManager) GetPartitions() []int32

+ func (m *SingleNodeManager) IsPrimary() bool

+ func (m *SingleNodeManager) IsReady() bool

+ func (m *SingleNodeManager) Join(peers []string) (int, error)

+ func (m *SingleNodeManager) MemberList() []Node

+ func (m *SingleNodeManager) SetPartitions(part []int32)

+ func (m *SingleNodeManager) SetPrimary(primary bool)

+ func (m *SingleNodeManager) SetPriority(prio int)

+ func (m *SingleNodeManager) SetReady()

+ func (m *SingleNodeManager) SetState(state NodeState)

+ func (m *SingleNodeManager) Start()

+ func (m *SingleNodeManager) Stop()

+ func (m *SingleNodeManager) ThisNode() Node

+ type Traceable interface

+ Trace func(span opentracing.Span)

+ TraceDebug func(span opentracing.Span)