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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(n *vqueue) error
func WithDeleteBufferSize ¶
func WithErrGroup ¶
func WithInsertBufferSize ¶
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) IVQLen() int IVCLen() int DVQLen() int DVCLen() int }
Click to show internal directories.
Click to hide internal directories.