tau

package
v0.0.0-...-93ee6ed Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package tau is a generated protocol buffer package.

It is generated from these files:

cluster.proto
core.proto
datasets.proto
math.proto
search.proto

It has these top-level messages:

Node
EmptyRequest
EmptyResponse
GetDatasetRequest
CreateDatasetRequest
CreateDatasetWithPartitionsRequest
DeleteDatasetRequest
ListPartitionsRequest
BtreeIndexOptions
VoronoiIndexOptions
HnswIndexOptions
Index
CsvDataset
JsonDataset
Dataset
DatasetPartition
SearchRequest
SearchPartitionsRequest
SearchResultItem

Index

Constants

This section is empty.

Variables

View Source
var HnswSearchAlgorithm_name = map[int32]string{
	0: "SIMPLE",
	1: "HEURISTIC",
}
View Source
var HnswSearchAlgorithm_value = map[string]int32{
	"SIMPLE":    0,
	"HEURISTIC": 1,
}
View Source
var SpaceType_name = map[int32]string{
	0: "EUCLIDEAN",
	1: "MANHATTAN",
	2: "COSINE",
}
View Source
var SpaceType_value = map[string]int32{
	"EUCLIDEAN": 0,
	"MANHATTAN": 1,
	"COSINE":    2,
}

Functions

func RegisterDatasetsServiceServer

func RegisterDatasetsServiceServer(s *grpc.Server, srv DatasetsServiceServer)

func RegisterSearchServiceServer

func RegisterSearchServiceServer(s *grpc.Server, srv SearchServiceServer)

Types

type BtreeIndexOptions

type BtreeIndexOptions struct {
	NumTrees     int32 `protobuf:"varint,1,opt,name=num_trees,json=numTrees" json:"num_trees,omitempty"`
	MaxLeafItems int32 `protobuf:"varint,2,opt,name=max_leaf_items,json=maxLeafItems" json:"max_leaf_items,omitempty"`
}

func (*BtreeIndexOptions) Descriptor

func (*BtreeIndexOptions) Descriptor() ([]byte, []int)

func (*BtreeIndexOptions) GetMaxLeafItems

func (m *BtreeIndexOptions) GetMaxLeafItems() int32

func (*BtreeIndexOptions) GetNumTrees

func (m *BtreeIndexOptions) GetNumTrees() int32

func (*BtreeIndexOptions) ProtoMessage

func (*BtreeIndexOptions) ProtoMessage()

func (*BtreeIndexOptions) Reset

func (m *BtreeIndexOptions) Reset()

func (*BtreeIndexOptions) String

func (m *BtreeIndexOptions) String() string

type CreateDatasetRequest

type CreateDatasetRequest struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset" json:"dataset,omitempty"`
}

func (*CreateDatasetRequest) Descriptor

func (*CreateDatasetRequest) Descriptor() ([]byte, []int)

func (*CreateDatasetRequest) GetDataset

func (m *CreateDatasetRequest) GetDataset() *Dataset

func (*CreateDatasetRequest) ProtoMessage

func (*CreateDatasetRequest) ProtoMessage()

func (*CreateDatasetRequest) Reset

func (m *CreateDatasetRequest) Reset()

func (*CreateDatasetRequest) String

func (m *CreateDatasetRequest) String() string

type CreateDatasetWithPartitionsRequest

type CreateDatasetWithPartitionsRequest struct {
	Dataset    *Dataset            `protobuf:"bytes,1,opt,name=dataset" json:"dataset,omitempty"`
	Partitions []*DatasetPartition `protobuf:"bytes,2,rep,name=partitions" json:"partitions,omitempty"`
}

func (*CreateDatasetWithPartitionsRequest) Descriptor

func (*CreateDatasetWithPartitionsRequest) Descriptor() ([]byte, []int)

func (*CreateDatasetWithPartitionsRequest) GetDataset

func (*CreateDatasetWithPartitionsRequest) GetPartitions

func (*CreateDatasetWithPartitionsRequest) ProtoMessage

func (*CreateDatasetWithPartitionsRequest) ProtoMessage()

func (*CreateDatasetWithPartitionsRequest) Reset

func (*CreateDatasetWithPartitionsRequest) String

type CsvDataset

type CsvDataset struct {
}

