coordinatorpb

package
v0.0.0-...-64e0c52 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MetadataReader_QueryMetadata_FullMethodName = "/chroma.MetadataReader/QueryMetadata"
	MetadataReader_CountRecords_FullMethodName  = "/chroma.MetadataReader/CountRecords"
)
View Source
const (
	VectorReader_GetVectors_FullMethodName   = "/chroma.VectorReader/GetVectors"
	VectorReader_QueryVectors_FullMethodName = "/chroma.VectorReader/QueryVectors"
)
View Source
const (
	SysDB_CreateDatabase_FullMethodName                 = "/chroma.SysDB/CreateDatabase"
	SysDB_GetDatabase_FullMethodName                    = "/chroma.SysDB/GetDatabase"
	SysDB_CreateTenant_FullMethodName                   = "/chroma.SysDB/CreateTenant"
	SysDB_GetTenant_FullMethodName                      = "/chroma.SysDB/GetTenant"
	SysDB_CreateSegment_FullMethodName                  = "/chroma.SysDB/CreateSegment"
	SysDB_DeleteSegment_FullMethodName                  = "/chroma.SysDB/DeleteSegment"
	SysDB_GetSegments_FullMethodName                    = "/chroma.SysDB/GetSegments"
	SysDB_UpdateSegment_FullMethodName                  = "/chroma.SysDB/UpdateSegment"
	SysDB_CreateCollection_FullMethodName               = "/chroma.SysDB/CreateCollection"
	SysDB_DeleteCollection_FullMethodName               = "/chroma.SysDB/DeleteCollection"
	SysDB_GetCollections_FullMethodName                 = "/chroma.SysDB/GetCollections"
	SysDB_UpdateCollection_FullMethodName               = "/chroma.SysDB/UpdateCollection"
	SysDB_ResetState_FullMethodName                     = "/chroma.SysDB/ResetState"
	SysDB_GetLastCompactionTimeForTenant_FullMethodName = "/chroma.SysDB/GetLastCompactionTimeForTenant"
	SysDB_SetLastCompactionTimeForTenant_FullMethodName = "/chroma.SysDB/SetLastCompactionTimeForTenant"
	SysDB_FlushCollectionCompaction_FullMethodName      = "/chroma.SysDB/FlushCollectionCompaction"
)

Variables

View Source
var (
	Operation_name = map[int32]string{
		0: "ADD",
		1: "UPDATE",
		2: "UPSERT",
		3: "DELETE",
	}
	Operation_value = map[string]int32{
		"ADD":    0,
		"UPDATE": 1,
		"UPSERT": 2,
		"DELETE": 3,
	}
)

Enum value maps for Operation.

View Source
var (
	ScalarEncoding_name = map[int32]string{
		0: "FLOAT32",
		1: "INT32",
	}
	ScalarEncoding_value = map[string]int32{
		"FLOAT32": 0,
		"INT32":   1,
	}
)

Enum value maps for ScalarEncoding.

View Source
var (
	SegmentScope_name = map[int32]string{
		0: "VECTOR",
		1: "METADATA",
		2: "RECORD",
		3: "SQLITE",
	}
	SegmentScope_value = map[string]int32{
		"VECTOR":   0,
		"METADATA": 1,
		"RECORD":   2,
		"SQLITE":   3,
	}
)

Enum value maps for SegmentScope.

View Source
var (
	WhereDocumentOperator_name = map[int32]string{
		0: "CONTAINS",
		1: "NOT_CONTAINS",
	}
	WhereDocumentOperator_value = map[string]int32{
		"CONTAINS":     0,
		"NOT_CONTAINS": 1,
	}
)

Enum value maps for WhereDocumentOperator.

View Source
var (
	BooleanOperator_name = map[int32]string{
		0: "AND",
		1: "OR",
	}
	BooleanOperator_value = map[string]int32{
		"AND": 0,
		"OR":  1,
	}
)

Enum value maps for BooleanOperator.

View Source
var (
	ListOperator_name = map[int32]string{
		0: "IN",
		1: "NIN",
	}
	ListOperator_value = map[string]int32{
		"IN":  0,
		"NIN": 1,
	}
)

Enum value maps for ListOperator.

View Source
var (
	GenericComparator_name = map[int32]string{
		0: "EQ",
		1: "NE",
	}
	GenericComparator_value = map[string]int32{
		"EQ": 0,
		"NE": 1,
	}
)

Enum value maps for GenericComparator.

View Source
var (
	NumberComparator_name = map[int32]string{
		0: "GT",
		1: "GTE",
		2: "LT",
		3: "LTE",
	}
	NumberComparator_value = map[string]int32{
		"GT":  0,
		"GTE": 1,
		"LT":  2,
		"LTE": 3,
	}
)

Enum value maps for NumberComparator.

View Source
var File_chromadb_proto_chroma_proto protoreflect.FileDescriptor
View Source
var File_chromadb_proto_coordinator_proto protoreflect.FileDescriptor
View Source
var MetadataReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chroma.MetadataReader",
	HandlerType: (*MetadataReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryMetadata",
			Handler:    _MetadataReader_QueryMetadata_Handler,
		},
		{
			MethodName: "CountRecords",
			Handler:    _MetadataReader_CountRecords_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chromadb/proto/chroma.proto",
}

MetadataReader_ServiceDesc is the grpc.ServiceDesc for MetadataReader service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var SysDB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chroma.SysDB",
	HandlerType: (*SysDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDatabase",
			Handler:    _SysDB_CreateDatabase_Handler,
		},
		{
			MethodName: "GetDatabase",
			Handler:    _SysDB_GetDatabase_Handler,
		},
		{
			MethodName: "CreateTenant",
			Handler:    _SysDB_CreateTenant_Handler,
		},
		{
			MethodName: "GetTenant",
			Handler:    _SysDB_GetTenant_Handler,
		},
		{
			MethodName: "CreateSegment",
			Handler:    _SysDB_CreateSegment_Handler,
		},
		{
			MethodName: "DeleteSegment",
			Handler:    _SysDB_DeleteSegment_Handler,
		},
		{
			MethodName: "GetSegments",
			Handler:    _SysDB_GetSegments_Handler,
		},
		{
			MethodName: "UpdateSegment",
			Handler:    _SysDB_UpdateSegment_Handler,
		},
		{
			MethodName: "CreateCollection",
			Handler:    _SysDB_CreateCollection_Handler,
		},
		{
			MethodName: "DeleteCollection",
			Handler:    _SysDB_DeleteCollection_Handler,
		},
		{
			MethodName: "GetCollections",
			Handler:    _SysDB_GetCollections_Handler,
		},
		{
			MethodName: "UpdateCollection",
			Handler:    _SysDB_UpdateCollection_Handler,
		},
		{
			MethodName: "ResetState",
			Handler:    _SysDB_ResetState_Handler,
		},
		{
			MethodName: "GetLastCompactionTimeForTenant",
			Handler:    _SysDB_GetLastCompactionTimeForTenant_Handler,
		},
		{
			MethodName: "SetLastCompactionTimeForTenant",
			Handler:    _SysDB_SetLastCompactionTimeForTenant_Handler,
		},
		{
			MethodName: "FlushCollectionCompaction",
			Handler:    _SysDB_FlushCollectionCompaction_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chromadb/proto/coordinator.proto",
}

SysDB_ServiceDesc is the grpc.ServiceDesc for SysDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var VectorReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chroma.VectorReader",
	HandlerType: (*VectorReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVectors",
			Handler:    _VectorReader_GetVectors_Handler,
		},
		{
			MethodName: "QueryVectors",
			Handler:    _VectorReader_QueryVectors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chromadb/proto/chroma.proto",
}

VectorReader_ServiceDesc is the grpc.ServiceDesc for VectorReader service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMetadataReaderServer

func RegisterMetadataReaderServer(s grpc.ServiceRegistrar, srv MetadataReaderServer)

func RegisterSysDBServer

func RegisterSysDBServer(s grpc.ServiceRegistrar, srv SysDBServer)

func RegisterVectorReaderServer

func RegisterVectorReaderServer(s grpc.ServiceRegistrar, srv VectorReaderServer)

Types

type BoolListComparison

type BoolListComparison struct {
	Values       []bool       `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	ListOperator ListOperator `protobuf:"varint,2,opt,name=list_operator,json=listOperator,proto3,enum=chroma.ListOperator" json:"list_operator,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolListComparison) Descriptor deprecated

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

Deprecated: Use BoolListComparison.ProtoReflect.Descriptor instead.

func (*BoolListComparison) GetListOperator

func (x *BoolListComparison) GetListOperator() ListOperator

func (*BoolListComparison) GetValues

func (x *BoolListComparison) GetValues() []bool

func (*BoolListComparison) ProtoMessage

func (*BoolListComparison) ProtoMessage()

func (*BoolListComparison) ProtoReflect

func (x *BoolListComparison) ProtoReflect() protoreflect.Message

func (*BoolListComparison) Reset

func (x *BoolListComparison) Reset()

func (*BoolListComparison) String

func (x *BoolListComparison) String() string

type BooleanOperator

type BooleanOperator int32

A `Where` clause may have a list of children. This enum specifies how the children should be combined.

const (
	BooleanOperator_AND BooleanOperator = 0
	BooleanOperator_OR  BooleanOperator = 1
)

func (BooleanOperator) Descriptor

func (BooleanOperator) Enum

func (x BooleanOperator) Enum() *BooleanOperator

func (BooleanOperator) EnumDescriptor deprecated

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

Deprecated: Use BooleanOperator.Descriptor instead.

func (BooleanOperator) Number

func (BooleanOperator) String

func (x BooleanOperator) String() string

func (BooleanOperator) Type

type Collection

type Collection struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ConfigurationJsonStr string          `protobuf:"bytes,3,opt,name=configuration_json_str,json=configurationJsonStr,proto3" json:"configuration_json_str,omitempty"`
	Metadata             *UpdateMetadata `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	Dimension            *int32          `protobuf:"varint,5,opt,name=dimension,proto3,oneof" json:"dimension,omitempty"`
	Tenant               string          `protobuf:"bytes,6,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Database             string          `protobuf:"bytes,7,opt,name=database,proto3" json:"database,omitempty"`
	LogPosition          int64           `protobuf:"varint,8,opt,name=log_position,json=logPosition,proto3" json:"log_position,omitempty"`
	Version              int32           `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Collection) Descriptor deprecated

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

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetConfigurationJsonStr

func (x *Collection) GetConfigurationJsonStr() string

func (*Collection) GetDatabase

func (x *Collection) GetDatabase() string

func (*Collection) GetDimension

func (x *Collection) GetDimension() int32

func (*Collection) GetId

func (x *Collection) GetId() string

func (*Collection) GetLogPosition

func (x *Collection) GetLogPosition() int64

func (*Collection) GetMetadata

func (x *Collection) GetMetadata() *UpdateMetadata

func (*Collection) GetName

func (x *Collection) GetName() string

func (*Collection) GetTenant

func (x *Collection) GetTenant() string

func (*Collection) GetVersion

func (x *Collection) GetVersion() int32

func (*Collection) ProtoMessage

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect

func (x *Collection) ProtoReflect() protoreflect.Message

func (*Collection) Reset

func (x *Collection) Reset()

func (*Collection) String

func (x *Collection) String() string

type CountRecordsRequest

type CountRecordsRequest struct {
	SegmentId      string                 `protobuf:"bytes,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	CollectionId   string                 `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	VersionContext *RequestVersionContext `protobuf:"bytes,3,opt,name=version_context,json=versionContext,proto3" json:"version_context,omitempty"`
	// contains filtered or unexported fields
}

func (*CountRecordsRequest) Descriptor deprecated

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

Deprecated: Use CountRecordsRequest.ProtoReflect.Descriptor instead.

func (*CountRecordsRequest) GetCollectionId

func (x *CountRecordsRequest) GetCollectionId() string

func (*CountRecordsRequest) GetSegmentId

func (x *CountRecordsRequest) GetSegmentId() string

func (*CountRecordsRequest) GetVersionContext

func (x *CountRecordsRequest) GetVersionContext() *RequestVersionContext

func (*CountRecordsRequest) ProtoMessage

func (*CountRecordsRequest) ProtoMessage()

func (*CountRecordsRequest) ProtoReflect

func (x *CountRecordsRequest) ProtoReflect() protoreflect.Message

func (*CountRecordsRequest) Reset

func (x *CountRecordsRequest) Reset()

func (*CountRecordsRequest) String

func (x *CountRecordsRequest) String() string

