search

Documentation

Index

• Constants
• Variables
• func IsSearchError(err error) bool
• func NewSearchError(httpCode int, code ErrCode, msg string, args ...interface{}) error
• type ErrCode
• type Error
  • func (se Error) Error() string
• type IndexDocumentsOptions
• type NoopStore
  • func (n *NoopStore) CreateCollection(context.Context, *tsApi.CollectionSchema) error
  • func (n *NoopStore) DeleteDocuments(context.Context, string, string) error
  • func (n *NoopStore) DropCollection(context.Context, string) error
  • func (n *NoopStore) IndexDocuments(context.Context, string, io.Reader, IndexDocumentsOptions) error
  • func (n *NoopStore) Search(context.Context, string, *qsearch.Query, int) ([]tsApi.SearchResult, error)
  • func (n *NoopStore) UpdateCollection(context.Context, string, *tsApi.CollectionUpdateSchema) error
• type Store
  • func NewStore(config *config.SearchConfig) (Store, error)
  • func NewStoreWithMetrics(config *config.SearchConfig) (Store, error)

Constants

const StreamContentType = "application/x-json-stream"

Variables

var (
	ErrDuplicateEntity = NewSearchError(http.StatusConflict, ErrCodeDuplicate, "entity already exists")
	ErrNotFound        = NewSearchError(http.StatusNotFound, ErrCodeNotFound, "not found")
)

Functions

func IsSearchError

func IsSearchError(err error) bool

func NewSearchError

func NewSearchError(httpCode int, code ErrCode, msg string, args ...interface{}) error

Types

type ErrCode

type ErrCode byte

const (
	ErrCodeInvalid           ErrCode = 0x00
	ErrCodeDuplicate         ErrCode = 0x01
	ErrCodeNotFound          ErrCode = 0x02
	ErrCodeIndexingDocuments ErrCode = 0x03
	ErrCodeUnhandled         ErrCode = 0x04
)

type Error

type Error struct {
	// contains filtered or unexported fields
}

func (Error) Error

func (se Error) Error() string

type IndexDocumentsOptions

type IndexDocumentsOptions struct {
	Action    string
	BatchSize int
}

type NoopStore

type NoopStore struct{}

func (*NoopStore) CreateCollection

func (n *NoopStore) CreateCollection(context.Context, *tsApi.CollectionSchema) error

func (*NoopStore) DeleteDocuments

func (n *NoopStore) DeleteDocuments(context.Context, string, string) error

func (*NoopStore) DropCollection

func (n *NoopStore) DropCollection(context.Context, string) error

func (*NoopStore) IndexDocuments

func (n *NoopStore) IndexDocuments(context.Context, string, io.Reader, IndexDocumentsOptions) error

func (*NoopStore) Search

func (n *NoopStore) Search(context.Context, string, *qsearch.Query, int) ([]tsApi.SearchResult, error)

func (*NoopStore) UpdateCollection

func (n *NoopStore) UpdateCollection(context.Context, string, *tsApi.CollectionUpdateSchema) error

type Store

type Store interface {
	CreateCollection(ctx context.Context, schema *tsApi.CollectionSchema) error
	UpdateCollection(ctx context.Context, name string, schema *tsApi.CollectionUpdateSchema) error
	DropCollection(ctx context.Context, table string) error
	IndexDocuments(ctx context.Context, table string, documents io.Reader, options IndexDocumentsOptions) error
	DeleteDocuments(ctx context.Context, table string, key string) error
	Search(ctx context.Context, table string, query *qsearch.Query, pageNo int) ([]tsApi.SearchResult, error)
}

func NewStore

func NewStore(config *config.SearchConfig) (Store, error)

func NewStoreWithMetrics

func NewStoreWithMetrics(config *config.SearchConfig) (Store, error)