func (*CsvDataset) Descriptor

func (*CsvDataset) Descriptor() ([]byte, []int)

func (*CsvDataset) ProtoMessage

func (*CsvDataset) ProtoMessage()

func (*CsvDataset) Reset

func (m *CsvDataset) Reset()

func (*CsvDataset) String

func (m *CsvDataset) String() string

type Dataset

type Dataset struct {
	Name          string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Path          string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	NumPartitions int32  `protobuf:"varint,3,opt,name=num_partitions,json=numPartitions" json:"num_partitions,omitempty"`
	NumReplicas   int32  `protobuf:"varint,4,opt,name=num_replicas,json=numReplicas" json:"num_replicas,omitempty"`
	Index         *Index `protobuf:"bytes,5,opt,name=index" json:"index,omitempty"`
	// Types that are valid to be assigned to Format:
	//	*Dataset_Csv
	//	*Dataset_Json
	Format isDataset_Format `protobuf_oneof:"format"`
}

func (*Dataset) Descriptor

func (*Dataset) Descriptor() ([]byte, []int)

func (*Dataset) GetCsv

func (m *Dataset) GetCsv() *CsvDataset

func (*Dataset) GetFormat

func (m *Dataset) GetFormat() isDataset_Format

func (*Dataset) GetIndex

func (m *Dataset) GetIndex() *Index

func (*Dataset) GetJson

func (m *Dataset) GetJson() *JsonDataset

func (*Dataset) GetName

func (m *Dataset) GetName() string

func (*Dataset) GetNumPartitions

func (m *Dataset) GetNumPartitions() int32

func (*Dataset) GetNumReplicas

func (m *Dataset) GetNumReplicas() int32

func (*Dataset) GetPath

func (m *Dataset) GetPath() string

func (*Dataset) ProtoMessage

func (*Dataset) ProtoMessage()

func (*Dataset) Reset

func (m *Dataset) Reset()

func (*Dataset) String

func (m *Dataset) String() string

func (*Dataset) XXX_OneofFuncs

func (*Dataset) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type DatasetPartition

