sets

Documentation

Index

• type DiffChannels
• type IndividualSet
  • func (is *IndividualSet) Add(item []byte) (err error)
  • func (is *IndividualSet) Contains(key []byte) bool
  • func (is *IndividualSet) Remove(item []byte) (err error)
  • func (is *IndividualSet) Scan(f func(item []byte) bool) (err error)
  • func (is *IndividualSet) ScanRange(start, limit []byte, f func(item []byte) bool) (err error)
• type MutableSortedSet
• type ObservableSortedSet
• type SharedSet
  • func NewSharedSet(kvs kvstore.SortedStore) (*SharedSet, error)
  • func (ss *SharedSet) Contains(key []byte) bool
  • func (ss *SharedSet) DeleteSetFor(who friends.ID) (err error)
  • func (ss *SharedSet) DiffChannels() DiffChannels
  • func (ss *SharedSet) GetSetFor(who friends.ID) IndividualSet
  • func (ss *SharedSet) Scan(f func(item []byte) bool) (err error)
  • func (ss *SharedSet) ScanRange(start, limit []byte, f func(item []byte) bool) (err error)
• type SharedSetState
• type SimpleSet
  • func NewSimpleSet(kvs kvstore.SortedStore) SimpleSet
  • func (ss *SimpleSet) Add(key []byte) error
  • func (ss *SimpleSet) Contains(key []byte) bool
  • func (ss *SimpleSet) Remove(key []byte) error
  • func (ss *SimpleSet) Scan(f func(item []byte) bool) error
  • func (ss *SimpleSet) ScanRange(start, stop []byte, f func(item []byte) bool) error
• type SortedSet

Types

type DiffChannels

type DiffChannels struct {
	Adds, Deletes chan []byte
}

type IndividualSet

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

func (*IndividualSet) Add

func (is *IndividualSet) Add(item []byte) (err error)

func (*IndividualSet) Contains

func (is *IndividualSet) Contains(key []byte) bool

func (*IndividualSet) Remove

func (is *IndividualSet) Remove(item []byte) (err error)

func (*IndividualSet) Scan

func (is *IndividualSet) Scan(f func(item []byte) bool) (err error)

func (*IndividualSet) ScanRange

func (is *IndividualSet) ScanRange(start, limit []byte, f func(item []byte) bool) (err error)

type MutableSortedSet

type MutableSortedSet interface {
	Add([]byte) error
	Remove([]byte) error
	SortedSet
}

type ObservableSortedSet

type ObservableSortedSet interface {
	SortedSet
	DiffChannels() DiffChannels
}

type SharedSet

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

func NewSharedSet

func NewSharedSet(kvs kvstore.SortedStore) (*SharedSet, error)

func (*SharedSet) Contains

func (ss *SharedSet) Contains(key []byte) bool

func (*SharedSet) DeleteSetFor

func (ss *SharedSet) DeleteSetFor(who friends.ID) (err error)

func (*SharedSet) DiffChannels

func (ss *SharedSet) DiffChannels() DiffChannels

func (*SharedSet) GetSetFor

func (ss *SharedSet) GetSetFor(who friends.ID) IndividualSet

func (*SharedSet) Scan

func (ss *SharedSet) Scan(f func(item []byte) bool) (err error)

func (*SharedSet) ScanRange

func (ss *SharedSet) ScanRange(start, limit []byte, f func(item []byte) bool) (err error)

type SharedSetState

type SharedSetState struct {
	NextPos    int
	Person2Pos map[friends.ID]int
}

type SimpleSet

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

func NewSimpleSet

func NewSimpleSet(kvs kvstore.SortedStore) SimpleSet

func (*SimpleSet) Add

func (ss *SimpleSet) Add(key []byte) error

func (*SimpleSet) Contains

func (ss *SimpleSet) Contains(key []byte) bool

func (*SimpleSet) Remove

func (ss *SimpleSet) Remove(key []byte) error

func (*SimpleSet) Scan

func (ss *SimpleSet) Scan(f func(item []byte) bool) error

func (*SimpleSet) ScanRange

func (ss *SimpleSet) ScanRange(start, stop []byte, f func(item []byte) bool) error

type SortedSet

type SortedSet interface {
	Scan(f func(item []byte) bool) error
	ScanRange(start, limit []byte, f func(item []byte) bool) error
	Contains(key []byte) bool
}