priamCassandra

Documentation

Overview

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

Index

• func Distribute(cass map[string]chan gotocol.Message) string
• func Start(listener chan gotocol.Message)
• type ByToken
  • func RingConfig(m string) ByToken
  • func (a ByToken) Find(h uint32) int
  • func (a ByToken) Len() int
  • func (a ByToken) Less(i, j int) bool
  • func (a ByToken) Swap(i, j int)

Functions

func Distribute

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

func Start(listener chan gotocol.Message)

Start priamCassandra, all configuration and state is sent via messages

Types

type ByToken

type ByToken []node

ByToken ring of node names sorted by token

func RingConfig

func RingConfig(m string) ByToken

RingConfig gets the tokens for a ring

func (ByToken) Find

func (a ByToken) Find(h uint32) int

Find the node in the ring for a token

func (ByToken) Len

func (a ByToken) Len() int

implement node array sortable by Token interface

func (ByToken) Less

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

func (ByToken) Swap

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