type DatasetPartition struct {
	Id    int32    `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Files []string `protobuf:"bytes,2,rep,name=files" json:"files,omitempty"`
}

func (*DatasetPartition) Descriptor

func (*DatasetPartition) Descriptor() ([]byte, []int)

func (*DatasetPartition) GetFiles

func (m *DatasetPartition) GetFiles() []string

func (*DatasetPartition) GetId

func (m *DatasetPartition) GetId() int32

func (*DatasetPartition) ProtoMessage

func (*DatasetPartition) ProtoMessage()

func (*DatasetPartition) Reset

func (m *DatasetPartition) Reset()

func (*DatasetPartition) String

func (m *DatasetPartition) String() string

type Dataset_Csv

type Dataset_Csv struct {
	Csv *CsvDataset `protobuf:"bytes,6,opt,name=csv,oneof"`
}

type Dataset_Json

type Dataset_Json struct {
	Json *JsonDataset `protobuf:"bytes,7,opt,name=json,oneof"`
}

type DatasetsService_ListClient

type DatasetsService_ListClient interface {
	Recv() (*Dataset, error)
	grpc.ClientStream
}

type DatasetsService_ListPartitionsClient

type DatasetsService_ListPartitionsClient interface {
	Recv() (*DatasetPartition, error)
	grpc.ClientStream
}

type DatasetsService_ListPartitionsServer

type DatasetsService_ListPartitionsServer interface {
	Send(*DatasetPartition) error
	grpc.ServerStream
}

type DatasetsService_ListServer

type DatasetsService_ListServer interface {
	Send(*Dataset) error
	grpc.ServerStream
}

type DeleteDatasetRequest

type DeleteDatasetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*DeleteDatasetRequest) Descriptor

func (*DeleteDatasetRequest) Descriptor() ([]byte, []int)

func (*DeleteDatasetRequest) GetName

func (m *DeleteDatasetRequest) GetName() string

func (*DeleteDatasetRequest) ProtoMessage

func (*DeleteDatasetRequest) ProtoMessage()

func (*DeleteDatasetRequest) Reset

func (m *DeleteDatasetRequest) Reset()

func (*DeleteDatasetRequest) String

func (m *DeleteDatasetRequest) String() string

type EmptyRequest

type EmptyRequest struct {
}

func (*EmptyRequest) Descriptor

func (*EmptyRequest) Descriptor() ([]byte, []int)

func (*EmptyRequest) ProtoMessage

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) Reset

func (m *EmptyRequest) Reset()

func (*EmptyRequest) String

func (m *EmptyRequest) String() string

type EmptyResponse

type EmptyResponse struct {
}

func (*EmptyResponse) Descriptor

func (*EmptyResponse) Descriptor() ([]byte, []int)

func (*EmptyResponse) ProtoMessage

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset

func (m *EmptyResponse) Reset()

func (*EmptyResponse) String

func (m *EmptyResponse) String() string

type GetDatasetRequest

type GetDatasetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*GetDatasetRequest) Descriptor

func (*GetDatasetRequest) Descriptor() ([]byte, []int)

func (*GetDatasetRequest) GetName

func (m *GetDatasetRequest) GetName() string

func (*GetDatasetRequest) ProtoMessage

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) Reset

func (m *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String

func (m *GetDatasetRequest) String() string

type HnswIndexOptions

type HnswIndexOptions struct {
	SearchAlgorithm HnswSearchAlgorithm `` /* 129-byte string literal not displayed */
	LevelMultiplier float32             `protobuf:"fixed32,2,opt,name=level_multiplier,json=levelMultiplier" json:"level_multiplier,omitempty"`
	Ef              int32               `protobuf:"varint,3,opt,name=ef" json:"ef,omitempty"`
	EfConstruction  int32               `protobuf:"varint,4,opt,name=ef_construction,json=efConstruction" json:"ef_construction,omitempty"`
	M               int32               `protobuf:"varint,5,opt,name=m" json:"m,omitempty"`
	MMax            int32               `protobuf:"varint,6,opt,name=m_max,json=mMax" json:"m_max,omitempty"`
	MMax_0          int32               `protobuf:"varint,7,opt,name=m_max_0,json=mMax0" json:"m_max_0,omitempty"`
}

func (*HnswIndexOptions) Descriptor

func (*HnswIndexOptions) Descriptor() ([]byte, []int)

func (*HnswIndexOptions) GetEf

func (m *HnswIndexOptions) GetEf() int32

func (*HnswIndexOptions) GetEfConstruction

func (m *HnswIndexOptions) GetEfConstruction() int32

func (*HnswIndexOptions) GetLevelMultiplier

func (m *HnswIndexOptions) GetLevelMultiplier() float32

func (*HnswIndexOptions) GetM

func (m *HnswIndexOptions) GetM() int32

func (*HnswIndexOptions) GetMMax

func (m *HnswIndexOptions) GetMMax() int32

func (*HnswIndexOptions) GetMMax_0

func (m *HnswIndexOptions) GetMMax_0() int32

func (*HnswIndexOptions) GetSearchAlgorithm

func (m *HnswIndexOptions) GetSearchAlgorithm() HnswSearchAlgorithm

func (*HnswIndexOptions) ProtoMessage

func (*HnswIndexOptions) ProtoMessage()

func (*HnswIndexOptions) Reset

func (m *HnswIndexOptions) Reset()

func (*HnswIndexOptions) String

func (m *HnswIndexOptions) String() string

type HnswSearchAlgorithm

type HnswSearchAlgorithm int32
const (
	HnswSearchAlgorithm_SIMPLE    HnswSearchAlgorithm = 0
	HnswSearchAlgorithm_HEURISTIC HnswSearchAlgorithm = 1
)

func (HnswSearchAlgorithm) EnumDescriptor

func (HnswSearchAlgorithm) EnumDescriptor() ([]byte, []int)

func (HnswSearchAlgorithm) String

func (x HnswSearchAlgorithm) String() string

type Index

type Index struct {
	Size  int32     `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	Space SpaceType `protobuf:"varint,2,opt,name=space,enum=tau.SpaceType" json:"space,omitempty"`
	// Types that are valid to be assigned to Options:
	//	*Index_Btree
	//	*Index_Voronoi
	//	*Index_Hnsw
	Options isIndex_Options `protobuf_oneof:"options"`
}

func (*Index) Descriptor

func (*Index) Descriptor() ([]byte, []int)

