sets

package
v0.0.0-...-01875d1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 18, 2019 License: GPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL