internal

Documentation

Index

• type CommonIndex
  • func NewCommonIndex[T comparable]() *CommonIndex[T]
  • func (i *CommonIndex[T]) Clear()
  • func (i *CommonIndex[T]) Delete(id int)
  • func (i *CommonIndex[T]) Get(key any) ([]int, error)
  • func (i *CommonIndex[T]) Set(key any, id int) error
• type Indexer
  • func NewIndexer() *Indexer
  • func (i *Indexer) Clear()
  • func (i *Indexer) Resolve(indices Indices) []int
  • func (i *Indexer) Set(id int, indices Indices) error
  • func (i *Indexer) Unset(id int)
  • func (i *Indexer) WithIndex(name string, index core.Index) *Indexer
• type Indices
• type Set
  • func (s Set) Contains(id int) bool
  • func (s Set) Intersect(other Set) Set
  • func (s Set) Len() int
  • func (s Set) Less(i, j int) bool
  • func (s Set) Sort() Set
  • func (s Set) Swap(i, j int)
  • func (s Set) Unique() Set
• type UniqueIndex
  • func NewUniqueIndex[T comparable]() *UniqueIndex[T]
  • func (i *UniqueIndex[T]) Clear()
  • func (i *UniqueIndex[T]) Delete(id int)
  • func (i *UniqueIndex[T]) Get(key any) ([]int, error)
  • func (i *UniqueIndex[T]) Set(key any, id int) error

Types

type CommonIndex

type CommonIndex[T comparable] struct {
	// contains filtered or unexported fields
}

CommonIndex is a common implementation of Index. It is thread-safe. It is used by Bucket to provide indexes for its items. It supports the following operations:

• Get(T) ([]int, error)
• Set(T, int) error
• Remove(T, int) error
• Delete(key) error
• Clear()
• Exists(T) bool

func NewCommonIndex

func NewCommonIndex[T comparable]() *CommonIndex[T]

NewCommonIndex creates a new CommonIndex.

func (*CommonIndex[T]) Clear

func (i *CommonIndex[T]) Clear()

Clear clears the index.

func (*CommonIndex[T]) Delete

func (i *CommonIndex[T]) Delete(id int)

Delete deletes the item with the given ID.

func (*CommonIndex[T]) Get

func (i *CommonIndex[T]) Get(key any) ([]int, error)

Get returns the ID of the item with the given key. If the item does not exist, it returns Unknown.

func (*CommonIndex[T]) Set

func (i *CommonIndex[T]) Set(key any, id int) error

Set sets the ID of the item with the given key.

type Indexer

type Indexer struct {
	sync.RWMutex
	Indexes map[string]core.Index
}

Indexer is an index resolver. It is used to resolve a list of IDs that match a list of keys. It uses a map to store indexes by string keys. It is thread-safe. It is used by the Bucket to resolve the IDs of the objects that match a list of keys. It supports both unique and common indexes. It follows the builder pattern. It supports the following operations: - Set(int, map[string]interface{}): sets the IDs of the objects that match the given keys. - Resolve(...key): resolves the IDs of the objects that match the given keys. - Unset(id): removes the given ID from the indexes. - WithIndex(name, index): adds the given index to the indexer. - Clear(): clears the indexer.

func NewIndexer

func NewIndexer() *Indexer

NewIndexer returns a new Indexer.

func (*Indexer) Clear

func (i *Indexer) Clear()

Clear clears the indexer.

func (*Indexer) Resolve

func (i *Indexer) Resolve(indices Indices) []int

Resolve resolves the IDs of the objects that match the given keys. It returns an error if any of the indexes returns an error.

func (*Indexer) Set

func (i *Indexer) Set(id int, indices Indices) error

Set sets the IDs of the objects that match the given keys. It returns an error if any of the indexes returns an error.

func (*Indexer) Unset

func (i *Indexer) Unset(id int)

Unset removes the given ID from the indexes. It returns an error if any of the indexes returns an error.

func (*Indexer) WithIndex

func (i *Indexer) WithIndex(name string, index core.Index) *Indexer

WithIndex adds the given index to the indexer. It returns the indexer.

type Indices

type Indices map[string]interface{}

Indices is a map of index names to interfaces. It is used to provide indexes for an item when it is added to a bucket.

type Set

type Set []int

func (Set) Contains

func (s Set) Contains(id int) bool

func (Set) Intersect

func (s Set) Intersect(other Set) Set

func (Set) Len

func (s Set) Len() int

func (Set) Less

func (s Set) Less(i, j int) bool

func (Set) Sort

func (s Set) Sort() Set

func (Set) Swap

func (s Set) Swap(i, j int)

func (Set) Unique

func (s Set) Unique() Set

type UniqueIndex

type UniqueIndex[T comparable] struct {
	// contains filtered or unexported fields
}

UniqueIndex is a unique index. It implements the Index interface. It is thread-safe. It is used by Bucket to provide indexes for its items. It supports the following operations:

• Get(T) ([]int, error)
• Set(T, int) error
• Delete(int) error
• Clear()

func NewUniqueIndex

func NewUniqueIndex[T comparable]() *UniqueIndex[T]

NewUniqueIndex creates a new UniqueIndex.

func (*UniqueIndex[T]) Clear

func (i *UniqueIndex[T]) Clear()

Clear clears the index.

func (*UniqueIndex[T]) Delete

func (i *UniqueIndex[T]) Delete(id int)

Delete deletes the item with the given ID from the index.

func (*UniqueIndex[T]) Get

func (i *UniqueIndex[T]) Get(key any) ([]int, error)

Get returns the ID of the item with the given key.

func (*UniqueIndex[T]) Set

func (i *UniqueIndex[T]) Set(key any, id int) error

Set sets the ID of the item with the given key.