priamCassandra

package

v0.0.0-...-168b963 Latest Latest Go to latest Published: Dec 20, 2016 License: Apache-2.0 Imports: 12 Imported by: 1

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

Package priamCassandra simulates a cassandra cluster with NetflixOSS Priam Takes incoming traffic and calls into cross zone and cross region nodes

This section is empty.

This section is empty.

func Distribute(cass map[string]chan gotocol.Message) string

Distribute tokens to one zone of a cassandra cluster, this doesn't yet allow for clusters to grow or replace nodes

func Start(listener chan gotocol.Message)

Start priamCassandra, all configuration and state is sent via messages

type ByToken []node

ByToken ring of node names sorted by token

func RingConfig(m string) ByToken

RingConfig gets the tokens for a ring

func (a ByToken) Find(h uint32) int

Find the node in the ring for a token

func (a ByToken) Len() int

implement node array sortable by Token interface

func (a ByToken) Less(i, j int) bool

func (a ByToken) Swap(i, j int)