func (*Index) GetBtree

func (m *Index) GetBtree() *BtreeIndexOptions

func (*Index) GetHnsw

func (m *Index) GetHnsw() *HnswIndexOptions

func (*Index) GetOptions

func (m *Index) GetOptions() isIndex_Options

func (*Index) GetSize

func (m *Index) GetSize() int32

func (*Index) GetSpace

func (m *Index) GetSpace() SpaceType

func (*Index) GetVoronoi

func (m *Index) GetVoronoi() *VoronoiIndexOptions

func (*Index) ProtoMessage

func (*Index) ProtoMessage()

func (*Index) Reset

func (m *Index) Reset()

func (*Index) String

func (m *Index) String() string

func (*Index) XXX_OneofFuncs

func (*Index) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Index_Btree

type Index_Btree struct {
	Btree *BtreeIndexOptions `protobuf:"bytes,3,opt,name=btree,oneof"`
}

type Index_Hnsw

type Index_Hnsw struct {
	Hnsw *HnswIndexOptions `protobuf:"bytes,5,opt,name=hnsw,oneof"`
}

type Index_Voronoi

type Index_Voronoi struct {
	Voronoi *VoronoiIndexOptions `protobuf:"bytes,4,opt,name=voronoi,oneof"`
}

type JsonDataset

type JsonDataset struct {
}

func (*JsonDataset) Descriptor

func (*JsonDataset) Descriptor() ([]byte, []int)

func (*JsonDataset) ProtoMessage

func (*JsonDataset) ProtoMessage()

func (*JsonDataset) Reset

func (m *JsonDataset) Reset()

func (*JsonDataset) String

func (m *JsonDataset) String() string

type ListPartitionsRequest

type ListPartitionsRequest struct {
	DatasetName string `protobuf:"bytes,1,opt,name=dataset_name,json=datasetName" json:"dataset_name,omitempty"`
}

func (*ListPartitionsRequest) Descriptor

func (*ListPartitionsRequest) Descriptor() ([]byte, []int)

func (*ListPartitionsRequest) GetDatasetName

func (m *ListPartitionsRequest) GetDatasetName() string

func (*ListPartitionsRequest) ProtoMessage

func (*ListPartitionsRequest) ProtoMessage()

func (*ListPartitionsRequest) Reset

func (m *ListPartitionsRequest) Reset()

func (*ListPartitionsRequest) String

func (m *ListPartitionsRequest) String() string

type Node

type Node struct {
	Uuid      string `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"`
	IpAddress string `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress" json:"ip_address,omitempty"`
	Port      string `protobuf:"bytes,3,opt,name=port" json:"port,omitempty"`
}

func (*Node) Descriptor

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetIpAddress

func (m *Node) GetIpAddress() string

func (*Node) GetPort

func (m *Node) GetPort() string

func (*Node) GetUuid

func (m *Node) GetUuid() string

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) String

func (m *Node) String() string

type SearchPartitionsRequest

type SearchPartitionsRequest struct {
	DatasetName string    `protobuf:"bytes,1,opt,name=dataset_name,json=datasetName" json:"dataset_name,omitempty"`
	K           int32     `protobuf:"varint,2,opt,name=k" json:"k,omitempty"`
	Query       []float32 `protobuf:"fixed32,3,rep,packed,name=query" json:"query,omitempty"`
	Partitions  []string  `protobuf:"bytes,4,rep,name=partitions" json:"partitions,omitempty"`
}

func (*SearchPartitionsRequest) Descriptor

func (*SearchPartitionsRequest) Descriptor() ([]byte, []int)

func (*SearchPartitionsRequest) GetDatasetName

func (m *SearchPartitionsRequest) GetDatasetName() string

func (*SearchPartitionsRequest) GetK

func (m *SearchPartitionsRequest) GetK() int32

func (*SearchPartitionsRequest) GetPartitions

func (m *SearchPartitionsRequest) GetPartitions() []string

func (*SearchPartitionsRequest) GetQuery

func (m *SearchPartitionsRequest) GetQuery() []float32

func (*SearchPartitionsRequest) ProtoMessage

func (*SearchPartitionsRequest) ProtoMessage()

func (*SearchPartitionsRequest) Reset

func (m *SearchPartitionsRequest) Reset()

func (*SearchPartitionsRequest) String

func (m *SearchPartitionsRequest) String() string

type SearchRequest

type SearchRequest struct {
	DatasetName string    `protobuf:"bytes,1,opt,name=dataset_name,json=datasetName" json:"dataset_name,omitempty"`
	K           int32     `protobuf:"varint,2,opt,name=k" json:"k,omitempty"`
	Query       []float32 `protobuf:"fixed32,3,rep,packed,name=query" json:"query,omitempty"`
}

func (*SearchRequest) Descriptor

func (*SearchRequest) Descriptor() ([]byte, []int)

func (*SearchRequest) GetDatasetName

func (m *SearchRequest) GetDatasetName() string

func (*SearchRequest) GetK

func (m *SearchRequest) GetK() int32

func (*SearchRequest) GetQuery

func (m *SearchRequest) GetQuery() []float32

func (*SearchRequest) ProtoMessage

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset

func (m *SearchRequest) Reset()

func (*SearchRequest) String

func (m *SearchRequest) String() string

type SearchResultItem

type SearchResultItem struct {
	Id       int64   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Distance float32 `protobuf:"fixed32,2,opt,name=distance" json:"distance,omitempty"`
}

func (*SearchResultItem) Descriptor

func (*SearchResultItem) Descriptor() ([]byte, []int)

func (*SearchResultItem) GetDistance

func (m *SearchResultItem) GetDistance() float32

func (*SearchResultItem) GetId

func (m *SearchResultItem) GetId() int64

func (*SearchResultItem) ProtoMessage

func (*SearchResultItem) ProtoMessage()

func (*SearchResultItem) Reset

func (m *SearchResultItem) Reset()

func (*SearchResultItem) String

func (m *SearchResultItem) String() string

type SearchServiceClient

type SearchServiceClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (SearchService_SearchClient, error)
	SearchPartitions(ctx context.Context, in *SearchPartitionsRequest, opts ...grpc.CallOption) (SearchService_SearchPartitionsClient, error)
}

func NewSearchServiceClient

func NewSearchServiceClient(cc *grpc.ClientConn) SearchServiceClient

type SearchService_SearchClient

type SearchService_SearchClient interface {
	Recv() (*SearchResultItem, error)
	grpc.ClientStream
}

type SearchService_SearchPartitionsClient

type SearchService_SearchPartitionsClient interface {
	Recv() (*SearchResultItem, error)
	grpc.ClientStream
}

type SearchService_SearchPartitionsServer

type SearchService_SearchPartitionsServer interface {
	Send(*SearchResultItem) error
	grpc.ServerStream
}

type SearchService_SearchServer

type SearchService_SearchServer interface {
	Send(*SearchResultItem) error
	grpc.ServerStream
}

type SpaceType

type SpaceType int32
const (
	SpaceType_EUCLIDEAN SpaceType = 0
	SpaceType_MANHATTAN SpaceType = 1
	SpaceType_COSINE    SpaceType = 2
)

func (SpaceType) EnumDescriptor

func (SpaceType) EnumDescriptor() ([]byte, []int)

func (SpaceType) String

func (x SpaceType) String() string

type VoronoiIndexOptions

type VoronoiIndexOptions struct {
	SplitFactor  int32 `protobuf:"varint,1,opt,name=split_factor,json=splitFactor" json:"split_factor,omitempty"`
	MaxCellItems int32 `protobuf:"varint,2,opt,name=max_cell_items,json=maxCellItems" json:"max_cell_items,omitempty"`
}

func (*VoronoiIndexOptions) Descriptor

func (*VoronoiIndexOptions) Descriptor() ([]byte, []int)

func (*VoronoiIndexOptions) GetMaxCellItems

func (m *VoronoiIndexOptions) GetMaxCellItems() int32

func (*VoronoiIndexOptions) GetSplitFactor

func (m *VoronoiIndexOptions) GetSplitFactor() int32

func (*VoronoiIndexOptions) ProtoMessage

func (*VoronoiIndexOptions) ProtoMessage()

func (*VoronoiIndexOptions) Reset

func (m *VoronoiIndexOptions) Reset()

func (*VoronoiIndexOptions) String

func (m *VoronoiIndexOptions) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL