proxy

Documentation

Index

• Variables
• type Option
  • func WithDim(dim int) Option
  • func WithSearchTimeout(timeout time.Duration) Option
• type Proxy
  • func NewMQBasedProxy(topic string, addrs []string, prophetAddrs []string, opts ...Option) (Proxy, error)

Variables

var (
	// ErrTimeout timeout
	ErrTimeout = errors.New("timeout")
)

Types

type Option

type Option func(*options)

Option option

func WithDim

func WithDim(dim int) Option

WithDim with dim option

func WithSearchTimeout

func WithSearchTimeout(timeout time.Duration) Option

WithSearchTimeout with timeout option

type Proxy

type Proxy interface {
	UpdateWithIds(db uint64, extXid int64, extXb []float32) error
	AddWithIds(newXb []float32, newXids []int64) error
	Search(xq []float32) ([]uint64, []float32, []int64, error)
}

Proxy is proxy for versiondb

func NewMQBasedProxy

func NewMQBasedProxy(topic string, addrs []string, prophetAddrs []string, opts ...Option) (Proxy, error)

NewMQBasedProxy return a Proxy based on mq