service

Documentation

Overview

Package service manages the main logic of server.

Package service manages the main logic of server.

Index

• type NGT
  • func New(cfg *config.NGT, opts ...Option) (nn NGT, err error)
• type Option
  • func WithAutoIndexCheckDuration(dur string) Option
  • func WithAutoIndexDurationLimit(dur string) Option
  • func WithAutoIndexLength(l int) Option
  • func WithAutoSaveIndexDuration(dur string) Option
  • func WithDefaultEpsilon(epsilon float32) Option
  • func WithDefaultPoolSize(ps uint32) Option
  • func WithDefaultRadius(rad float32) Option
  • func WithEnableInMemoryMode(enabled bool) Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithIndexPath(path string) Option
  • func WithInitialDelayMaxDuration(dur string) Option
  • func WithLoadIndexTimeoutFactor(dur string) Option
  • func WithMaxLoadIndexTimeout(dur string) Option
  • func WithMinLoadIndexTimeout(dur string) Option
  • func WithProactiveGC(enabled bool) Option

Types

type NGT

type NGT interface {
	Start(ctx context.Context) <-chan error
	Search(vec []float32, size uint32, epsilon, radius float32) ([]model.Distance, error)
	SearchByID(uuid string, size uint32, epsilon, radius float32) ([]model.Distance, error)
	Insert(uuid string, vec []float32) (err error)
	InsertMultiple(vecs map[string][]float32) (err error)
	Update(uuid string, vec []float32) (err error)
	UpdateMultiple(vecs map[string][]float32) (err error)
	Delete(uuid string) (err error)
	DeleteMultiple(uuids ...string) (err error)
	GetObject(uuid string) (vec []float32, err error)
	CreateIndex(ctx context.Context, poolSize uint32) (err error)
	SaveIndex(ctx context.Context) (err error)
	Exists(string) (uint32, bool)
	CreateAndSaveIndex(ctx context.Context, poolSize uint32) (err error)
	IsIndexing() bool
	IsSaving() bool
	Len() uint64
	NumberOfCreateIndexExecution() uint64
	NumberOfProactiveGCExecution() uint64
	UUIDs(context.Context) (uuids []string)
	DeleteVQueueBufferLen() uint64
	InsertVQueueBufferLen() uint64
	DeleteVQueueChannelLen() uint64
	InsertVQueueChannelLen() uint64
	GetDimensionSize() int
	Close(ctx context.Context) error
}

func New

func New(cfg *config.NGT, opts ...Option) (nn NGT, err error)

type Option

type Option func(n *ngt) error

func WithAutoIndexCheckDuration

func WithAutoIndexCheckDuration(dur string) Option

func WithAutoIndexDurationLimit

func WithAutoIndexDurationLimit(dur string) Option

func WithAutoIndexLength

func WithAutoIndexLength(l int) Option

func WithAutoSaveIndexDuration

func WithAutoSaveIndexDuration(dur string) Option

func WithDefaultEpsilon

func WithDefaultEpsilon(epsilon float32) Option

func WithDefaultPoolSize

func WithDefaultPoolSize(ps uint32) Option

func WithDefaultRadius

func WithDefaultRadius(rad float32) Option

func WithEnableInMemoryMode

func WithEnableInMemoryMode(enabled bool) Option

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

func WithIndexPath

func WithIndexPath(path string) Option

func WithInitialDelayMaxDuration

func WithInitialDelayMaxDuration(dur string) Option

func WithLoadIndexTimeoutFactor

func WithLoadIndexTimeoutFactor(dur string) Option

func WithMaxLoadIndexTimeout

func WithMaxLoadIndexTimeout(dur string) Option

func WithMinLoadIndexTimeout

func WithMinLoadIndexTimeout(dur string) Option

func WithProactiveGC

func WithProactiveGC(enabled bool) Option