type CountRecordsResponse

type CountRecordsResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

TODO: Add error propagation in the response.

func (*CountRecordsResponse) Descriptor deprecated

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

Deprecated: Use CountRecordsResponse.ProtoReflect.Descriptor instead.

func (*CountRecordsResponse) GetCount

func (x *CountRecordsResponse) GetCount() uint32

func (*CountRecordsResponse) ProtoMessage

func (*CountRecordsResponse) ProtoMessage()

func (*CountRecordsResponse) ProtoReflect

func (x *CountRecordsResponse) ProtoReflect() protoreflect.Message

func (*CountRecordsResponse) Reset

func (x *CountRecordsResponse) Reset()

func (*CountRecordsResponse) String

func (x *CountRecordsResponse) String() string

type CreateCollectionRequest

type CreateCollectionRequest struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ConfigurationJsonStr string          `protobuf:"bytes,3,opt,name=configuration_json_str,json=configurationJsonStr,proto3" json:"configuration_json_str,omitempty"`
	Metadata             *UpdateMetadata `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	Dimension            *int32          `protobuf:"varint,5,opt,name=dimension,proto3,oneof" json:"dimension,omitempty"`
	GetOrCreate          *bool           `protobuf:"varint,6,opt,name=get_or_create,json=getOrCreate,proto3,oneof" json:"get_or_create,omitempty"`
	Tenant               string          `protobuf:"bytes,7,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Database             string          `protobuf:"bytes,8,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCollectionRequest) Descriptor deprecated

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

Deprecated: Use CreateCollectionRequest.ProtoReflect.Descriptor instead.

func (*CreateCollectionRequest) GetConfigurationJsonStr

func (x *CreateCollectionRequest) GetConfigurationJsonStr() string

func (*CreateCollectionRequest) GetDatabase

func (x *CreateCollectionRequest) GetDatabase() string

func (*CreateCollectionRequest) GetDimension

func (x *CreateCollectionRequest) GetDimension() int32

func (*CreateCollectionRequest) GetGetOrCreate

func (x *CreateCollectionRequest) GetGetOrCreate() bool

func (*CreateCollectionRequest) GetId

func (x *CreateCollectionRequest) GetId() string

func (*CreateCollectionRequest) GetMetadata

func (x *CreateCollectionRequest) GetMetadata() *UpdateMetadata

func (*CreateCollectionRequest) GetName

func (x *CreateCollectionRequest) GetName() string

func (*CreateCollectionRequest) GetTenant

func (x *CreateCollectionRequest) GetTenant() string

func (*CreateCollectionRequest) ProtoMessage

func (*CreateCollectionRequest) ProtoMessage()

func (*CreateCollectionRequest) ProtoReflect

func (x *CreateCollectionRequest) ProtoReflect() protoreflect.Message

func (*CreateCollectionRequest) Reset

func (x *CreateCollectionRequest) Reset()

func (*CreateCollectionRequest) String

func (x *CreateCollectionRequest) String() string

type CreateCollectionResponse

type CreateCollectionResponse struct {
	Collection *Collection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Created    bool        `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	Status     *Status     `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCollectionResponse) Descriptor deprecated

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

Deprecated: Use CreateCollectionResponse.ProtoReflect.Descriptor instead.

func (*CreateCollectionResponse) GetCollection

func (x *CreateCollectionResponse) GetCollection() *Collection

func (*CreateCollectionResponse) GetCreated

func (x *CreateCollectionResponse) GetCreated() bool

func (*CreateCollectionResponse) GetStatus

func (x *CreateCollectionResponse) GetStatus() *Status

func (*CreateCollectionResponse) ProtoMessage

func (*CreateCollectionResponse) ProtoMessage()

func (*CreateCollectionResponse) ProtoReflect

func (x *CreateCollectionResponse) ProtoReflect() protoreflect.Message

func (*CreateCollectionResponse) Reset

func (x *CreateCollectionResponse) Reset()

func (*CreateCollectionResponse) String

func (x *CreateCollectionResponse) String() string

type CreateDatabaseRequest

type CreateDatabaseRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Tenant string `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseRequest) Descriptor deprecated

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

Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.

func (*CreateDatabaseRequest) GetId

func (x *CreateDatabaseRequest) GetId() string

func (*CreateDatabaseRequest) GetName

func (x *CreateDatabaseRequest) GetName() string

func (*CreateDatabaseRequest) GetTenant

func (x *CreateDatabaseRequest) GetTenant() string

func (*CreateDatabaseRequest) ProtoMessage

func (*CreateDatabaseRequest) ProtoMessage()

func (*CreateDatabaseRequest) ProtoReflect

func (x *CreateDatabaseRequest) ProtoReflect() protoreflect.Message

func (*CreateDatabaseRequest) Reset

func (x *CreateDatabaseRequest) Reset()

func (*CreateDatabaseRequest) String

func (x *CreateDatabaseRequest) String() string

type CreateDatabaseResponse

type CreateDatabaseResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseResponse) Descriptor deprecated

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

Deprecated: Use CreateDatabaseResponse.ProtoReflect.Descriptor instead.

func (*CreateDatabaseResponse) GetStatus

func (x *CreateDatabaseResponse) GetStatus() *Status

func (*CreateDatabaseResponse) ProtoMessage

func (*CreateDatabaseResponse) ProtoMessage()

func (*CreateDatabaseResponse) ProtoReflect

func (x *CreateDatabaseResponse) ProtoReflect() protoreflect.Message

func (*CreateDatabaseResponse) Reset

func (x *CreateDatabaseResponse) Reset()

func (*CreateDatabaseResponse) String

func (x *CreateDatabaseResponse) String() string

type CreateSegmentRequest

type CreateSegmentRequest struct {
	Segment *Segment `protobuf:"bytes,1,opt,name=segment,proto3" json:"segment,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSegmentRequest) Descriptor deprecated

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

Deprecated: Use CreateSegmentRequest.ProtoReflect.Descriptor instead.

func (*CreateSegmentRequest) GetSegment

func (x *CreateSegmentRequest) GetSegment() *Segment

func (*CreateSegmentRequest) ProtoMessage

func (*CreateSegmentRequest) ProtoMessage()

func (*CreateSegmentRequest) ProtoReflect

func (x *CreateSegmentRequest) ProtoReflect() protoreflect.Message

func (*CreateSegmentRequest) Reset

func (x *CreateSegmentRequest) Reset()

func (*CreateSegmentRequest) String

func (x *CreateSegmentRequest) String() string

type CreateSegmentResponse

type CreateSegmentResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSegmentResponse) Descriptor deprecated

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

Deprecated: Use CreateSegmentResponse.ProtoReflect.Descriptor instead.

func (*CreateSegmentResponse) GetStatus

func (x *CreateSegmentResponse) GetStatus() *Status

func (*CreateSegmentResponse) ProtoMessage

func (*CreateSegmentResponse) ProtoMessage()

func (*CreateSegmentResponse) ProtoReflect

func (x *CreateSegmentResponse) ProtoReflect() protoreflect.Message

func (*CreateSegmentResponse) Reset

func (x *CreateSegmentResponse) Reset()

func (*CreateSegmentResponse) String

func (x *CreateSegmentResponse) String() string

type CreateTenantRequest

type CreateTenantRequest struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Names are globally unique
	// contains filtered or unexported fields
}

func (*CreateTenantRequest) Descriptor deprecated

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

Deprecated: Use CreateTenantRequest.ProtoReflect.Descriptor instead.

func (*CreateTenantRequest) GetName

func (x *CreateTenantRequest) GetName() string

func (*CreateTenantRequest) ProtoMessage

func (*CreateTenantRequest) ProtoMessage()

func (*CreateTenantRequest) ProtoReflect

func (x *CreateTenantRequest) ProtoReflect() protoreflect.Message

func (*CreateTenantRequest) Reset

func (x *CreateTenantRequest) Reset()

func (*CreateTenantRequest) String

func (x *CreateTenantRequest) String() string

type CreateTenantResponse

type CreateTenantResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTenantResponse) Descriptor deprecated

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

Deprecated: Use CreateTenantResponse.ProtoReflect.Descriptor instead.

func (*CreateTenantResponse) GetStatus

func (x *CreateTenantResponse) GetStatus() *Status

func (*CreateTenantResponse) ProtoMessage

func (*CreateTenantResponse) ProtoMessage()

func (*CreateTenantResponse) ProtoReflect

func (x *CreateTenantResponse) ProtoReflect() protoreflect.Message

func (*CreateTenantResponse) Reset

func (x *CreateTenantResponse) Reset()

func (*CreateTenantResponse) String

func (x *CreateTenantResponse) String() string

type Database

type Database struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Tenant string `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*Database) Descriptor deprecated

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

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetId

func (x *Database) GetId() string

func (*Database) GetName

func (x *Database) GetName() string

func (*Database) GetTenant

func (x *Database) GetTenant() string

func (*Database) ProtoMessage

func (*Database) ProtoMessage()

func (*Database) ProtoReflect

func (x *Database) ProtoReflect() protoreflect.Message

func (*Database) Reset

func (x *Database) Reset()

func (*Database) String

func (x *Database) String() string

type DeleteCollectionRequest

type DeleteCollectionRequest struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tenant   string `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCollectionRequest) Descriptor deprecated

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

Deprecated: Use DeleteCollectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteCollectionRequest) GetDatabase

func (x *DeleteCollectionRequest) GetDatabase() string

func (*DeleteCollectionRequest) GetId

func (x *DeleteCollectionRequest) GetId() string

func (*DeleteCollectionRequest) GetTenant

func (x *DeleteCollectionRequest) GetTenant() string

func (*DeleteCollectionRequest) ProtoMessage

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) ProtoReflect

func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message

func (*DeleteCollectionRequest) Reset

func (x *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String

func (x *DeleteCollectionRequest) String() string

type DeleteCollectionResponse

type DeleteCollectionResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCollectionResponse) Descriptor deprecated

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

Deprecated: Use DeleteCollectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteCollectionResponse) GetStatus

func (x *DeleteCollectionResponse) GetStatus() *Status

func (*DeleteCollectionResponse) ProtoMessage

func (*DeleteCollectionResponse) ProtoMessage()

func (*DeleteCollectionResponse) ProtoReflect

func (x *DeleteCollectionResponse) ProtoReflect() protoreflect.Message

func (*DeleteCollectionResponse) Reset

func (x *DeleteCollectionResponse) Reset()

func (*DeleteCollectionResponse) String

func (x *DeleteCollectionResponse) String() string

type DeleteSegmentRequest

type DeleteSegmentRequest struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSegmentRequest) Descriptor deprecated

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

Deprecated: Use DeleteSegmentRequest.ProtoReflect.Descriptor instead.

func (*DeleteSegmentRequest) GetCollection

func (x *DeleteSegmentRequest) GetCollection() string

func (*DeleteSegmentRequest) GetId

func (x *DeleteSegmentRequest) GetId() string

func (*DeleteSegmentRequest) ProtoMessage

func (*DeleteSegmentRequest) ProtoMessage()

func (*DeleteSegmentRequest) ProtoReflect

func (x *DeleteSegmentRequest) ProtoReflect() protoreflect.Message

func (*DeleteSegmentRequest) Reset

func (x *DeleteSegmentRequest) Reset()

func (*DeleteSegmentRequest) String

func (x *DeleteSegmentRequest) String() string

type DeleteSegmentResponse

type DeleteSegmentResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSegmentResponse) Descriptor deprecated

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

Deprecated: Use DeleteSegmentResponse.ProtoReflect.Descriptor instead.

func (*DeleteSegmentResponse) GetStatus

func (x *DeleteSegmentResponse) GetStatus() *Status

func (*DeleteSegmentResponse) ProtoMessage

func (*DeleteSegmentResponse) ProtoMessage()

func (*DeleteSegmentResponse) ProtoReflect

func (x *DeleteSegmentResponse) ProtoReflect() protoreflect.Message

func (*DeleteSegmentResponse) Reset

func (x *DeleteSegmentResponse) Reset()

func (*DeleteSegmentResponse) String

func (x *DeleteSegmentResponse) String() string

type DirectComparison

type DirectComparison struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Comparison:
	//
	//	*DirectComparison_SingleStringOperand
	//	*DirectComparison_StringListOperand
	//	*DirectComparison_SingleIntOperand
	//	*DirectComparison_IntListOperand
	//	*DirectComparison_SingleDoubleOperand
	//	*DirectComparison_DoubleListOperand
	//	*DirectComparison_BoolListOperand
	//	*DirectComparison_SingleBoolOperand
	Comparison isDirectComparison_Comparison `protobuf_oneof:"comparison"`
	// contains filtered or unexported fields
}

