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.
Copyright (C) 2019-2022 vdaas.org vald team <vald@vdaas.org>
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
https://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright (C) 2019-2022 vdaas.org vald team <vald@vdaas.org>
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
https://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
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
Option represents the functional option for vqueue.
func WithDeleteBufferPoolSize ¶
WithDeleteBufferPoolSize returns the option to set the pool size of the delete buffer.
func WithErrGroup ¶
WithErrGroup returns the option to set the errgroup.
func WithInsertBufferPoolSize ¶
WithInsertBufferPoolSize returns the option to set the pool size of the insert buffer.
type Queue ¶
type Queue interface {
PushInsert(uuid string, vector []float32, date int64) error
PushDelete(uuid string, date int64) error
GetVector(uuid string) ([]float32, bool)
RangePopInsert(ctx context.Context, now int64, f func(uuid string, vector []float32) bool)
RangePopDelete(ctx context.Context, now int64, f func(uuid string) bool)
IVExists(uuid string) bool
DVExists(uuid string) bool
IVQLen() int
DVQLen() int
}
Queue
Source Files