query

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

type CacheMetrics struct {
	// OpsDuration tracks overall duration of each cache operation.
	OpsDuration *prometheus.HistogramVec
	CacheMiss   *prometheus.CounterVec

	// UsageCalcDuration tracks `usage()` calls that sits in both read and write path.
	UsageCalcDuration prometheus.Histogram
}

type Config struct {
	GRPCListenAddr string `long:"grpc.listen" description:"gRPC address that query node listens at" default:"0.0.0.0:7071"`
	SchemaAddr     string `long:"schema.addr" description:"address to get schema information" default:"http://0.0.0.0:8080"`
	S3URL          string `long:"s3.url" description:"s3 URL to query offloaded tenants (e.g: s3://<url>)"`
	S3Endpoint     string `long:"s3.endpoint" description:"s3 endpoint to if mocking s3 (e.g: via minio)"`

	// NOTE(kavi): This `DataPath` makes `querier` statefulset. Depend on disk to serve query reqeust.
	// Main rationale is, we first download the objects from object store and put it on local disk
	// We need this, to make it work with existing query helpers, where we assume we serve query from
	// local disk. This will go away eventually once we start reading from object store into memory directly.
	DataPath string `long:"datapath" description:"place to look for tenant data after downloading it from object storage" default:"/tmp/weaviate"`

	VectorizerAddr string `long:"vectorize-addr" description:"vectorizer address to be used to vectorize near-text query" default:"0.0.0.0:9999"`

	// MetadataGRPCAddress is the host which will be used to connect to the metadata node's gRPC server.
	// Note that this should be replaced later to avoid having a single metadata node as a single point of failure.
	// If MetadataGRPCAddress is empty, the querier will connect to localhost.
	MetadataGRPCAddress string `long:"metadata.grpc.address" description:"metadata grpc address" default:":9050"`

	NoCache        bool  `long:"no-cache" description:"disable disk based cache on query path"`
	CacheMaxSizeGB int64 `long:"cache-max-size" description:"max size allocated for cache in GBs. More than this start evicting the cache" default:"20"`
}

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

type GRPC struct {

	// TODO(kavi): This should go away once we split v1.WeaviateServer into composable v1.Searcher
	protocol.UnimplementedWeaviateServer
	// contains filtered or unexported fields
}

type LSMCache interface {
	// get tenant
	Tenant(collection, tenantID string) (*TenantCache, error)

	// put tenant
	AddTenant(collection, tenantID string, version int64) error

	BasePath() string
}

type LSMDownloader interface {
	DownloadToPath(ctx context.Context, collection, tenant, nodeName, path string) error
}

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

type Result struct {
	Obj       *storobj.Object
	Certainty float64
}

type SchemaQuerier interface {
	// TenantStatus returns (STATUS, BELONGSTONODES, VERSION) tuple
	TenantStatus(ctx context.Context, collection, tenant string) (string, []string, int64, error)
	Collection(ctx context.Context, collection string) (*models.Class, error)
}

type SearchRequest struct {
	Collection string
	// if class is not nil, try avoid getting the class again from schema
	Class     *models.Class
	Tenant    string
	NearText  []string // vector search
	Certainty float64  // threshold to match with certainty of vectors match
	Limit     int
	Filters   *filters.LocalFilter
}

type SearchResponse struct {
	Results []Result
}

type TenantCache struct {
	Collection   string
	TenantID     string
	Version      int64
	LastAccessed time.Time
	// contains filtered or unexported fields
}