chash

Apr 14, 2023

Changes in this version

+ func RemoveAllGroup()

Apr 14, 2023

Changes in this version

type CHash

+ func (c *CHash) RemoveAllGroup()

Apr 14, 2023

Changes in this version

type Group

+ func (b *Group) Upsert(key string, payload []byte) error

Apr 6, 2023

Changes in this version

type Group

+ func (b *Group) GetElements() []*Element

Apr 5, 2023

Changes in this version

+ type Circle []uint32

+ func (idx Circle) Len() int

+ func (idx Circle) Less(i, j int) bool

+ func (idx Circle) Match(target uint32) (int, bool)

+ func (idx Circle) Search(target uint32) (int, bool)

+ func (idx Circle) Sort()

+ func (idx Circle) Swap(i, j int)

+ type Element struct

+ Key string

+ Payload []byte

type Group

+ Elements map[string]*Element

Apr 5, 2023

Changes in this version

+ var ErrGroupExisted = err

+ var ErrGroupNotFound = err

+ func RemoveGroup(groupName string)

type CHash

+ func (c *CHash) CreateGroup(groupName string, replicas int) (*Group, error)

+ func (c *CHash) Delete(groupName string, key string) error

+ func (c *CHash) GetGroup(groupName string) (*Group, error)

+ func (c *CHash) Insert(groupName string, key string, payload []byte) error

+ func (c *CHash) RemoveGroup(groupName string)

+ type Group struct

+ Agents map[string]*Agent

+ Name string

+ NumberOfReplicas int

+ func CreateGroup(groupName string, replicas int) (*Group, error)

+ func GetGroup(groupName string) (*Group, error)

+ func NewGroup(name string, replicas int) *Group

+ func (b *Group) Delete(key string) error

+ func (b *Group) Init()

+ func (b *Group) Insert(key string, payload []byte) error

+ func (b *Group) Match(key string) (string, []byte, error)

Apr 4, 2023

Changes in this version

+ func Restore(data []byte) error

+ func Serialize() ([]byte, error)

type Bucket

+ func GetBucket(bucketName string) (*Bucket, error)

Apr 3, 2023

Changes in this version

+ var ErrKeyExisted = err

Apr 3, 2023

Changes in this version

+ var ErrBucketExisted = err

+ var ErrBucketNotFound = err

+ var ErrNoResultMatched = err

+ type Agent struct

+ Key string

+ Payload []byte

+ type Bucket struct

+ Agents map[string]*Agent

+ Name string

+ NumberOfReplicas int

+ func CreateBucket(bucketName string, replicas int) (*Bucket, error)

+ func NewBucket(name string, replicas int, handler Handler) *Bucket

+ func (b *Bucket) Delete(key string) error

+ func (b *Bucket) Init()

+ func (b *Bucket) Insert(key string, payload []byte) error

+ func (b *Bucket) Match(key string) (string, []byte, error)

+ func (b *Bucket) SetHandler(handler Handler)

+ type CHash struct

+ func New() *CHash

+ func (c *CHash) CreateBucket(bucketName string, replicas int) error

+ func (c *CHash) DeleteAgent(bucketName string, key string) error

+ func (c *CHash) GetBucket(bucketName string) (*Bucket, error)

+ func (c *CHash) InsertAgent(bucketName string, key string, payload []byte) error

+ func (c *CHash) Match(bucketName string, key string) (string, []byte, error)

+ func (c *CHash) RemoveBucket(bucketName string) error

+ func (c *CHash) Restore(data []byte) error

+ func (c *CHash) Serialize() ([]byte, error)

+ func (c *CHash) SetHandler(handler Handler)

+ type Handler interface

+ OnAgentDelete func(name string, agent *Agent) error

+ OnAgentInsert func(name string, agent *Agent) error

+ OnBucketCreate func(bucket *Bucket) error

+ OnBucketRemove func(bucket *Bucket) error

+ type Indexes []uint32

+ func (idx Indexes) Len() int

+ func (idx Indexes) Less(i, j int) bool

+ func (idx Indexes) Match(target uint32) (int, bool)

+ func (idx Indexes) Search(target uint32) (int, bool)

+ func (idx Indexes) Sort()

+ func (idx Indexes) Swap(i, j int)