A leaf-node `Where` clause.

func (*DirectComparison) Descriptor deprecated

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

Deprecated: Use DirectComparison.ProtoReflect.Descriptor instead.

func (*DirectComparison) GetBoolListOperand

func (x *DirectComparison) GetBoolListOperand() *BoolListComparison

func (*DirectComparison) GetComparison

func (m *DirectComparison) GetComparison() isDirectComparison_Comparison

func (*DirectComparison) GetDoubleListOperand

func (x *DirectComparison) GetDoubleListOperand() *DoubleListComparison

func (*DirectComparison) GetIntListOperand

func (x *DirectComparison) GetIntListOperand() *IntListComparison

func (*DirectComparison) GetKey

func (x *DirectComparison) GetKey() string

func (*DirectComparison) GetSingleBoolOperand

func (x *DirectComparison) GetSingleBoolOperand() *SingleBoolComparison

func (*DirectComparison) GetSingleDoubleOperand

func (x *DirectComparison) GetSingleDoubleOperand() *SingleDoubleComparison

func (*DirectComparison) GetSingleIntOperand

func (x *DirectComparison) GetSingleIntOperand() *SingleIntComparison

func (*DirectComparison) GetSingleStringOperand

func (x *DirectComparison) GetSingleStringOperand() *SingleStringComparison

func (*DirectComparison) GetStringListOperand

func (x *DirectComparison) GetStringListOperand() *StringListComparison

func (*DirectComparison) ProtoMessage

func (*DirectComparison) ProtoMessage()

func (*DirectComparison) ProtoReflect

func (x *DirectComparison) ProtoReflect() protoreflect.Message

func (*DirectComparison) Reset

func (x *DirectComparison) Reset()

func (*DirectComparison) String

func (x *DirectComparison) String() string

type DirectComparison_BoolListOperand

type DirectComparison_BoolListOperand struct {
	BoolListOperand *BoolListComparison `protobuf:"bytes,8,opt,name=bool_list_operand,json=boolListOperand,proto3,oneof"`
}

type DirectComparison_DoubleListOperand

type DirectComparison_DoubleListOperand struct {
	DoubleListOperand *DoubleListComparison `protobuf:"bytes,7,opt,name=double_list_operand,json=doubleListOperand,proto3,oneof"`
}

type DirectComparison_IntListOperand

type DirectComparison_IntListOperand struct {
	IntListOperand *IntListComparison `protobuf:"bytes,5,opt,name=int_list_operand,json=intListOperand,proto3,oneof"`
}

type DirectComparison_SingleBoolOperand

type DirectComparison_SingleBoolOperand struct {
	SingleBoolOperand *SingleBoolComparison `protobuf:"bytes,9,opt,name=single_bool_operand,json=singleBoolOperand,proto3,oneof"`
}

type DirectComparison_SingleDoubleOperand

type DirectComparison_SingleDoubleOperand struct {
	SingleDoubleOperand *SingleDoubleComparison `protobuf:"bytes,6,opt,name=single_double_operand,json=singleDoubleOperand,proto3,oneof"`
}

type DirectComparison_SingleIntOperand

type DirectComparison_SingleIntOperand struct {
	SingleIntOperand *SingleIntComparison `protobuf:"bytes,4,opt,name=single_int_operand,json=singleIntOperand,proto3,oneof"`
}

type DirectComparison_SingleStringOperand

type DirectComparison_SingleStringOperand struct {
	SingleStringOperand *SingleStringComparison `protobuf:"bytes,2,opt,name=single_string_operand,json=singleStringOperand,proto3,oneof"`
}

type DirectComparison_StringListOperand

type DirectComparison_StringListOperand struct {
	StringListOperand *StringListComparison `protobuf:"bytes,3,opt,name=string_list_operand,json=stringListOperand,proto3,oneof"`
}

type DirectWhereDocument

type DirectWhereDocument struct {
	Document string                `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	Operator WhereDocumentOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=chroma.WhereDocumentOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

A leaf-node `WhereDocument` clause may compare a document to a single value.

func (*DirectWhereDocument) Descriptor deprecated

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

Deprecated: Use DirectWhereDocument.ProtoReflect.Descriptor instead.

func (*DirectWhereDocument) GetDocument

func (x *DirectWhereDocument) GetDocument() string

func (*DirectWhereDocument) GetOperator

func (x *DirectWhereDocument) GetOperator() WhereDocumentOperator

func (*DirectWhereDocument) ProtoMessage

func (*DirectWhereDocument) ProtoMessage()

func (*DirectWhereDocument) ProtoReflect

func (x *DirectWhereDocument) ProtoReflect() protoreflect.Message

func (*DirectWhereDocument) Reset

func (x *DirectWhereDocument) Reset()

func (*DirectWhereDocument) String

func (x *DirectWhereDocument) String() string

type DoubleListComparison

type DoubleListComparison struct {
	Values       []float64    `protobuf:"fixed64,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	ListOperator ListOperator `protobuf:"varint,2,opt,name=list_operator,json=listOperator,proto3,enum=chroma.ListOperator" json:"list_operator,omitempty"`
	// contains filtered or unexported fields
}

Used when a leaf-node `Where` clause compares a float to a list of floats. `ListOperator` specifies whether values in the list are allowed or disallowed.

func (*DoubleListComparison) Descriptor deprecated

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

Deprecated: Use DoubleListComparison.ProtoReflect.Descriptor instead.

func (*DoubleListComparison) GetListOperator

func (x *DoubleListComparison) GetListOperator() ListOperator

func (*DoubleListComparison) GetValues

func (x *DoubleListComparison) GetValues() []float64

func (*DoubleListComparison) ProtoMessage

func (*DoubleListComparison) ProtoMessage()

func (*DoubleListComparison) ProtoReflect

func (x *DoubleListComparison) ProtoReflect() protoreflect.Message

func (*DoubleListComparison) Reset

func (x *DoubleListComparison) Reset()

func (*DoubleListComparison) String

func (x *DoubleListComparison) String() string

type FilePaths

type FilePaths struct {
	Paths []string `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*FilePaths) Descriptor deprecated

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

Deprecated: Use FilePaths.ProtoReflect.Descriptor instead.

func (*FilePaths) GetPaths

func (x *FilePaths) GetPaths() []string

func (*FilePaths) ProtoMessage

func (*FilePaths) ProtoMessage()

func (*FilePaths) ProtoReflect

func (x *FilePaths) ProtoReflect() protoreflect.Message

func (*FilePaths) Reset

func (x *FilePaths) Reset()

func (*FilePaths) String

func (x *FilePaths) String() string

type FlushCollectionCompactionRequest

type FlushCollectionCompactionRequest struct {
	TenantId              string                        `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	CollectionId          string                        `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	LogPosition           int64                         `protobuf:"varint,3,opt,name=log_position,json=logPosition,proto3" json:"log_position,omitempty"`
	CollectionVersion     int32                         `protobuf:"varint,4,opt,name=collection_version,json=collectionVersion,proto3" json:"collection_version,omitempty"`
	SegmentCompactionInfo []*FlushSegmentCompactionInfo `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FlushCollectionCompactionRequest) Descriptor deprecated

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

Deprecated: Use FlushCollectionCompactionRequest.ProtoReflect.Descriptor instead.

func (*FlushCollectionCompactionRequest) GetCollectionId

func (x *FlushCollectionCompactionRequest) GetCollectionId() string

func (*FlushCollectionCompactionRequest) GetCollectionVersion

func (x *FlushCollectionCompactionRequest) GetCollectionVersion() int32

func (*FlushCollectionCompactionRequest) GetLogPosition

func (x *FlushCollectionCompactionRequest) GetLogPosition() int64

func (*FlushCollectionCompactionRequest) GetSegmentCompactionInfo

func (x *FlushCollectionCompactionRequest) GetSegmentCompactionInfo() []*FlushSegmentCompactionInfo

func (*FlushCollectionCompactionRequest) GetTenantId

func (x *FlushCollectionCompactionRequest) GetTenantId() string

func (*FlushCollectionCompactionRequest) ProtoMessage

func (*FlushCollectionCompactionRequest) ProtoMessage()

func (*FlushCollectionCompactionRequest) ProtoReflect

func (*FlushCollectionCompactionRequest) Reset

func (*FlushCollectionCompactionRequest) String

type FlushCollectionCompactionResponse

type FlushCollectionCompactionResponse struct {
	CollectionId       string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	CollectionVersion  int32  `protobuf:"varint,2,opt,name=collection_version,json=collectionVersion,proto3" json:"collection_version,omitempty"`
	LastCompactionTime int64  `protobuf:"varint,3,opt,name=last_compaction_time,json=lastCompactionTime,proto3" json:"last_compaction_time,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushCollectionCompactionResponse) Descriptor deprecated

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

Deprecated: Use FlushCollectionCompactionResponse.ProtoReflect.Descriptor instead.

func (*FlushCollectionCompactionResponse) GetCollectionId

func (x *FlushCollectionCompactionResponse) GetCollectionId() string

func (*FlushCollectionCompactionResponse) GetCollectionVersion

func (x *FlushCollectionCompactionResponse) GetCollectionVersion() int32

func (*FlushCollectionCompactionResponse) GetLastCompactionTime

func (x *FlushCollectionCompactionResponse) GetLastCompactionTime() int64

func (*FlushCollectionCompactionResponse) ProtoMessage

func (*FlushCollectionCompactionResponse) ProtoMessage()

func (*FlushCollectionCompactionResponse) ProtoReflect

func (*FlushCollectionCompactionResponse) Reset

func (*FlushCollectionCompactionResponse) String

type FlushSegmentCompactionInfo

type FlushSegmentCompactionInfo struct {
	SegmentId string                `protobuf:"bytes,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	FilePaths map[string]*FilePaths `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FlushSegmentCompactionInfo) Descriptor deprecated

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

Deprecated: Use FlushSegmentCompactionInfo.ProtoReflect.Descriptor instead.

func (*FlushSegmentCompactionInfo) GetFilePaths

func (x *FlushSegmentCompactionInfo) GetFilePaths() map[string]*FilePaths

func (*FlushSegmentCompactionInfo) GetSegmentId

func (x *FlushSegmentCompactionInfo) GetSegmentId() string

func (*FlushSegmentCompactionInfo) ProtoMessage

func (*FlushSegmentCompactionInfo) ProtoMessage()

func (*FlushSegmentCompactionInfo) ProtoReflect

func (*FlushSegmentCompactionInfo) Reset

func (x *FlushSegmentCompactionInfo) Reset()

func (*FlushSegmentCompactionInfo) String

func (x *FlushSegmentCompactionInfo) String() string

type GenericComparator

type GenericComparator int32

A leaf-node `Where` clause may compare a string, int, or float to a single value of the same type. These comparators apply to all three of those types.

const (
	GenericComparator_EQ GenericComparator = 0
	GenericComparator_NE GenericComparator = 1
)

func (GenericComparator) Descriptor

func (GenericComparator) Enum

func (GenericComparator) EnumDescriptor deprecated

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

Deprecated: Use GenericComparator.Descriptor instead.

func (GenericComparator) Number

func (GenericComparator) String

func (x GenericComparator) String() string

func (GenericComparator) Type

type GetCollectionsRequest

type GetCollectionsRequest struct {
	Id       *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Name     *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Tenant   string  `protobuf:"bytes,4,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Database string  `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	Limit    *int32  `protobuf:"varint,6,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset   *int32  `protobuf:"varint,7,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectionsRequest) Descriptor deprecated

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

Deprecated: Use GetCollectionsRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionsRequest) GetDatabase

func (x *GetCollectionsRequest) GetDatabase() string

func (*GetCollectionsRequest) GetId

func (x *GetCollectionsRequest) GetId() string

func (*GetCollectionsRequest) GetLimit

func (x *GetCollectionsRequest) GetLimit() int32

func (*GetCollectionsRequest) GetName

func (x *GetCollectionsRequest) GetName() string

func (*GetCollectionsRequest) GetOffset

func (x *GetCollectionsRequest) GetOffset() int32

func (*GetCollectionsRequest) GetTenant

func (x *GetCollectionsRequest) GetTenant() string

func (*GetCollectionsRequest) ProtoMessage

func (*GetCollectionsRequest) ProtoMessage()

func (*GetCollectionsRequest) ProtoReflect

func (x *GetCollectionsRequest) ProtoReflect() protoreflect.Message

func (*GetCollectionsRequest) Reset

func (x *GetCollectionsRequest) Reset()

func (*GetCollectionsRequest) String

func (x *GetCollectionsRequest) String() string

type GetCollectionsResponse

type GetCollectionsResponse struct {
	Collections []*Collection `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
	Status      *Status       `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectionsResponse) Descriptor deprecated

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

Deprecated: Use GetCollectionsResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionsResponse) GetCollections

func (x *GetCollectionsResponse) GetCollections() []*Collection

func (*GetCollectionsResponse) GetStatus

func (x *GetCollectionsResponse) GetStatus() *Status

func (*GetCollectionsResponse) ProtoMessage

func (*GetCollectionsResponse) ProtoMessage()

func (*GetCollectionsResponse) ProtoReflect

func (x *GetCollectionsResponse) ProtoReflect() protoreflect.Message

func (*GetCollectionsResponse) Reset

func (x *GetCollectionsResponse) Reset()

func (*GetCollectionsResponse) String

func (x *GetCollectionsResponse) String() string

type GetDatabaseRequest

type GetDatabaseRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tenant string `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabaseRequest) Descriptor deprecated

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

Deprecated: Use GetDatabaseRequest.ProtoReflect.Descriptor instead.

func (*GetDatabaseRequest) GetName

func (x *GetDatabaseRequest) GetName() string

func (*GetDatabaseRequest) GetTenant

func (x *GetDatabaseRequest) GetTenant() string

func (*GetDatabaseRequest) ProtoMessage

func (*GetDatabaseRequest) ProtoMessage()

func (*GetDatabaseRequest) ProtoReflect

func (x *GetDatabaseRequest) ProtoReflect() protoreflect.Message

func (*GetDatabaseRequest) Reset

func (x *GetDatabaseRequest) Reset()

func (*GetDatabaseRequest) String

func (x *GetDatabaseRequest) String() string

type GetDatabaseResponse

type GetDatabaseResponse struct {
	Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Status   *Status   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabaseResponse) Descriptor deprecated

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

Deprecated: Use GetDatabaseResponse.ProtoReflect.Descriptor instead.

func (*GetDatabaseResponse) GetDatabase

func (x *GetDatabaseResponse) GetDatabase() *Database

func (*GetDatabaseResponse) GetStatus

func (x *GetDatabaseResponse) GetStatus() *Status

func (*GetDatabaseResponse) ProtoMessage

func (*GetDatabaseResponse) ProtoMessage()

func (*GetDatabaseResponse) ProtoReflect

func (x *GetDatabaseResponse) ProtoReflect() protoreflect.Message

func (*GetDatabaseResponse) Reset

func (x *GetDatabaseResponse) Reset()

func (*GetDatabaseResponse) String

func (x *GetDatabaseResponse) String() string

type GetLastCompactionTimeForTenantRequest

type GetLastCompactionTimeForTenantRequest struct {
	TenantId []string `protobuf:"bytes,1,rep,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLastCompactionTimeForTenantRequest) Descriptor deprecated

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

Deprecated: Use GetLastCompactionTimeForTenantRequest.ProtoReflect.Descriptor instead.

func (*GetLastCompactionTimeForTenantRequest) GetTenantId

func (x *GetLastCompactionTimeForTenantRequest) GetTenantId() []string

func (*GetLastCompactionTimeForTenantRequest) ProtoMessage

func (*GetLastCompactionTimeForTenantRequest) ProtoMessage()

func (*GetLastCompactionTimeForTenantRequest) ProtoReflect

func (*GetLastCompactionTimeForTenantRequest) Reset

func (*GetLastCompactionTimeForTenantRequest) String

type GetLastCompactionTimeForTenantResponse

type GetLastCompactionTimeForTenantResponse struct {
	TenantLastCompactionTime []*TenantLastCompactionTime `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetLastCompactionTimeForTenantResponse) Descriptor deprecated

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

Deprecated: Use GetLastCompactionTimeForTenantResponse.ProtoReflect.Descriptor instead.

func (*GetLastCompactionTimeForTenantResponse) GetTenantLastCompactionTime

func (x *GetLastCompactionTimeForTenantResponse) GetTenantLastCompactionTime() []*TenantLastCompactionTime

func (*GetLastCompactionTimeForTenantResponse) ProtoMessage

func (*GetLastCompactionTimeForTenantResponse) ProtoReflect

func (*GetLastCompactionTimeForTenantResponse) Reset

func (*GetLastCompactionTimeForTenantResponse) String

type GetSegmentsRequest

type GetSegmentsRequest struct {
	Id         *string       `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Type       *string       `protobuf:"bytes,2,opt,name=type,proto3,oneof" json:"type,omitempty"`
	Scope      *SegmentScope `protobuf:"varint,3,opt,name=scope,proto3,enum=chroma.SegmentScope,oneof" json:"scope,omitempty"`
	Collection string        `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"` // Collection ID
	// contains filtered or unexported fields
}

func (*GetSegmentsRequest) Descriptor deprecated

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

Deprecated: Use GetSegmentsRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentsRequest) GetCollection

func (x *GetSegmentsRequest) GetCollection() string

func (*GetSegmentsRequest) GetId

func (x *GetSegmentsRequest) GetId() string

func (*GetSegmentsRequest) GetScope

func (x *GetSegmentsRequest) GetScope() SegmentScope

func (*GetSegmentsRequest) GetType

func (x *GetSegmentsRequest) GetType() string

func (*GetSegmentsRequest) ProtoMessage

func (*GetSegmentsRequest) ProtoMessage()

func (*GetSegmentsRequest) ProtoReflect

func (x *GetSegmentsRequest) ProtoReflect() protoreflect.Message

func (*GetSegmentsRequest) Reset

func (x *GetSegmentsRequest) Reset()

func (*GetSegmentsRequest) String

func (x *GetSegmentsRequest) String() string

type GetSegmentsResponse

type GetSegmentsResponse struct {
	Segments []*Segment `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
	Status   *Status    `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentsResponse) Descriptor deprecated

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

Deprecated: Use GetSegmentsResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentsResponse) GetSegments

func (x *GetSegmentsResponse) GetSegments() []*Segment

func (*GetSegmentsResponse) GetStatus

func (x *GetSegmentsResponse) GetStatus() *Status

func (*GetSegmentsResponse) ProtoMessage

func (*GetSegmentsResponse) ProtoMessage()

func (*GetSegmentsResponse) ProtoReflect

func (x *GetSegmentsResponse) ProtoReflect() protoreflect.Message

func (*GetSegmentsResponse) Reset

func (x *GetSegmentsResponse) Reset()

func (*GetSegmentsResponse) String

func (x *GetSegmentsResponse) String() string

type GetTenantRequest

type GetTenantRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantRequest) Descriptor deprecated

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

Deprecated: Use GetTenantRequest.ProtoReflect.Descriptor instead.

func (*GetTenantRequest) GetName

func (x *GetTenantRequest) GetName() string

func (*GetTenantRequest) ProtoMessage

func (*GetTenantRequest) ProtoMessage()

func (*GetTenantRequest) ProtoReflect

func (x *GetTenantRequest) ProtoReflect() protoreflect.Message

func (*GetTenantRequest) Reset

func (x *GetTenantRequest) Reset()

func (*GetTenantRequest) String

func (x *GetTenantRequest) String() string

type GetTenantResponse

type GetTenantResponse struct {
	Tenant *Tenant `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Status *Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantResponse) Descriptor deprecated

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

Deprecated: Use GetTenantResponse.ProtoReflect.Descriptor instead.

func (*GetTenantResponse) GetStatus

func (x *GetTenantResponse) GetStatus() *Status

func (*GetTenantResponse) GetTenant

func (x *GetTenantResponse) GetTenant() *Tenant

func (*GetTenantResponse) ProtoMessage

func (*GetTenantResponse) ProtoMessage()

func (*GetTenantResponse) ProtoReflect

func (x *GetTenantResponse) ProtoReflect() protoreflect.Message

func (*GetTenantResponse) Reset

func (x *GetTenantResponse) Reset()

func (*GetTenantResponse) String

func (x *GetTenantResponse) String() string

type GetVectorsRequest

type GetVectorsRequest struct {
	Ids            []string               `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	SegmentId      string                 `protobuf:"bytes,2,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	CollectionId   string                 `protobuf:"bytes,3,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	VersionContext *RequestVersionContext `protobuf:"bytes,4,opt,name=version_context,json=versionContext,proto3" json:"version_context,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVectorsRequest) Descriptor deprecated

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

Deprecated: Use GetVectorsRequest.ProtoReflect.Descriptor instead.

func (*GetVectorsRequest) GetCollectionId

func (x *GetVectorsRequest) GetCollectionId() string

func (*GetVectorsRequest) GetIds

func (x *GetVectorsRequest) GetIds() []string

func (*GetVectorsRequest) GetSegmentId

func (x *GetVectorsRequest) GetSegmentId() string

func (*GetVectorsRequest) GetVersionContext

func (x *GetVectorsRequest) GetVersionContext() *RequestVersionContext

func (*GetVectorsRequest) ProtoMessage

func (*GetVectorsRequest) ProtoMessage()

func (*GetVectorsRequest) ProtoReflect

func (x *GetVectorsRequest) ProtoReflect() protoreflect.Message

func (*GetVectorsRequest) Reset

func (x *GetVectorsRequest) Reset()

func (*GetVectorsRequest) String

func (x *GetVectorsRequest) String() string

type GetVectorsResponse

type GetVectorsResponse struct {
	Records []*VectorEmbeddingRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVectorsResponse) Descriptor deprecated

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

Deprecated: Use GetVectorsResponse.ProtoReflect.Descriptor instead.

func (*GetVectorsResponse) GetRecords

func (x *GetVectorsResponse) GetRecords() []*VectorEmbeddingRecord

func (*GetVectorsResponse) ProtoMessage

func (*GetVectorsResponse) ProtoMessage()

func (*GetVectorsResponse) ProtoReflect

func (x *GetVectorsResponse) ProtoReflect() protoreflect.Message

func (*GetVectorsResponse) Reset

func (x *GetVectorsResponse) Reset()

func (*GetVectorsResponse) String

func (x *GetVectorsResponse) String() string

type IntListComparison

type IntListComparison struct {
	Values       []int64      `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	ListOperator ListOperator `protobuf:"varint,2,opt,name=list_operator,json=listOperator,proto3,enum=chroma.ListOperator" json:"list_operator,omitempty"`
	// contains filtered or unexported fields
}

Used when a leaf-node `Where` clause compares an int to a list of ints. `ListOperator` specifies whether values in the list are allowed or disallowed.

func (*IntListComparison) Descriptor deprecated

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

Deprecated: Use IntListComparison.ProtoReflect.Descriptor instead.

func (*IntListComparison) GetListOperator

func (x *IntListComparison) GetListOperator() ListOperator

func (*IntListComparison) GetValues

func (x *IntListComparison) GetValues() []int64

func (*IntListComparison) ProtoMessage

func (*IntListComparison) ProtoMessage()

func (*IntListComparison) ProtoReflect

func (x *IntListComparison) ProtoReflect() protoreflect.Message

func (*IntListComparison) Reset

func (x *IntListComparison) Reset()

func (*IntListComparison) String

func (x *IntListComparison) String() string

type ListOperator

type ListOperator int32

A `Where` clause may have a list of allowed or disallowed values. This enum specifies which type of list it is.

const (
	ListOperator_IN  ListOperator = 0
	ListOperator_NIN ListOperator = 1
)

func (ListOperator) Descriptor

func (ListOperator) Enum

func (x ListOperator) Enum() *ListOperator

func (ListOperator) EnumDescriptor deprecated

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

Deprecated: Use ListOperator.Descriptor instead.

func (ListOperator) Number

func (ListOperator) String

func (x ListOperator) String() string

func (ListOperator) Type

type MetadataEmbeddingRecord

type MetadataEmbeddingRecord struct {
	Id       string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata *UpdateMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataEmbeddingRecord) Descriptor deprecated

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

Deprecated: Use MetadataEmbeddingRecord.ProtoReflect.Descriptor instead.

func (*MetadataEmbeddingRecord) GetId

func (x *MetadataEmbeddingRecord) GetId() string

func (*MetadataEmbeddingRecord) GetMetadata

func (x *MetadataEmbeddingRecord) GetMetadata() *UpdateMetadata

func (*MetadataEmbeddingRecord) ProtoMessage

func (*MetadataEmbeddingRecord) ProtoMessage()

func (*MetadataEmbeddingRecord) ProtoReflect

func (x *MetadataEmbeddingRecord) ProtoReflect() protoreflect.Message

func (*MetadataEmbeddingRecord) Reset

func (x *MetadataEmbeddingRecord) Reset()

func (*MetadataEmbeddingRecord) String

func (x *MetadataEmbeddingRecord) String() string

type MetadataReaderClient

type MetadataReaderClient interface {
	QueryMetadata(ctx context.Context, in *QueryMetadataRequest, opts ...grpc.CallOption) (*QueryMetadataResponse, error)
	CountRecords(ctx context.Context, in *CountRecordsRequest, opts ...grpc.CallOption) (*CountRecordsResponse, error)
}

MetadataReaderClient is the client API for MetadataReader service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type MetadataReaderServer

type MetadataReaderServer interface {
	QueryMetadata(context.Context, *QueryMetadataRequest) (*QueryMetadataResponse, error)
	CountRecords(context.Context, *CountRecordsRequest) (*CountRecordsResponse, error)
	// contains filtered or unexported methods
}

MetadataReaderServer is the server API for MetadataReader service. All implementations must embed UnimplementedMetadataReaderServer for forward compatibility

type Notification

type Notification struct {
	Id           int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Type         string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Status       string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetCollectionId

func (x *Notification) GetCollectionId() string

func (*Notification) GetId

func (x *Notification) GetId() int64

func (*Notification) GetStatus

func (x *Notification) GetStatus() string

func (*Notification) GetType

func (x *Notification) GetType() string

func (*Notification) ProtoMessage

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect

func (x *Notification) ProtoReflect() protoreflect.Message

func (*Notification) Reset

func (x *Notification) Reset()

func (*Notification) String

func (x *Notification) String() string

type NumberComparator

type NumberComparator int32

Used when a leaf-node `Where` clause compares an int or float to a single value of the same type.

const (
	NumberComparator_GT  NumberComparator = 0
	NumberComparator_GTE NumberComparator = 1
	NumberComparator_LT  NumberComparator = 2
	NumberComparator_LTE NumberComparator = 3
)

func (NumberComparator) Descriptor

func (NumberComparator) Enum

func (NumberComparator) EnumDescriptor deprecated

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

Deprecated: Use NumberComparator.Descriptor instead.

func (NumberComparator) Number

func (NumberComparator) String

func (x NumberComparator) String() string

func (NumberComparator) Type

type Operation

type Operation int32

Types here should mirror chromadb/types.py

const (
	Operation_ADD    Operation = 0
	Operation_UPDATE Operation = 1
	Operation_UPSERT Operation = 2
	Operation_DELETE Operation = 3
)

func (Operation) Descriptor

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated

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

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String

func (x Operation) String() string

func (Operation) Type

type OperationRecord

type OperationRecord struct {
	Id        string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Vector    *Vector         `protobuf:"bytes,2,opt,name=vector,proto3,oneof" json:"vector,omitempty"`
	Metadata  *UpdateMetadata `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	Operation Operation       `protobuf:"varint,4,opt,name=operation,proto3,enum=chroma.Operation" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Represents an operation the user submits

func (*OperationRecord) Descriptor deprecated

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

Deprecated: Use OperationRecord.ProtoReflect.Descriptor instead.

func (*OperationRecord) GetId

func (x *OperationRecord) GetId() string

func (*OperationRecord) GetMetadata

func (x *OperationRecord) GetMetadata() *UpdateMetadata

func (*OperationRecord) GetOperation

func (x *OperationRecord) GetOperation() Operation

func (*OperationRecord) GetVector

func (x *OperationRecord) GetVector() *Vector

func (*OperationRecord) ProtoMessage

func (*OperationRecord) ProtoMessage()

func (*OperationRecord) ProtoReflect

func (x *OperationRecord) ProtoReflect() protoreflect.Message

func (*OperationRecord) Reset

func (x *OperationRecord) Reset()

func (*OperationRecord) String

func (x *OperationRecord) String() string

type QueryMetadataRequest

type QueryMetadataRequest struct {
	SegmentId       string                 `protobuf:"bytes,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	Where           *Where                 `protobuf:"bytes,2,opt,name=where,proto3" json:"where,omitempty"`
	WhereDocument   *WhereDocument         `protobuf:"bytes,3,opt,name=where_document,json=whereDocument,proto3" json:"where_document,omitempty"`
	Ids             *UserIds               `protobuf:"bytes,4,opt,name=ids,proto3,oneof" json:"ids,omitempty"`
	Limit           *uint32                `protobuf:"varint,5,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Offset          *uint32                `protobuf:"varint,6,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	CollectionId    string                 `protobuf:"bytes,7,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	IncludeMetadata bool                   `protobuf:"varint,8,opt,name=include_metadata,json=includeMetadata,proto3" json:"include_metadata,omitempty"`
	VersionContext  *RequestVersionContext `protobuf:"bytes,9,opt,name=version_context,json=versionContext,proto3" json:"version_context,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataRequest) Descriptor deprecated

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

Deprecated: Use QueryMetadataRequest.ProtoReflect.Descriptor instead.

func (*QueryMetadataRequest) GetCollectionId

func (x *QueryMetadataRequest) GetCollectionId() string

func (*QueryMetadataRequest) GetIds

func (x *QueryMetadataRequest) GetIds() *UserIds

func (*QueryMetadataRequest) GetIncludeMetadata

func (x *QueryMetadataRequest) GetIncludeMetadata() bool

func (*QueryMetadataRequest) GetLimit

func (x *QueryMetadataRequest) GetLimit() uint32

func (*QueryMetadataRequest) GetOffset

func (x *QueryMetadataRequest) GetOffset() uint32

func (*QueryMetadataRequest) GetSegmentId

func (x *QueryMetadataRequest) GetSegmentId() string

func (*QueryMetadataRequest) GetVersionContext

func (x *QueryMetadataRequest) GetVersionContext() *RequestVersionContext

func (*QueryMetadataRequest) GetWhere

func (x *QueryMetadataRequest) GetWhere() *Where

func (*QueryMetadataRequest) GetWhereDocument

func (x *QueryMetadataRequest) GetWhereDocument() *WhereDocument

func (*QueryMetadataRequest) ProtoMessage

func (*QueryMetadataRequest) ProtoMessage()

func (*QueryMetadataRequest) ProtoReflect

func (x *QueryMetadataRequest) ProtoReflect() protoreflect.Message

func (*QueryMetadataRequest) Reset

func (x *QueryMetadataRequest) Reset()

func (*QueryMetadataRequest) String

func (x *QueryMetadataRequest) String() string

type QueryMetadataResponse

type QueryMetadataResponse struct {
	Records []*MetadataEmbeddingRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataResponse) Descriptor deprecated

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

Deprecated: Use QueryMetadataResponse.ProtoReflect.Descriptor instead.

func (*QueryMetadataResponse) GetRecords

func (*QueryMetadataResponse) ProtoMessage

func (*QueryMetadataResponse) ProtoMessage()

func (*QueryMetadataResponse) ProtoReflect

func (x *QueryMetadataResponse) ProtoReflect() protoreflect.Message

func (*QueryMetadataResponse) Reset

func (x *QueryMetadataResponse) Reset()

func (*QueryMetadataResponse) String

func (x *QueryMetadataResponse) String() string

type QueryVectorsRequest

type QueryVectorsRequest struct {
	Vectors           []*Vector              `protobuf:"bytes,1,rep,name=vectors,proto3" json:"vectors,omitempty"`
	K                 int32                  `protobuf:"varint,2,opt,name=k,proto3" json:"k,omitempty"`
	AllowedIds        []string               `protobuf:"bytes,3,rep,name=allowed_ids,json=allowedIds,proto3" json:"allowed_ids,omitempty"`
	IncludeEmbeddings bool                   `protobuf:"varint,4,opt,name=include_embeddings,json=includeEmbeddings,proto3" json:"include_embeddings,omitempty"`
	SegmentId         string                 `protobuf:"bytes,5,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	CollectionId      string                 `protobuf:"bytes,6,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	VersionContext    *RequestVersionContext `protobuf:"bytes,7,opt,name=version_context,json=versionContext,proto3" json:"version_context,omitempty"` // TODO: options as in types.py, its currently unused so can add later
	// contains filtered or unexported fields
}

func (*QueryVectorsRequest) Descriptor deprecated

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

Deprecated: Use QueryVectorsRequest.ProtoReflect.Descriptor instead.

func (*QueryVectorsRequest) GetAllowedIds

func (x *QueryVectorsRequest) GetAllowedIds() []string

func (*QueryVectorsRequest) GetCollectionId

func (x *QueryVectorsRequest) GetCollectionId() string

func (*QueryVectorsRequest) GetIncludeEmbeddings

func (x *QueryVectorsRequest) GetIncludeEmbeddings() bool

func (*QueryVectorsRequest) GetK

func (x *QueryVectorsRequest) GetK() int32

func (*QueryVectorsRequest) GetSegmentId

func (x *QueryVectorsRequest) GetSegmentId() string

func (*QueryVectorsRequest) GetVectors

func (x *QueryVectorsRequest) GetVectors() []*Vector

func (*QueryVectorsRequest) GetVersionContext

func (x *QueryVectorsRequest) GetVersionContext() *RequestVersionContext

func (*QueryVectorsRequest) ProtoMessage

func (*QueryVectorsRequest) ProtoMessage()

func (*QueryVectorsRequest) ProtoReflect

func (x *QueryVectorsRequest) ProtoReflect() protoreflect.Message

func (*QueryVectorsRequest) Reset

func (x *QueryVectorsRequest) Reset()

func (*QueryVectorsRequest) String

func (x *QueryVectorsRequest) String() string

type QueryVectorsResponse

type QueryVectorsResponse struct {
	Results []*VectorQueryResults `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryVectorsResponse) Descriptor deprecated

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

Deprecated: Use QueryVectorsResponse.ProtoReflect.Descriptor instead.

func (*QueryVectorsResponse) GetResults

func (x *QueryVectorsResponse) GetResults() []*VectorQueryResults

func (*QueryVectorsResponse) ProtoMessage

func (*QueryVectorsResponse) ProtoMessage()

func (*QueryVectorsResponse) ProtoReflect

func (x *QueryVectorsResponse) ProtoReflect() protoreflect.Message

func (*QueryVectorsResponse) Reset

func (x *QueryVectorsResponse) Reset()

func (*QueryVectorsResponse) String

func (x *QueryVectorsResponse) String() string

type RequestVersionContext

type RequestVersionContext struct {
	CollectionVersion uint32 `protobuf:"varint,1,opt,name=collection_version,json=collectionVersion,proto3" json:"collection_version,omitempty"`
	LogPosition       uint64 `protobuf:"varint,2,opt,name=log_position,json=logPosition,proto3" json:"log_position,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestVersionContext) Descriptor deprecated

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

Deprecated: Use RequestVersionContext.ProtoReflect.Descriptor instead.

func (*RequestVersionContext) GetCollectionVersion

func (x *RequestVersionContext) GetCollectionVersion() uint32

func (*RequestVersionContext) GetLogPosition

func (x *RequestVersionContext) GetLogPosition() uint64

func (*RequestVersionContext) ProtoMessage

func (*RequestVersionContext) ProtoMessage()

func (*RequestVersionContext) ProtoReflect

func (x *RequestVersionContext) ProtoReflect() protoreflect.Message

func (*RequestVersionContext) Reset

func (x *RequestVersionContext) Reset()

func (*RequestVersionContext) String

func (x *RequestVersionContext) String() string

type ResetStateResponse

type ResetStateResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetStateResponse) Descriptor deprecated

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

Deprecated: Use ResetStateResponse.ProtoReflect.Descriptor instead.

func (*ResetStateResponse) GetStatus

func (x *ResetStateResponse) GetStatus() *Status

func (*ResetStateResponse) ProtoMessage

func (*ResetStateResponse) ProtoMessage()

func (*ResetStateResponse) ProtoReflect

func (x *ResetStateResponse) ProtoReflect() protoreflect.Message

func (*ResetStateResponse) Reset

func (x *ResetStateResponse) Reset()

func (*ResetStateResponse) String

func (x *ResetStateResponse) String() string

type ScalarEncoding

type ScalarEncoding int32
const (
	ScalarEncoding_FLOAT32 ScalarEncoding = 0
	ScalarEncoding_INT32   ScalarEncoding = 1
)

func (ScalarEncoding) Descriptor

func (ScalarEncoding) Enum

func (x ScalarEncoding) Enum() *ScalarEncoding

func (ScalarEncoding) EnumDescriptor deprecated

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

Deprecated: Use ScalarEncoding.Descriptor instead.

func (ScalarEncoding) Number

func (ScalarEncoding) String

func (x ScalarEncoding) String() string

func (ScalarEncoding) Type

type Segment

type Segment struct {
	Id         string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type       string                `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Scope      SegmentScope          `protobuf:"varint,3,opt,name=scope,proto3,enum=chroma.SegmentScope" json:"scope,omitempty"`
	Collection string                `protobuf:"bytes,5,opt,name=collection,proto3" json:"collection,omitempty"`
	Metadata   *UpdateMetadata       `protobuf:"bytes,6,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	FilePaths  map[string]*FilePaths `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Segment) Descriptor deprecated

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

Deprecated: Use Segment.ProtoReflect.Descriptor instead.

func (*Segment) GetCollection

func (x *Segment) GetCollection() string

func (*Segment) GetFilePaths

func (x *Segment) GetFilePaths() map[string]*FilePaths

func (*Segment) GetId

func (x *Segment) GetId() string

func (*Segment) GetMetadata

func (x *Segment) GetMetadata() *UpdateMetadata

func (*Segment) GetScope

func (x *Segment) GetScope() SegmentScope

func (*Segment) GetType

func (x *Segment) GetType() string

func (*Segment) ProtoMessage

func (*Segment) ProtoMessage()

func (*Segment) ProtoReflect

func (x *Segment) ProtoReflect() protoreflect.Message

func (*Segment) Reset

func (x *Segment) Reset()

func (*Segment) String

func (x *Segment) String() string

type SegmentScope

type SegmentScope int32
const (
	SegmentScope_VECTOR   SegmentScope = 0
	SegmentScope_METADATA SegmentScope = 1
	SegmentScope_RECORD   SegmentScope = 2
	SegmentScope_SQLITE   SegmentScope = 3
)

func (SegmentScope) Descriptor

func (SegmentScope) Enum

func (x SegmentScope) Enum() *SegmentScope

func (SegmentScope) EnumDescriptor deprecated

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

Deprecated: Use SegmentScope.Descriptor instead.

func (SegmentScope) Number

func (SegmentScope) String

func (x SegmentScope) String() string

func (SegmentScope) Type

type SetLastCompactionTimeForTenantRequest

type SetLastCompactionTimeForTenantRequest struct {
	TenantLastCompactionTime *TenantLastCompactionTime `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetLastCompactionTimeForTenantRequest) Descriptor deprecated

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

Deprecated: Use SetLastCompactionTimeForTenantRequest.ProtoReflect.Descriptor instead.

func (*SetLastCompactionTimeForTenantRequest) GetTenantLastCompactionTime

func (x *SetLastCompactionTimeForTenantRequest) GetTenantLastCompactionTime() *TenantLastCompactionTime

func (*SetLastCompactionTimeForTenantRequest) ProtoMessage

func (*SetLastCompactionTimeForTenantRequest) ProtoMessage()

func (*SetLastCompactionTimeForTenantRequest) ProtoReflect

func (*SetLastCompactionTimeForTenantRequest) Reset

func (*SetLastCompactionTimeForTenantRequest) String

type SingleBoolComparison

type SingleBoolComparison struct {
	Value      bool              `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Comparator GenericComparator `protobuf:"varint,2,opt,name=comparator,proto3,enum=chroma.GenericComparator" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleBoolComparison) Descriptor deprecated

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

Deprecated: Use SingleBoolComparison.ProtoReflect.Descriptor instead.

func (*SingleBoolComparison) GetComparator

func (x *SingleBoolComparison) GetComparator() GenericComparator

func (*SingleBoolComparison) GetValue

func (x *SingleBoolComparison) GetValue() bool

func (*SingleBoolComparison) ProtoMessage

func (*SingleBoolComparison) ProtoMessage()

func (*SingleBoolComparison) ProtoReflect

func (x *SingleBoolComparison) ProtoReflect() protoreflect.Message

func (*SingleBoolComparison) Reset

func (x *SingleBoolComparison) Reset()

func (*SingleBoolComparison) String

func (x *SingleBoolComparison) String() string

type SingleDoubleComparison

type SingleDoubleComparison struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// Types that are assignable to Comparator:
	//
	//	*SingleDoubleComparison_GenericComparator
	//	*SingleDoubleComparison_NumberComparator
	Comparator isSingleDoubleComparison_Comparator `protobuf_oneof:"comparator"`
	// contains filtered or unexported fields
}

func (*SingleDoubleComparison) Descriptor deprecated

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

Deprecated: Use SingleDoubleComparison.ProtoReflect.Descriptor instead.

func (*SingleDoubleComparison) GetComparator

func (m *SingleDoubleComparison) GetComparator() isSingleDoubleComparison_Comparator

func (*SingleDoubleComparison) GetGenericComparator

func (x *SingleDoubleComparison) GetGenericComparator() GenericComparator

func (*SingleDoubleComparison) GetNumberComparator

func (x *SingleDoubleComparison) GetNumberComparator() NumberComparator

func (*SingleDoubleComparison) GetValue

func (x *SingleDoubleComparison) GetValue() float64

func (*SingleDoubleComparison) ProtoMessage

func (*SingleDoubleComparison) ProtoMessage()

func (*SingleDoubleComparison) ProtoReflect

func (x *SingleDoubleComparison) ProtoReflect() protoreflect.Message

func (*SingleDoubleComparison) Reset

func (x *SingleDoubleComparison) Reset()

func (*SingleDoubleComparison) String

func (x *SingleDoubleComparison) String() string

type SingleDoubleComparison_GenericComparator

type SingleDoubleComparison_GenericComparator struct {
	GenericComparator GenericComparator `protobuf:"varint,2,opt,name=generic_comparator,json=genericComparator,proto3,enum=chroma.GenericComparator,oneof"`
}

type SingleDoubleComparison_NumberComparator

type SingleDoubleComparison_NumberComparator struct {
	NumberComparator NumberComparator `protobuf:"varint,3,opt,name=number_comparator,json=numberComparator,proto3,enum=chroma.NumberComparator,oneof"`
}

type SingleIntComparison

type SingleIntComparison struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// Types that are assignable to Comparator:
	//
	//	*SingleIntComparison_GenericComparator
	//	*SingleIntComparison_NumberComparator
	Comparator isSingleIntComparison_Comparator `protobuf_oneof:"comparator"`
	// contains filtered or unexported fields
}

Used when a leaf-node `Where` clause compares an int to a single int.

func (*SingleIntComparison) Descriptor deprecated

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

Deprecated: Use SingleIntComparison.ProtoReflect.Descriptor instead.

func (*SingleIntComparison) GetComparator

func (m *SingleIntComparison) GetComparator() isSingleIntComparison_Comparator

func (*SingleIntComparison) GetGenericComparator

func (x *SingleIntComparison) GetGenericComparator() GenericComparator

func (*SingleIntComparison) GetNumberComparator

func (x *SingleIntComparison) GetNumberComparator() NumberComparator

func (*SingleIntComparison) GetValue

func (x *SingleIntComparison) GetValue() int64

func (*SingleIntComparison) ProtoMessage

func (*SingleIntComparison) ProtoMessage()

func (*SingleIntComparison) ProtoReflect

func (x *SingleIntComparison) ProtoReflect() protoreflect.Message

func (*SingleIntComparison) Reset

func (x *SingleIntComparison) Reset()

func (*SingleIntComparison) String

func (x *SingleIntComparison) String() string

type SingleIntComparison_GenericComparator

type SingleIntComparison_GenericComparator struct {
	GenericComparator GenericComparator `protobuf:"varint,2,opt,name=generic_comparator,json=genericComparator,proto3,enum=chroma.GenericComparator,oneof"`
}

type SingleIntComparison_NumberComparator

type SingleIntComparison_NumberComparator struct {
	NumberComparator NumberComparator `protobuf:"varint,3,opt,name=number_comparator,json=numberComparator,proto3,enum=chroma.NumberComparator,oneof"`
}

type SingleStringComparison

type SingleStringComparison struct {
	Value      string            `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Comparator GenericComparator `protobuf:"varint,2,opt,name=comparator,proto3,enum=chroma.GenericComparator" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

Used when a leaf-node `Where` clause compares a string to a single string.

func (*SingleStringComparison) Descriptor deprecated

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

Deprecated: Use SingleStringComparison.ProtoReflect.Descriptor instead.

func (*SingleStringComparison) GetComparator

func (x *SingleStringComparison) GetComparator() GenericComparator

func (*SingleStringComparison) GetValue

func (x *SingleStringComparison) GetValue() string

func (*SingleStringComparison) ProtoMessage

func (*SingleStringComparison) ProtoMessage()

func (*SingleStringComparison) ProtoReflect

func (x *SingleStringComparison) ProtoReflect() protoreflect.Message

func (*SingleStringComparison) Reset

func (x *SingleStringComparison) Reset()

func (*SingleStringComparison) String

func (x *SingleStringComparison) String() string

type Status

type Status struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	Code   int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` // TODO: What is the enum of this code?
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode

func (x *Status) GetCode() int32

func (*Status) GetReason

func (x *Status) GetReason() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

type StringListComparison

type StringListComparison struct {
	Values       []string     `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	ListOperator ListOperator `protobuf:"varint,2,opt,name=list_operator,json=listOperator,proto3,enum=chroma.ListOperator" json:"list_operator,omitempty"`
	// contains filtered or unexported fields
}

Used when a leaf-node `Where` clause compares a string to a list of strings. `ListOperator` specifies whether values in the list are allowed or disallowed.

func (*StringListComparison) Descriptor deprecated

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

Deprecated: Use StringListComparison.ProtoReflect.Descriptor instead.

func (*StringListComparison) GetListOperator

func (x *StringListComparison) GetListOperator() ListOperator

func (*StringListComparison) GetValues

func (x *StringListComparison) GetValues() []string

func (*StringListComparison) ProtoMessage

func (*StringListComparison) ProtoMessage()

func (*StringListComparison) ProtoReflect

func (x *StringListComparison) ProtoReflect() protoreflect.Message

func (*StringListComparison) Reset

func (x *StringListComparison) Reset()

func (*StringListComparison) String

func (x *StringListComparison) String() string

type SysDBClient

type SysDBClient interface {
	CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*GetDatabaseResponse, error)
	CreateTenant(ctx context.Context, in *CreateTenantRequest, opts ...grpc.CallOption) (*CreateTenantResponse, error)
	GetTenant(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*GetTenantResponse, error)
	CreateSegment(ctx context.Context, in *CreateSegmentRequest, opts ...grpc.CallOption) (*CreateSegmentResponse, error)
	DeleteSegment(ctx context.Context, in *DeleteSegmentRequest, opts ...grpc.CallOption) (*DeleteSegmentResponse, error)
	GetSegments(ctx context.Context, in *GetSegmentsRequest, opts ...grpc.CallOption) (*GetSegmentsResponse, error)
	UpdateSegment(ctx context.Context, in *UpdateSegmentRequest, opts ...grpc.CallOption) (*UpdateSegmentResponse, error)
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*CreateCollectionResponse, error)
	DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
	GetCollections(ctx context.Context, in *GetCollectionsRequest, opts ...grpc.CallOption) (*GetCollectionsResponse, error)
	UpdateCollection(ctx context.Context, in *UpdateCollectionRequest, opts ...grpc.CallOption) (*UpdateCollectionResponse, error)
	ResetState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ResetStateResponse, error)
	GetLastCompactionTimeForTenant(ctx context.Context, in *GetLastCompactionTimeForTenantRequest, opts ...grpc.CallOption) (*GetLastCompactionTimeForTenantResponse, error)
	SetLastCompactionTimeForTenant(ctx context.Context, in *SetLastCompactionTimeForTenantRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FlushCollectionCompaction(ctx context.Context, in *FlushCollectionCompactionRequest, opts ...grpc.CallOption) (*FlushCollectionCompactionResponse, error)
}

SysDBClient is the client API for SysDB service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSysDBClient

func NewSysDBClient(cc grpc.ClientConnInterface) SysDBClient

type SysDBServer

type SysDBServer interface {
	CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	GetDatabase(context.Context, *GetDatabaseRequest) (*GetDatabaseResponse, error)
	CreateTenant(context.Context, *CreateTenantRequest) (*CreateTenantResponse, error)
	GetTenant(context.Context, *GetTenantRequest) (*GetTenantResponse, error)
	CreateSegment(context.Context, *CreateSegmentRequest) (*CreateSegmentResponse, error)
	DeleteSegment(context.Context, *DeleteSegmentRequest) (*DeleteSegmentResponse, error)
	GetSegments(context.Context, *GetSegmentsRequest) (*GetSegmentsResponse, error)
	UpdateSegment(context.Context, *UpdateSegmentRequest) (*UpdateSegmentResponse, error)
	CreateCollection(context.Context, *CreateCollectionRequest) (*CreateCollectionResponse, error)
	DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
	GetCollections(context.Context, *GetCollectionsRequest) (*GetCollectionsResponse, error)
	UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionResponse, error)
	ResetState(context.Context, *emptypb.Empty) (*ResetStateResponse, error)
	GetLastCompactionTimeForTenant(context.Context, *GetLastCompactionTimeForTenantRequest) (*GetLastCompactionTimeForTenantResponse, error)
	SetLastCompactionTimeForTenant(context.Context, *SetLastCompactionTimeForTenantRequest) (*emptypb.Empty, error)
	FlushCollectionCompaction(context.Context, *FlushCollectionCompactionRequest) (*FlushCollectionCompactionResponse, error)
	// contains filtered or unexported methods
}

SysDBServer is the server API for SysDB service. All implementations must embed UnimplementedSysDBServer for forward compatibility

type Tenant

type Tenant struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Tenant) Descriptor deprecated

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

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetName

func (x *Tenant) GetName() string

func (*Tenant) ProtoMessage

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect

func (x *Tenant) ProtoReflect() protoreflect.Message

func (*Tenant) Reset

func (x *Tenant) Reset()

func (*Tenant) String

func (x *Tenant) String() string

type TenantLastCompactionTime

type TenantLastCompactionTime struct {
	TenantId           string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	LastCompactionTime int64  `protobuf:"varint,2,opt,name=last_compaction_time,json=lastCompactionTime,proto3" json:"last_compaction_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantLastCompactionTime) Descriptor deprecated

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

Deprecated: Use TenantLastCompactionTime.ProtoReflect.Descriptor instead.

func (*TenantLastCompactionTime) GetLastCompactionTime

func (x *TenantLastCompactionTime) GetLastCompactionTime() int64

func (*TenantLastCompactionTime) GetTenantId

func (x *TenantLastCompactionTime) GetTenantId() string

func (*TenantLastCompactionTime) ProtoMessage

func (*TenantLastCompactionTime) ProtoMessage()

func (*TenantLastCompactionTime) ProtoReflect

func (x *TenantLastCompactionTime) ProtoReflect() protoreflect.Message

func (*TenantLastCompactionTime) Reset

func (x *TenantLastCompactionTime) Reset()

func (*TenantLastCompactionTime) String

func (x *TenantLastCompactionTime) String() string

type UnimplementedMetadataReaderServer

type UnimplementedMetadataReaderServer struct {
}

UnimplementedMetadataReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataReaderServer) CountRecords

func (UnimplementedMetadataReaderServer) QueryMetadata

type UnimplementedSysDBServer

type UnimplementedSysDBServer struct {
}

UnimplementedSysDBServer must be embedded to have forward compatible implementations.

func (UnimplementedSysDBServer) CreateCollection

func (UnimplementedSysDBServer) CreateDatabase

func (UnimplementedSysDBServer) CreateSegment

func (UnimplementedSysDBServer) CreateTenant

func (UnimplementedSysDBServer) DeleteCollection

func (UnimplementedSysDBServer) DeleteSegment

func (UnimplementedSysDBServer) GetCollections

func (UnimplementedSysDBServer) GetDatabase

func (UnimplementedSysDBServer) GetSegments

func (UnimplementedSysDBServer) GetTenant

func (UnimplementedSysDBServer) ResetState

func (UnimplementedSysDBServer) SetLastCompactionTimeForTenant

func (UnimplementedSysDBServer) UpdateCollection

func (UnimplementedSysDBServer) UpdateSegment

type UnimplementedVectorReaderServer

type UnimplementedVectorReaderServer struct {
}

UnimplementedVectorReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedVectorReaderServer) GetVectors

func (UnimplementedVectorReaderServer) QueryVectors

type UnsafeMetadataReaderServer

type UnsafeMetadataReaderServer interface {
	// contains filtered or unexported methods
}

UnsafeMetadataReaderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetadataReaderServer will result in compilation errors.

type UnsafeSysDBServer

type UnsafeSysDBServer interface {
	// contains filtered or unexported methods
}

UnsafeSysDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SysDBServer will result in compilation errors.

type UnsafeVectorReaderServer

type UnsafeVectorReaderServer interface {
	// contains filtered or unexported methods
}

UnsafeVectorReaderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VectorReaderServer will result in compilation errors.

type UpdateCollectionRequest

type UpdateCollectionRequest struct {
	Id        string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      *string `protobuf:"bytes,3,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Dimension *int32  `protobuf:"varint,4,opt,name=dimension,proto3,oneof" json:"dimension,omitempty"`
	// Types that are assignable to MetadataUpdate:
	//
	//	*UpdateCollectionRequest_Metadata
	//	*UpdateCollectionRequest_ResetMetadata
	MetadataUpdate isUpdateCollectionRequest_MetadataUpdate `protobuf_oneof:"metadata_update"`
	// contains filtered or unexported fields
}

func (*UpdateCollectionRequest) Descriptor deprecated

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

Deprecated: Use UpdateCollectionRequest.ProtoReflect.Descriptor instead.

func (*UpdateCollectionRequest) GetDimension

func (x *UpdateCollectionRequest) GetDimension() int32

func (*UpdateCollectionRequest) GetId

func (x *UpdateCollectionRequest) GetId() string

func (*UpdateCollectionRequest) GetMetadata

func (x *UpdateCollectionRequest) GetMetadata() *UpdateMetadata

func (*UpdateCollectionRequest) GetMetadataUpdate

func (m *UpdateCollectionRequest) GetMetadataUpdate() isUpdateCollectionRequest_MetadataUpdate

func (*UpdateCollectionRequest) GetName

func (x *UpdateCollectionRequest) GetName() string

func (*UpdateCollectionRequest) GetResetMetadata

func (x *UpdateCollectionRequest) GetResetMetadata() bool

func (*UpdateCollectionRequest) ProtoMessage

func (*UpdateCollectionRequest) ProtoMessage()

func (*UpdateCollectionRequest) ProtoReflect

func (x *UpdateCollectionRequest) ProtoReflect() protoreflect.Message

func (*UpdateCollectionRequest) Reset

func (x *UpdateCollectionRequest) Reset()

func (*UpdateCollectionRequest) String

func (x *UpdateCollectionRequest) String() string

type UpdateCollectionRequest_Metadata

type UpdateCollectionRequest_Metadata struct {
	Metadata *UpdateMetadata `protobuf:"bytes,5,opt,name=metadata,proto3,oneof"`
}

type UpdateCollectionRequest_ResetMetadata

type UpdateCollectionRequest_ResetMetadata struct {
	ResetMetadata bool `protobuf:"varint,6,opt,name=reset_metadata,json=resetMetadata,proto3,oneof"`
}

type UpdateCollectionResponse

type UpdateCollectionResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCollectionResponse) Descriptor deprecated

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

Deprecated: Use UpdateCollectionResponse.ProtoReflect.Descriptor instead.

func (*UpdateCollectionResponse) GetStatus

func (x *UpdateCollectionResponse) GetStatus() *Status

func (*UpdateCollectionResponse) ProtoMessage

func (*UpdateCollectionResponse) ProtoMessage()

func (*UpdateCollectionResponse) ProtoReflect

func (x *UpdateCollectionResponse) ProtoReflect() protoreflect.Message

func (*UpdateCollectionResponse) Reset

func (x *UpdateCollectionResponse) Reset()

func (*UpdateCollectionResponse) String

func (x *UpdateCollectionResponse) String() string

type UpdateMetadata

type UpdateMetadata struct {
	Metadata map[string]*UpdateMetadataValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateMetadata) Descriptor deprecated

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

Deprecated: Use UpdateMetadata.ProtoReflect.Descriptor instead.

func (*UpdateMetadata) GetMetadata

func (x *UpdateMetadata) GetMetadata() map[string]*UpdateMetadataValue

func (*UpdateMetadata) ProtoMessage

func (*UpdateMetadata) ProtoMessage()

func (*UpdateMetadata) ProtoReflect

func (x *UpdateMetadata) ProtoReflect() protoreflect.Message

func (*UpdateMetadata) Reset

func (x *UpdateMetadata) Reset()

func (*UpdateMetadata) String

func (x *UpdateMetadata) String() string

type UpdateMetadataValue

type UpdateMetadataValue struct {

	// Not set if user wants to delete the key.
	// TODO(Sanket): Should we make this more explicit?
	//
	// Types that are assignable to Value:
	//
	//	*UpdateMetadataValue_StringValue
	//	*UpdateMetadataValue_IntValue
	//	*UpdateMetadataValue_FloatValue
	//	*UpdateMetadataValue_BoolValue
	Value isUpdateMetadataValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*UpdateMetadataValue) Descriptor deprecated

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

Deprecated: Use UpdateMetadataValue.ProtoReflect.Descriptor instead.

func (*UpdateMetadataValue) GetBoolValue

func (x *UpdateMetadataValue) GetBoolValue() bool

func (*UpdateMetadataValue) GetFloatValue

func (x *UpdateMetadataValue) GetFloatValue() float64

func (*UpdateMetadataValue) GetIntValue

func (x *UpdateMetadataValue) GetIntValue() int64

func (*UpdateMetadataValue) GetStringValue

func (x *UpdateMetadataValue) GetStringValue() string

func (*UpdateMetadataValue) GetValue

func (m *UpdateMetadataValue) GetValue() isUpdateMetadataValue_Value

func (*UpdateMetadataValue) ProtoMessage

func (*UpdateMetadataValue) ProtoMessage()

func (*UpdateMetadataValue) ProtoReflect

func (x *UpdateMetadataValue) ProtoReflect() protoreflect.Message

func (*UpdateMetadataValue) Reset

func (x *UpdateMetadataValue) Reset()

func (*UpdateMetadataValue) String

func (x *UpdateMetadataValue) String() string

type UpdateMetadataValue_BoolValue

type UpdateMetadataValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type UpdateMetadataValue_FloatValue

type UpdateMetadataValue_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,3,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type UpdateMetadataValue_IntValue

type UpdateMetadataValue_IntValue struct {
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type UpdateMetadataValue_StringValue

type UpdateMetadataValue_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type UpdateSegmentRequest

type UpdateSegmentRequest struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Collection string `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"`
	// Types that are assignable to MetadataUpdate:
	//
	//	*UpdateSegmentRequest_Metadata
	//	*UpdateSegmentRequest_ResetMetadata
	MetadataUpdate isUpdateSegmentRequest_MetadataUpdate `protobuf_oneof:"metadata_update"`
	// contains filtered or unexported fields
}

func (*UpdateSegmentRequest) Descriptor deprecated

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

Deprecated: Use UpdateSegmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateSegmentRequest) GetCollection

func (x *UpdateSegmentRequest) GetCollection() string

func (*UpdateSegmentRequest) GetId

func (x *UpdateSegmentRequest) GetId() string

func (*UpdateSegmentRequest) GetMetadata

func (x *UpdateSegmentRequest) GetMetadata() *UpdateMetadata

func (*UpdateSegmentRequest) GetMetadataUpdate

func (m *UpdateSegmentRequest) GetMetadataUpdate() isUpdateSegmentRequest_MetadataUpdate

func (*UpdateSegmentRequest) GetResetMetadata

func (x *UpdateSegmentRequest) GetResetMetadata() bool

func (*UpdateSegmentRequest) ProtoMessage

func (*UpdateSegmentRequest) ProtoMessage()

func (*UpdateSegmentRequest) ProtoReflect

func (x *UpdateSegmentRequest) ProtoReflect() protoreflect.Message

func (*UpdateSegmentRequest) Reset

func (x *UpdateSegmentRequest) Reset()

func (*UpdateSegmentRequest) String

func (x *UpdateSegmentRequest) String() string

type UpdateSegmentRequest_Metadata

type UpdateSegmentRequest_Metadata struct {
	Metadata *UpdateMetadata `protobuf:"bytes,6,opt,name=metadata,proto3,oneof"`
}

type UpdateSegmentRequest_ResetMetadata

type UpdateSegmentRequest_ResetMetadata struct {
	ResetMetadata bool `protobuf:"varint,7,opt,name=reset_metadata,json=resetMetadata,proto3,oneof"`
}

type UpdateSegmentResponse

type UpdateSegmentResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSegmentResponse) Descriptor deprecated

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

Deprecated: Use UpdateSegmentResponse.ProtoReflect.Descriptor instead.

func (*UpdateSegmentResponse) GetStatus

func (x *UpdateSegmentResponse) GetStatus() *Status

func (*UpdateSegmentResponse) ProtoMessage

func (*UpdateSegmentResponse) ProtoMessage()

func (*UpdateSegmentResponse) ProtoReflect

func (x *UpdateSegmentResponse) ProtoReflect() protoreflect.Message

func (*UpdateSegmentResponse) Reset

func (x *UpdateSegmentResponse) Reset()

func (*UpdateSegmentResponse) String

func (x *UpdateSegmentResponse) String() string

type UserIds

type UserIds struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

A `UserIds` should contain the set of user provided ids allowed in the result.

func (*UserIds) Descriptor deprecated

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

Deprecated: Use UserIds.ProtoReflect.Descriptor instead.

func (*UserIds) GetIds

func (x *UserIds) GetIds() []string

func (*UserIds) ProtoMessage

func (*UserIds) ProtoMessage()

func (*UserIds) ProtoReflect

func (x *UserIds) ProtoReflect() protoreflect.Message

func (*UserIds) Reset

func (x *UserIds) Reset()

func (*UserIds) String

func (x *UserIds) String() string

type Vector

type Vector struct {
	Dimension int32          `protobuf:"varint,1,opt,name=dimension,proto3" json:"dimension,omitempty"`
	Vector    []byte         `protobuf:"bytes,2,opt,name=vector,proto3" json:"vector,omitempty"`
	Encoding  ScalarEncoding `protobuf:"varint,3,opt,name=encoding,proto3,enum=chroma.ScalarEncoding" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

func (*Vector) Descriptor deprecated

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

Deprecated: Use Vector.ProtoReflect.Descriptor instead.

func (*Vector) GetDimension

func (x *Vector) GetDimension() int32

func (*Vector) GetEncoding

func (x *Vector) GetEncoding() ScalarEncoding

func (*Vector) GetVector

func (x *Vector) GetVector() []byte

func (*Vector) ProtoMessage

func (*Vector) ProtoMessage()

func (*Vector) ProtoReflect

func (x *Vector) ProtoReflect() protoreflect.Message

func (*Vector) Reset

func (x *Vector) Reset()

func (*Vector) String

func (x *Vector) String() string

type VectorEmbeddingRecord

type VectorEmbeddingRecord struct {
	Id     string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Vector *Vector `protobuf:"bytes,3,opt,name=vector,proto3" json:"vector,omitempty"` // TODO: we need to rethink source of truth for vector dimensionality and encoding
	// contains filtered or unexported fields
}

func (*VectorEmbeddingRecord) Descriptor deprecated

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

Deprecated: Use VectorEmbeddingRecord.ProtoReflect.Descriptor instead.

func (*VectorEmbeddingRecord) GetId

func (x *VectorEmbeddingRecord) GetId() string

func (*VectorEmbeddingRecord) GetVector

func (x *VectorEmbeddingRecord) GetVector() *Vector

func (*VectorEmbeddingRecord) ProtoMessage

func (*VectorEmbeddingRecord) ProtoMessage()

func (*VectorEmbeddingRecord) ProtoReflect

func (x *VectorEmbeddingRecord) ProtoReflect() protoreflect.Message

func (*VectorEmbeddingRecord) Reset

func (x *VectorEmbeddingRecord) Reset()

func (*VectorEmbeddingRecord) String

func (x *VectorEmbeddingRecord) String() string

type VectorQueryResult

type VectorQueryResult struct {
	Id       string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Distance float32 `protobuf:"fixed32,3,opt,name=distance,proto3" json:"distance,omitempty"`
	Vector   *Vector `protobuf:"bytes,4,opt,name=vector,proto3,oneof" json:"vector,omitempty"`
	// contains filtered or unexported fields
}

func (*VectorQueryResult) Descriptor deprecated

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

Deprecated: Use VectorQueryResult.ProtoReflect.Descriptor instead.

func (*VectorQueryResult) GetDistance

func (x *VectorQueryResult) GetDistance() float32

func (*VectorQueryResult) GetId

func (x *VectorQueryResult) GetId() string

func (*VectorQueryResult) GetVector

func (x *VectorQueryResult) GetVector() *Vector

func (*VectorQueryResult) ProtoMessage

func (*VectorQueryResult) ProtoMessage()

func (*VectorQueryResult) ProtoReflect

func (x *VectorQueryResult) ProtoReflect() protoreflect.Message

func (*VectorQueryResult) Reset

func (x *VectorQueryResult) Reset()

func (*VectorQueryResult) String

func (x *VectorQueryResult) String() string

type VectorQueryResults

type VectorQueryResults struct {
	Results []*VectorQueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*VectorQueryResults) Descriptor deprecated

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

Deprecated: Use VectorQueryResults.ProtoReflect.Descriptor instead.

func (*VectorQueryResults) GetResults

func (x *VectorQueryResults) GetResults() []*VectorQueryResult

func (*VectorQueryResults) ProtoMessage

func (*VectorQueryResults) ProtoMessage()

func (*VectorQueryResults) ProtoReflect

func (x *VectorQueryResults) ProtoReflect() protoreflect.Message

func (*VectorQueryResults) Reset

func (x *VectorQueryResults) Reset()

func (*VectorQueryResults) String

func (x *VectorQueryResults) String() string

type VectorReaderClient

type VectorReaderClient interface {
	GetVectors(ctx context.Context, in *GetVectorsRequest, opts ...grpc.CallOption) (*GetVectorsResponse, error)
	QueryVectors(ctx context.Context, in *QueryVectorsRequest, opts ...grpc.CallOption) (*QueryVectorsResponse, error)
}

VectorReaderClient is the client API for VectorReader service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type VectorReaderServer

type VectorReaderServer interface {
	GetVectors(context.Context, *GetVectorsRequest) (*GetVectorsResponse, error)
	QueryVectors(context.Context, *QueryVectorsRequest) (*QueryVectorsResponse, error)
	// contains filtered or unexported methods
}

VectorReaderServer is the server API for VectorReader service. All implementations must embed UnimplementedVectorReaderServer for forward compatibility

type Where

type Where struct {

	// Types that are assignable to Where:
	//
	//	*Where_DirectComparison
	//	*Where_Children
	Where isWhere_Where `protobuf_oneof:"where"`
	// contains filtered or unexported fields
}

A `Where` clause for filtering metadata. A `Where` clause is a tree of `Where` clauses, where each node is exactly one of:

  • A leaf node representing a direct comparison between a metadata key and a value or list of values.
  • An branch node with a list of children and a way to combine them (AND or OR).

func (*Where) Descriptor deprecated

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

Deprecated: Use Where.ProtoReflect.Descriptor instead.

func (*Where) GetChildren

func (x *Where) GetChildren() *WhereChildren

func (*Where) GetDirectComparison

func (x *Where) GetDirectComparison() *DirectComparison

func (*Where) GetWhere

func (m *Where) GetWhere() isWhere_Where

func (*Where) ProtoMessage

func (*Where) ProtoMessage()

func (*Where) ProtoReflect

func (x *Where) ProtoReflect() protoreflect.Message

func (*Where) Reset

func (x *Where) Reset()

func (*Where) String

func (x *Where) String() string

type WhereChildren

type WhereChildren struct {
	Children []*Where        `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	Operator BooleanOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=chroma.BooleanOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

A branch-node `Where` clause has a list of children and a specification for how to combine them.

func (*WhereChildren) Descriptor deprecated

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

Deprecated: Use WhereChildren.ProtoReflect.Descriptor instead.

func (*WhereChildren) GetChildren

func (x *WhereChildren) GetChildren() []*Where

func (*WhereChildren) GetOperator

func (x *WhereChildren) GetOperator() BooleanOperator

func (*WhereChildren) ProtoMessage

func (*WhereChildren) ProtoMessage()

func (*WhereChildren) ProtoReflect

func (x *WhereChildren) ProtoReflect() protoreflect.Message

func (*WhereChildren) Reset

func (x *WhereChildren) Reset()

func (*WhereChildren) String

func (x *WhereChildren) String() string

type WhereDocument

type WhereDocument struct {

	// Types that are assignable to WhereDocument:
	//
	//	*WhereDocument_Direct
	//	*WhereDocument_Children
	WhereDocument isWhereDocument_WhereDocument `protobuf_oneof:"where_document"`
	// contains filtered or unexported fields
}

A `WhereDocument` clause for filtering metadata. A `WhereDocument` clause is a tree of `WhereDocument` clauses, where each node is exactly one of: - A leaf node representing a `$contains` or `$not_contains` query directly. - An branch node with a list of children and a way to combine them (AND or OR).

func (*WhereDocument) Descriptor deprecated

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

Deprecated: Use WhereDocument.ProtoReflect.Descriptor instead.

func (*WhereDocument) GetChildren

func (x *WhereDocument) GetChildren() *WhereDocumentChildren

func (*WhereDocument) GetDirect

func (x *WhereDocument) GetDirect() *DirectWhereDocument

func (*WhereDocument) GetWhereDocument

func (m *WhereDocument) GetWhereDocument() isWhereDocument_WhereDocument

func (*WhereDocument) ProtoMessage

func (*WhereDocument) ProtoMessage()

func (*WhereDocument) ProtoReflect

func (x *WhereDocument) ProtoReflect() protoreflect.Message

func (*WhereDocument) Reset

func (x *WhereDocument) Reset()

func (*WhereDocument) String

func (x *WhereDocument) String() string

type WhereDocumentChildren

type WhereDocumentChildren struct {
	Children []*WhereDocument `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	Operator BooleanOperator  `protobuf:"varint,2,opt,name=operator,proto3,enum=chroma.BooleanOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

A branch-node `WhereDocument` node has a list of children.

func (*WhereDocumentChildren) Descriptor deprecated

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

Deprecated: Use WhereDocumentChildren.ProtoReflect.Descriptor instead.

func (*WhereDocumentChildren) GetChildren

func (x *WhereDocumentChildren) GetChildren() []*WhereDocument

func (*WhereDocumentChildren) GetOperator

func (x *WhereDocumentChildren) GetOperator() BooleanOperator

func (*WhereDocumentChildren) ProtoMessage

func (*WhereDocumentChildren) ProtoMessage()

func (*WhereDocumentChildren) ProtoReflect

func (x *WhereDocumentChildren) ProtoReflect() protoreflect.Message

func (*WhereDocumentChildren) Reset

func (x *WhereDocumentChildren) Reset()

func (*WhereDocumentChildren) String

func (x *WhereDocumentChildren) String() string

type WhereDocumentOperator

type WhereDocumentOperator int32

Types of operators for `WhereDocument` clauses. A `WhereDocument` clause can either require that a document contains a value or that it does not contain a value.

const (
	WhereDocumentOperator_CONTAINS     WhereDocumentOperator = 0
	WhereDocumentOperator_NOT_CONTAINS WhereDocumentOperator = 1
)

func (WhereDocumentOperator) Descriptor

func (WhereDocumentOperator) Enum

func (WhereDocumentOperator) EnumDescriptor deprecated

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

Deprecated: Use WhereDocumentOperator.Descriptor instead.

func (WhereDocumentOperator) Number

func (WhereDocumentOperator) String

func (x WhereDocumentOperator) String() string

func (WhereDocumentOperator) Type

type WhereDocument_Children

type WhereDocument_Children struct {
	Children *WhereDocumentChildren `protobuf:"bytes,2,opt,name=children,proto3,oneof"`
}

type WhereDocument_Direct

type WhereDocument_Direct struct {
	Direct *DirectWhereDocument `protobuf:"bytes,1,opt,name=direct,proto3,oneof"`
}

type Where_Children

type Where_Children struct {
	Children *WhereChildren `protobuf:"bytes,2,opt,name=children,proto3,oneof"`
}

type Where_DirectComparison

type Where_DirectComparison struct {
	DirectComparison *DirectComparison `protobuf:"bytes,1,opt,name=direct_comparison,json=directComparison,proto3,oneof"`
}

Jump to

Keyboard shortcuts

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