hash

Documentation

Index

• Variables
• type Hash
  • func New(view types.View) *Hash
  • func (m *Hash) Get(key string) (string, error)
  • func (m *Hash) GetAny(key string) (string, error)
  • func (m *Hash) GetKeyShardId(key string) (int, error)
  • func (m *Hash) GetReplicas(id int) []string
  • func (m *Hash) GetReplicationFactor() int
  • func (m *Hash) GetShardId(member string) int
  • func (m *Hash) GetView() types.View
  • func (m *Hash) Members() []string
  • func (m *Hash) TestAndSet(view types.View) bool

Variables

var (
	ErrNoElements = errors.New("No elements to hash to")
)

Types

type Hash

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

Hash implements simple modulo hashing.

func New

func New(view types.View) *Hash

func (*Hash) Get

func (m *Hash) Get(key string) (string, error)

Get returns the address of the node that should store the given key.

func (*Hash) GetAny

func (m *Hash) GetAny(key string) (string, error)

GetAny returns any node that should be able to service a given key, even if that node is not the primary for a given key.

func (*Hash) GetKeyShardId

func (m *Hash) GetKeyShardId(key string) (int, error)

GetKeyShardId returns the shard that a key belongs to.

func (*Hash) GetReplicas

func (m *Hash) GetReplicas(id int) []string

GetReplicas returns the set of members in the given shard.

func (*Hash) GetReplicationFactor

func (m *Hash) GetReplicationFactor() int

func (*Hash) GetShardId

func (m *Hash) GetShardId(member string) int

GetShardId returns the shard ID of the given member.

func (*Hash) GetView

func (m *Hash) GetView() types.View

Returns view address and replication factor

func (*Hash) Members

func (m *Hash) Members() []string

Members returns the list of nodes in this hash.

func (*Hash) TestAndSet

func (m *Hash) TestAndSet(view types.View) bool

Test and set performs an atomic Set operation iff the new member slice is different than the old. Returns true if the member slice changed.