vqueue

Documentation

Overview

Package vqueue manages the vector cache layer for reducing FFI overhead for fast Agent processing.

Package vqueue manages the vector cache layer for reducing FFI overhead for fast Agent processing.

Index

• type Option
  • func WithDeleteBufferPoolSize(size int) Option
  • func WithDeleteBufferSize(size int) Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithInsertBufferPoolSize(size int) Option
  • func WithInsertBufferSize(size int) Option
• type Queue
  • func New(opts ...Option) (Queue, error)

Types

type Option

type Option func(n *vqueue) error

func WithDeleteBufferPoolSize

func WithDeleteBufferPoolSize(size int) Option

func WithDeleteBufferSize

func WithDeleteBufferSize(size int) Option

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

func WithInsertBufferPoolSize

func WithInsertBufferPoolSize(size int) Option

func WithInsertBufferSize

func WithInsertBufferSize(size int) Option

type Queue

type Queue interface {
	Start(ctx context.Context) (<-chan error, error)
	PushInsert(uuid string, vector []float32, date int64) error
	PushDelete(uuid string, date int64) error
	GetVector(uuid string) ([]float32, bool)
	RangePopInsert(ctx context.Context, f func(uuid string, vector []float32) bool)
	RangePopDelete(ctx context.Context, f func(uuid string) bool)
	IVExists(uuid string) bool
	DVExists(uuid string) bool
	IVQLen() int
	IVCLen() int
	DVQLen() int
	DVCLen() int
}

Queue

func New

func New(opts ...Option) (Queue, error)