cluster

package

v0.2.1 Latest Latest Go to latest Published: Apr 6, 2017 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nicot/oklog

Links

Open Source Insights

Documentation ¶

Overview ¶

Package cluster provides an elastic peer discovery and gossip layer.

Ingest and store instances join the same cluster and know about each other. Store instances consume segments from each ingest instance, and broadcast queries to each store instance. In the future, ingest instances will share load information to potentially refuse connections and balance writes.

Index ¶

Constants
type Peer
- func NewPeer(addr string, port int, existing []string, t PeerType, apiPort int, ...) (*Peer, error)
type PeerType

Constants ¶

View Source

const (
	// PeerTypeIngest serves the ingest API.
	PeerTypeIngest PeerType = "ingest"

	// PeerTypeStore serves the store API.
	PeerTypeStore = "store"

	// PeerTypeIngestStore serves both ingest and store APIs.
	PeerTypeIngestStore = "ingeststore"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Peer ¶

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

Peer represents this node in the cluster.

func NewPeer ¶

func NewPeer(addr string, port int, existing []string, t PeerType, apiPort int, logger log.Logger) (*Peer, error)

NewPeer creates or joins a cluster with the existing peers. We will listen for cluster communications on the given addr:port. We advertise a PeerType HTTP API, reachable on apiPort.

func (*Peer) ClusterSize ¶

func (p *Peer) ClusterSize() int

ClusterSize returns the total size of the cluster from this node's perspective.

func (*Peer) Current ¶

func (p *Peer) Current(t PeerType) []string

Current API host:ports for the given type of node.

func (*Peer) Leave ¶

func (p *Peer) Leave(timeout time.Duration) error

Leave the cluster, waiting up to timeout.

func (*Peer) Name ¶

func (p *Peer) Name() string

Name returns the unique ID of this peer in the cluster.

func (*Peer) State ¶

func (p *Peer) State() map[string]interface{}

State returns a JSON-serializable dump of cluster state. Useful for debug.

type PeerType ¶

type PeerType string

PeerType enumerates the types of nodes in the cluster.

Source Files ¶

View all Source files

peer.go

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