Documentation ¶
Overview ¶
Package protomodel is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package protomodel is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAuthorizationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAuthorizationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthorizationServiceClient) error
- func RegisterAuthorizationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAuthorizationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuthorizationServiceServer) error
- func RegisterAuthorizationServiceServer(s grpc.ServiceRegistrar, srv AuthorizationServiceServer)
- func RegisterDocumentServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterDocumentServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DocumentServiceClient) error
- func RegisterDocumentServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterDocumentServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DocumentServiceServer) error
- func RegisterDocumentServiceServer(s grpc.ServiceRegistrar, srv DocumentServiceServer)
- type AuditDocumentRequest
- func (*AuditDocumentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuditDocumentRequest) GetCollectionName() string
- func (x *AuditDocumentRequest) GetDesc() bool
- func (x *AuditDocumentRequest) GetDocumentId() string
- func (x *AuditDocumentRequest) GetPage() uint32
- func (x *AuditDocumentRequest) GetPageSize() uint32
- func (*AuditDocumentRequest) ProtoMessage()
- func (x *AuditDocumentRequest) ProtoReflect() protoreflect.Message
- func (x *AuditDocumentRequest) Reset()
- func (x *AuditDocumentRequest) String() string
- type AuditDocumentResponse
- func (*AuditDocumentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuditDocumentResponse) GetRevisions() []*DocumentAtRevision
- func (*AuditDocumentResponse) ProtoMessage()
- func (x *AuditDocumentResponse) ProtoReflect() protoreflect.Message
- func (x *AuditDocumentResponse) Reset()
- func (x *AuditDocumentResponse) String() string
- type AuthorizationServiceClient
- type AuthorizationServiceServer
- type CloseSessionRequest
- type CloseSessionResponse
- type Collection
- func (*Collection) Descriptor() ([]byte, []int)deprecated
- func (x *Collection) GetDocumentIdFieldName() string
- func (x *Collection) GetFields() []*Field
- func (x *Collection) GetIndexes() []*Index
- func (x *Collection) GetName() string
- func (*Collection) ProtoMessage()
- func (x *Collection) ProtoReflect() protoreflect.Message
- func (x *Collection) Reset()
- func (x *Collection) String() string
- type ComparisonOperator
- func (ComparisonOperator) Descriptor() protoreflect.EnumDescriptor
- func (x ComparisonOperator) Enum() *ComparisonOperator
- func (ComparisonOperator) EnumDescriptor() ([]byte, []int)deprecated
- func (x ComparisonOperator) Number() protoreflect.EnumNumber
- func (x ComparisonOperator) String() string
- func (ComparisonOperator) Type() protoreflect.EnumType
- type CountDocumentsRequest
- func (*CountDocumentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CountDocumentsRequest) GetQuery() *Query
- func (*CountDocumentsRequest) ProtoMessage()
- func (x *CountDocumentsRequest) ProtoReflect() protoreflect.Message
- func (x *CountDocumentsRequest) Reset()
- func (x *CountDocumentsRequest) String() string
- type CountDocumentsResponse
- func (*CountDocumentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CountDocumentsResponse) GetCount() int64
- func (*CountDocumentsResponse) ProtoMessage()
- func (x *CountDocumentsResponse) ProtoReflect() protoreflect.Message
- func (x *CountDocumentsResponse) Reset()
- func (x *CountDocumentsResponse) String() string
- type CreateCollectionRequest
- func (*CreateCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCollectionRequest) GetDocumentIdFieldName() string
- func (x *CreateCollectionRequest) GetFields() []*Field
- func (x *CreateCollectionRequest) GetIndexes() []*Index
- func (x *CreateCollectionRequest) GetName() string
- func (*CreateCollectionRequest) ProtoMessage()
- func (x *CreateCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateCollectionRequest) Reset()
- func (x *CreateCollectionRequest) String() string
- type CreateCollectionResponse
- type CreateIndexRequest
- func (*CreateIndexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateIndexRequest) GetCollectionName() string
- func (x *CreateIndexRequest) GetFields() []string
- func (x *CreateIndexRequest) GetIsUnique() bool
- func (*CreateIndexRequest) ProtoMessage()
- func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message
- func (x *CreateIndexRequest) Reset()
- func (x *CreateIndexRequest) String() string
- type CreateIndexResponse
- type DeleteCollectionRequest
- func (*DeleteCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCollectionRequest) GetName() string
- func (*DeleteCollectionRequest) ProtoMessage()
- func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCollectionRequest) Reset()
- func (x *DeleteCollectionRequest) String() string
- type DeleteCollectionResponse
- type DeleteDocumentsRequest
- func (*DeleteDocumentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDocumentsRequest) GetQuery() *Query
- func (*DeleteDocumentsRequest) ProtoMessage()
- func (x *DeleteDocumentsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDocumentsRequest) Reset()
- func (x *DeleteDocumentsRequest) String() string
- type DeleteDocumentsResponse
- type DeleteIndexRequest
- func (*DeleteIndexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteIndexRequest) GetCollectionName() string
- func (x *DeleteIndexRequest) GetFields() []string
- func (*DeleteIndexRequest) ProtoMessage()
- func (x *DeleteIndexRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteIndexRequest) Reset()
- func (x *DeleteIndexRequest) String() string
- type DeleteIndexResponse
- type DocumentAtRevision
- func (*DocumentAtRevision) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentAtRevision) GetDocument() *structpb.Struct
- func (x *DocumentAtRevision) GetDocumentId() string
- func (x *DocumentAtRevision) GetMetadata() *DocumentMetadata
- func (x *DocumentAtRevision) GetRevision() uint64
- func (x *DocumentAtRevision) GetTransactionId() uint64
- func (*DocumentAtRevision) ProtoMessage()
- func (x *DocumentAtRevision) ProtoReflect() protoreflect.Message
- func (x *DocumentAtRevision) Reset()
- func (x *DocumentAtRevision) String() string
- type DocumentMetadata
- type DocumentServiceClient
- type DocumentServiceServer
- type Field
- type FieldComparison
- func (*FieldComparison) Descriptor() ([]byte, []int)deprecated
- func (x *FieldComparison) GetField() string
- func (x *FieldComparison) GetOperator() ComparisonOperator
- func (x *FieldComparison) GetValue() *structpb.Value
- func (*FieldComparison) ProtoMessage()
- func (x *FieldComparison) ProtoReflect() protoreflect.Message
- func (x *FieldComparison) Reset()
- func (x *FieldComparison) String() string
- type FieldType
- type GetCollectionRequest
- func (*GetCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionRequest) GetName() string
- func (*GetCollectionRequest) ProtoMessage()
- func (x *GetCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *GetCollectionRequest) Reset()
- func (x *GetCollectionRequest) String() string
- type GetCollectionResponse
- func (*GetCollectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionResponse) GetCollection() *Collection
- func (*GetCollectionResponse) ProtoMessage()
- func (x *GetCollectionResponse) ProtoReflect() protoreflect.Message
- func (x *GetCollectionResponse) Reset()
- func (x *GetCollectionResponse) String() string
- type GetCollectionsRequest
- type GetCollectionsResponse
- func (*GetCollectionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionsResponse) GetCollections() []*Collection
- func (*GetCollectionsResponse) ProtoMessage()
- func (x *GetCollectionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetCollectionsResponse) Reset()
- func (x *GetCollectionsResponse) String() string
- type Index
- type InsertDocumentsRequest
- func (*InsertDocumentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertDocumentsRequest) GetCollectionName() string
- func (x *InsertDocumentsRequest) GetDocuments() []*structpb.Struct
- func (*InsertDocumentsRequest) ProtoMessage()
- func (x *InsertDocumentsRequest) ProtoReflect() protoreflect.Message
- func (x *InsertDocumentsRequest) Reset()
- func (x *InsertDocumentsRequest) String() string
- type InsertDocumentsResponse
- func (*InsertDocumentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InsertDocumentsResponse) GetDocumentIds() []string
- func (x *InsertDocumentsResponse) GetTransactionId() uint64
- func (*InsertDocumentsResponse) ProtoMessage()
- func (x *InsertDocumentsResponse) ProtoReflect() protoreflect.Message
- func (x *InsertDocumentsResponse) Reset()
- func (x *InsertDocumentsResponse) String() string
- type KeepAliveRequest
- type KeepAliveResponse
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionRequest) GetDatabase() string
- func (x *OpenSessionRequest) GetPassword() string
- func (x *OpenSessionRequest) GetUsername() string
- func (*OpenSessionRequest) ProtoMessage()
- func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
- func (x *OpenSessionRequest) Reset()
- func (x *OpenSessionRequest) String() string
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionResponse) GetExpirationTimestamp() int32
- func (x *OpenSessionResponse) GetInactivityTimestamp() int32
- func (x *OpenSessionResponse) GetServerUUID() string
- func (x *OpenSessionResponse) GetSessionID() string
- func (*OpenSessionResponse) ProtoMessage()
- func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
- func (x *OpenSessionResponse) Reset()
- func (x *OpenSessionResponse) String() string
- type OrderByClause
- func (*OrderByClause) Descriptor() ([]byte, []int)deprecated
- func (x *OrderByClause) GetDesc() bool
- func (x *OrderByClause) GetField() string
- func (*OrderByClause) ProtoMessage()
- func (x *OrderByClause) ProtoReflect() protoreflect.Message
- func (x *OrderByClause) Reset()
- func (x *OrderByClause) String() string
- type ProofDocumentRequest
- func (*ProofDocumentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProofDocumentRequest) GetCollectionName() string
- func (x *ProofDocumentRequest) GetDocumentId() string
- func (x *ProofDocumentRequest) GetProofSinceTransactionId() uint64
- func (x *ProofDocumentRequest) GetTransactionId() uint64
- func (*ProofDocumentRequest) ProtoMessage()
- func (x *ProofDocumentRequest) ProtoReflect() protoreflect.Message
- func (x *ProofDocumentRequest) Reset()
- func (x *ProofDocumentRequest) String() string
- type ProofDocumentResponse
- func (*ProofDocumentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProofDocumentResponse) GetCollectionId() uint32
- func (x *ProofDocumentResponse) GetDatabase() string
- func (x *ProofDocumentResponse) GetDocumentIdFieldName() string
- func (x *ProofDocumentResponse) GetEncodedDocument() []byte
- func (x *ProofDocumentResponse) GetVerifiableTx() *schema.VerifiableTxV2
- func (*ProofDocumentResponse) ProtoMessage()
- func (x *ProofDocumentResponse) ProtoReflect() protoreflect.Message
- func (x *ProofDocumentResponse) Reset()
- func (x *ProofDocumentResponse) String() string
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetCollectionName() string
- func (x *Query) GetExpressions() []*QueryExpression
- func (x *Query) GetLimit() uint32
- func (x *Query) GetOrderBy() []*OrderByClause
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type QueryExpression
- func (*QueryExpression) Descriptor() ([]byte, []int)deprecated
- func (x *QueryExpression) GetFieldComparisons() []*FieldComparison
- func (*QueryExpression) ProtoMessage()
- func (x *QueryExpression) ProtoReflect() protoreflect.Message
- func (x *QueryExpression) Reset()
- func (x *QueryExpression) String() string
- type ReplaceDocumentsRequest
- func (*ReplaceDocumentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReplaceDocumentsRequest) GetDocument() *structpb.Struct
- func (x *ReplaceDocumentsRequest) GetQuery() *Query
- func (*ReplaceDocumentsRequest) ProtoMessage()
- func (x *ReplaceDocumentsRequest) ProtoReflect() protoreflect.Message
- func (x *ReplaceDocumentsRequest) Reset()
- func (x *ReplaceDocumentsRequest) String() string
- type ReplaceDocumentsResponse
- func (*ReplaceDocumentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReplaceDocumentsResponse) GetRevisions() []*DocumentAtRevision
- func (*ReplaceDocumentsResponse) ProtoMessage()
- func (x *ReplaceDocumentsResponse) ProtoReflect() protoreflect.Message
- func (x *ReplaceDocumentsResponse) Reset()
- func (x *ReplaceDocumentsResponse) String() string
- type SearchDocumentsRequest
- func (*SearchDocumentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchDocumentsRequest) GetKeepOpen() bool
- func (x *SearchDocumentsRequest) GetPage() uint32
- func (x *SearchDocumentsRequest) GetPageSize() uint32
- func (x *SearchDocumentsRequest) GetQuery() *Query
- func (x *SearchDocumentsRequest) GetSearchId() string
- func (*SearchDocumentsRequest) ProtoMessage()
- func (x *SearchDocumentsRequest) ProtoReflect() protoreflect.Message
- func (x *SearchDocumentsRequest) Reset()
- func (x *SearchDocumentsRequest) String() string
- type SearchDocumentsResponse
- func (*SearchDocumentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchDocumentsResponse) GetRevisions() []*DocumentAtRevision
- func (x *SearchDocumentsResponse) GetSearchId() string
- func (*SearchDocumentsResponse) ProtoMessage()
- func (x *SearchDocumentsResponse) ProtoReflect() protoreflect.Message
- func (x *SearchDocumentsResponse) Reset()
- func (x *SearchDocumentsResponse) String() string
- type UnimplementedAuthorizationServiceServer
- func (UnimplementedAuthorizationServiceServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
- func (UnimplementedAuthorizationServiceServer) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)
- func (UnimplementedAuthorizationServiceServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
- type UnimplementedDocumentServiceServer
- func (UnimplementedDocumentServiceServer) AuditDocument(context.Context, *AuditDocumentRequest) (*AuditDocumentResponse, error)
- func (UnimplementedDocumentServiceServer) CountDocuments(context.Context, *CountDocumentsRequest) (*CountDocumentsResponse, error)
- func (UnimplementedDocumentServiceServer) CreateCollection(context.Context, *CreateCollectionRequest) (*CreateCollectionResponse, error)
- func (UnimplementedDocumentServiceServer) CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error)
- func (UnimplementedDocumentServiceServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
- func (UnimplementedDocumentServiceServer) DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error)
- func (UnimplementedDocumentServiceServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error)
- func (UnimplementedDocumentServiceServer) GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error)
- func (UnimplementedDocumentServiceServer) GetCollections(context.Context, *GetCollectionsRequest) (*GetCollectionsResponse, error)
- func (UnimplementedDocumentServiceServer) InsertDocuments(context.Context, *InsertDocumentsRequest) (*InsertDocumentsResponse, error)
- func (UnimplementedDocumentServiceServer) ProofDocument(context.Context, *ProofDocumentRequest) (*ProofDocumentResponse, error)
- func (UnimplementedDocumentServiceServer) ReplaceDocuments(context.Context, *ReplaceDocumentsRequest) (*ReplaceDocumentsResponse, error)
- func (UnimplementedDocumentServiceServer) SearchDocuments(context.Context, *SearchDocumentsRequest) (*SearchDocumentsResponse, error)
- func (UnimplementedDocumentServiceServer) UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionResponse, error)
- type UnsafeAuthorizationServiceServer
- type UnsafeDocumentServiceServer
- type UpdateCollectionRequest
- func (*UpdateCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCollectionRequest) GetDocumentIdFieldName() string
- func (x *UpdateCollectionRequest) GetName() string
- func (*UpdateCollectionRequest) ProtoMessage()
- func (x *UpdateCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateCollectionRequest) Reset()
- func (x *UpdateCollectionRequest) String() string
- type UpdateCollectionResponse
Constants ¶
This section is empty.
Variables ¶
var ( FieldType_name = map[int32]string{ 0: "STRING", 1: "BOOLEAN", 2: "INTEGER", 3: "DOUBLE", } FieldType_value = map[string]int32{ "STRING": 0, "BOOLEAN": 1, "INTEGER": 2, "DOUBLE": 3, } )
Enum value maps for FieldType.
var ( ComparisonOperator_name = map[int32]string{ 0: "EQ", 1: "NE", 2: "LT", 3: "LE", 4: "GT", 5: "GE", 6: "LIKE", 7: "NOT_LIKE", } ComparisonOperator_value = map[string]int32{ "EQ": 0, "NE": 1, "LT": 2, "LE": 3, "GT": 4, "GE": 5, "LIKE": 6, "NOT_LIKE": 7, } )
Enum value maps for ComparisonOperator.
var AuthorizationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "immudb.model.AuthorizationService", HandlerType: (*AuthorizationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "OpenSession", Handler: _AuthorizationService_OpenSession_Handler, }, { MethodName: "KeepAlive", Handler: _AuthorizationService_KeepAlive_Handler, }, { MethodName: "CloseSession", Handler: _AuthorizationService_CloseSession_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "authorization.proto", }
AuthorizationService_ServiceDesc is the grpc.ServiceDesc for AuthorizationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DocumentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "immudb.model.DocumentService", HandlerType: (*DocumentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateCollection", Handler: _DocumentService_CreateCollection_Handler, }, { MethodName: "GetCollections", Handler: _DocumentService_GetCollections_Handler, }, { MethodName: "GetCollection", Handler: _DocumentService_GetCollection_Handler, }, { MethodName: "UpdateCollection", Handler: _DocumentService_UpdateCollection_Handler, }, { MethodName: "DeleteCollection", Handler: _DocumentService_DeleteCollection_Handler, }, { MethodName: "CreateIndex", Handler: _DocumentService_CreateIndex_Handler, }, { MethodName: "DeleteIndex", Handler: _DocumentService_DeleteIndex_Handler, }, { MethodName: "InsertDocuments", Handler: _DocumentService_InsertDocuments_Handler, }, { MethodName: "ReplaceDocuments", Handler: _DocumentService_ReplaceDocuments_Handler, }, { MethodName: "DeleteDocuments", Handler: _DocumentService_DeleteDocuments_Handler, }, { MethodName: "SearchDocuments", Handler: _DocumentService_SearchDocuments_Handler, }, { MethodName: "CountDocuments", Handler: _DocumentService_CountDocuments_Handler, }, { MethodName: "AuditDocument", Handler: _DocumentService_AuditDocument_Handler, }, { MethodName: "ProofDocument", Handler: _DocumentService_ProofDocument_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "documents.proto", }
DocumentService_ServiceDesc is the grpc.ServiceDesc for DocumentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_documents_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAuthorizationServiceHandler ¶
func RegisterAuthorizationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAuthorizationServiceHandler registers the http handlers for service AuthorizationService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAuthorizationServiceHandlerClient ¶
func RegisterAuthorizationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthorizationServiceClient) error
RegisterAuthorizationServiceHandlerClient registers the http handlers for service AuthorizationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AuthorizationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AuthorizationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AuthorizationServiceClient" to call the correct interceptors.
func RegisterAuthorizationServiceHandlerFromEndpoint ¶
func RegisterAuthorizationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAuthorizationServiceHandlerFromEndpoint is same as RegisterAuthorizationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAuthorizationServiceHandlerServer ¶
func RegisterAuthorizationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuthorizationServiceServer) error
RegisterAuthorizationServiceHandlerServer registers the http handlers for service AuthorizationService to "mux". UnaryRPC :call AuthorizationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAuthorizationServiceHandlerFromEndpoint instead.
func RegisterAuthorizationServiceServer ¶
func RegisterAuthorizationServiceServer(s grpc.ServiceRegistrar, srv AuthorizationServiceServer)
func RegisterDocumentServiceHandler ¶
func RegisterDocumentServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterDocumentServiceHandler registers the http handlers for service DocumentService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterDocumentServiceHandlerClient ¶
func RegisterDocumentServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DocumentServiceClient) error
RegisterDocumentServiceHandlerClient registers the http handlers for service DocumentService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DocumentServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DocumentServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DocumentServiceClient" to call the correct interceptors.
func RegisterDocumentServiceHandlerFromEndpoint ¶
func RegisterDocumentServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterDocumentServiceHandlerFromEndpoint is same as RegisterDocumentServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterDocumentServiceHandlerServer ¶
func RegisterDocumentServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DocumentServiceServer) error
RegisterDocumentServiceHandlerServer registers the http handlers for service DocumentService to "mux". UnaryRPC :call DocumentServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDocumentServiceHandlerFromEndpoint instead.
func RegisterDocumentServiceServer ¶
func RegisterDocumentServiceServer(s grpc.ServiceRegistrar, srv DocumentServiceServer)
Types ¶
type AuditDocumentRequest ¶
type AuditDocumentRequest struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` DocumentId string `protobuf:"bytes,2,opt,name=documentId,proto3" json:"documentId,omitempty"` Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"` Page uint32 `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"` PageSize uint32 `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"` // contains filtered or unexported fields }
func (*AuditDocumentRequest) Descriptor
deprecated
func (*AuditDocumentRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuditDocumentRequest.ProtoReflect.Descriptor instead.
func (*AuditDocumentRequest) GetCollectionName ¶
func (x *AuditDocumentRequest) GetCollectionName() string
func (*AuditDocumentRequest) GetDesc ¶
func (x *AuditDocumentRequest) GetDesc() bool
func (*AuditDocumentRequest) GetDocumentId ¶
func (x *AuditDocumentRequest) GetDocumentId() string
func (*AuditDocumentRequest) GetPage ¶
func (x *AuditDocumentRequest) GetPage() uint32
func (*AuditDocumentRequest) GetPageSize ¶
func (x *AuditDocumentRequest) GetPageSize() uint32
func (*AuditDocumentRequest) ProtoMessage ¶
func (*AuditDocumentRequest) ProtoMessage()
func (*AuditDocumentRequest) ProtoReflect ¶
func (x *AuditDocumentRequest) ProtoReflect() protoreflect.Message
func (*AuditDocumentRequest) Reset ¶
func (x *AuditDocumentRequest) Reset()
func (*AuditDocumentRequest) String ¶
func (x *AuditDocumentRequest) String() string
type AuditDocumentResponse ¶
type AuditDocumentResponse struct { Revisions []*DocumentAtRevision `protobuf:"bytes,1,rep,name=revisions,proto3" json:"revisions,omitempty"` // contains filtered or unexported fields }
func (*AuditDocumentResponse) Descriptor
deprecated
func (*AuditDocumentResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuditDocumentResponse.ProtoReflect.Descriptor instead.
func (*AuditDocumentResponse) GetRevisions ¶
func (x *AuditDocumentResponse) GetRevisions() []*DocumentAtRevision
func (*AuditDocumentResponse) ProtoMessage ¶
func (*AuditDocumentResponse) ProtoMessage()
func (*AuditDocumentResponse) ProtoReflect ¶
func (x *AuditDocumentResponse) ProtoReflect() protoreflect.Message
func (*AuditDocumentResponse) Reset ¶
func (x *AuditDocumentResponse) Reset()
func (*AuditDocumentResponse) String ¶
func (x *AuditDocumentResponse) String() string
type AuthorizationServiceClient ¶
type AuthorizationServiceClient interface { OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) }
AuthorizationServiceClient is the client API for AuthorizationService 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 NewAuthorizationServiceClient ¶
func NewAuthorizationServiceClient(cc grpc.ClientConnInterface) AuthorizationServiceClient
type AuthorizationServiceServer ¶
type AuthorizationServiceServer interface { OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) }
AuthorizationServiceServer is the server API for AuthorizationService service. All implementations should embed UnimplementedAuthorizationServiceServer for forward compatibility
type CloseSessionRequest ¶
type CloseSessionRequest struct {
// contains filtered or unexported fields
}
func (*CloseSessionRequest) Descriptor
deprecated
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (x *CloseSessionRequest) String() string
type CloseSessionResponse ¶
type CloseSessionResponse struct {
// contains filtered or unexported fields
}
func (*CloseSessionResponse) Descriptor
deprecated
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (x *CloseSessionResponse) String() string
type Collection ¶
type Collection struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DocumentIdFieldName string `protobuf:"bytes,2,opt,name=documentIdFieldName,proto3" json:"documentIdFieldName,omitempty"` Fields []*Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"` Indexes []*Index `protobuf:"bytes,4,rep,name=indexes,proto3" json:"indexes,omitempty"` // contains filtered or unexported fields }
func (*Collection) Descriptor
deprecated
func (*Collection) Descriptor() ([]byte, []int)
Deprecated: Use Collection.ProtoReflect.Descriptor instead.
func (*Collection) GetDocumentIdFieldName ¶
func (x *Collection) GetDocumentIdFieldName() string
func (*Collection) GetFields ¶
func (x *Collection) GetFields() []*Field
func (*Collection) GetIndexes ¶
func (x *Collection) GetIndexes() []*Index
func (*Collection) GetName ¶
func (x *Collection) GetName() string
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 ComparisonOperator ¶
type ComparisonOperator int32
const ( ComparisonOperator_EQ ComparisonOperator = 0 ComparisonOperator_NE ComparisonOperator = 1 ComparisonOperator_LT ComparisonOperator = 2 ComparisonOperator_LE ComparisonOperator = 3 ComparisonOperator_GT ComparisonOperator = 4 ComparisonOperator_GE ComparisonOperator = 5 ComparisonOperator_LIKE ComparisonOperator = 6 ComparisonOperator_NOT_LIKE ComparisonOperator = 7 )
func (ComparisonOperator) Descriptor ¶
func (ComparisonOperator) Descriptor() protoreflect.EnumDescriptor
func (ComparisonOperator) Enum ¶
func (x ComparisonOperator) Enum() *ComparisonOperator
func (ComparisonOperator) EnumDescriptor
deprecated
func (ComparisonOperator) EnumDescriptor() ([]byte, []int)
Deprecated: Use ComparisonOperator.Descriptor instead.
func (ComparisonOperator) Number ¶
func (x ComparisonOperator) Number() protoreflect.EnumNumber
func (ComparisonOperator) String ¶
func (x ComparisonOperator) String() string
func (ComparisonOperator) Type ¶
func (ComparisonOperator) Type() protoreflect.EnumType
type CountDocumentsRequest ¶
type CountDocumentsRequest struct { Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*CountDocumentsRequest) Descriptor
deprecated
func (*CountDocumentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CountDocumentsRequest.ProtoReflect.Descriptor instead.
func (*CountDocumentsRequest) GetQuery ¶
func (x *CountDocumentsRequest) GetQuery() *Query
func (*CountDocumentsRequest) ProtoMessage ¶
func (*CountDocumentsRequest) ProtoMessage()
func (*CountDocumentsRequest) ProtoReflect ¶
func (x *CountDocumentsRequest) ProtoReflect() protoreflect.Message
func (*CountDocumentsRequest) Reset ¶
func (x *CountDocumentsRequest) Reset()
func (*CountDocumentsRequest) String ¶
func (x *CountDocumentsRequest) String() string
type CountDocumentsResponse ¶
type CountDocumentsResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*CountDocumentsResponse) Descriptor
deprecated
func (*CountDocumentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CountDocumentsResponse.ProtoReflect.Descriptor instead.
func (*CountDocumentsResponse) GetCount ¶
func (x *CountDocumentsResponse) GetCount() int64
func (*CountDocumentsResponse) ProtoMessage ¶
func (*CountDocumentsResponse) ProtoMessage()
func (*CountDocumentsResponse) ProtoReflect ¶
func (x *CountDocumentsResponse) ProtoReflect() protoreflect.Message
func (*CountDocumentsResponse) Reset ¶
func (x *CountDocumentsResponse) Reset()
func (*CountDocumentsResponse) String ¶
func (x *CountDocumentsResponse) String() string
type CreateCollectionRequest ¶
type CreateCollectionRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DocumentIdFieldName string `protobuf:"bytes,2,opt,name=documentIdFieldName,proto3" json:"documentIdFieldName,omitempty"` Fields []*Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"` Indexes []*Index `protobuf:"bytes,4,rep,name=indexes,proto3" json:"indexes,omitempty"` // contains filtered or unexported fields }
func (*CreateCollectionRequest) Descriptor
deprecated
func (*CreateCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateCollectionRequest.ProtoReflect.Descriptor instead.
func (*CreateCollectionRequest) GetDocumentIdFieldName ¶
func (x *CreateCollectionRequest) GetDocumentIdFieldName() string
func (*CreateCollectionRequest) GetFields ¶
func (x *CreateCollectionRequest) GetFields() []*Field
func (*CreateCollectionRequest) GetIndexes ¶
func (x *CreateCollectionRequest) GetIndexes() []*Index
func (*CreateCollectionRequest) GetName ¶
func (x *CreateCollectionRequest) GetName() 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 {
// contains filtered or unexported fields
}
func (*CreateCollectionResponse) Descriptor
deprecated
func (*CreateCollectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateCollectionResponse.ProtoReflect.Descriptor instead.
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 CreateIndexRequest ¶
type CreateIndexRequest struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` IsUnique bool `protobuf:"varint,3,opt,name=isUnique,proto3" json:"isUnique,omitempty"` // contains filtered or unexported fields }
func (*CreateIndexRequest) Descriptor
deprecated
func (*CreateIndexRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.
func (*CreateIndexRequest) GetCollectionName ¶
func (x *CreateIndexRequest) GetCollectionName() string
func (*CreateIndexRequest) GetFields ¶
func (x *CreateIndexRequest) GetFields() []string
func (*CreateIndexRequest) GetIsUnique ¶
func (x *CreateIndexRequest) GetIsUnique() bool
func (*CreateIndexRequest) ProtoMessage ¶
func (*CreateIndexRequest) ProtoMessage()
func (*CreateIndexRequest) ProtoReflect ¶
func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message
func (*CreateIndexRequest) Reset ¶
func (x *CreateIndexRequest) Reset()
func (*CreateIndexRequest) String ¶
func (x *CreateIndexRequest) String() string
type CreateIndexResponse ¶
type CreateIndexResponse struct {
// contains filtered or unexported fields
}
func (*CreateIndexResponse) Descriptor
deprecated
func (*CreateIndexResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateIndexResponse.ProtoReflect.Descriptor instead.
func (*CreateIndexResponse) ProtoMessage ¶
func (*CreateIndexResponse) ProtoMessage()
func (*CreateIndexResponse) ProtoReflect ¶
func (x *CreateIndexResponse) ProtoReflect() protoreflect.Message
func (*CreateIndexResponse) Reset ¶
func (x *CreateIndexResponse) Reset()
func (*CreateIndexResponse) String ¶
func (x *CreateIndexResponse) String() string
type DeleteCollectionRequest ¶
type DeleteCollectionRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteCollectionRequest) Descriptor
deprecated
func (*DeleteCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCollectionRequest.ProtoReflect.Descriptor instead.
func (*DeleteCollectionRequest) GetName ¶
func (x *DeleteCollectionRequest) GetName() 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 {
// contains filtered or unexported fields
}
func (*DeleteCollectionResponse) Descriptor
deprecated
func (*DeleteCollectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCollectionResponse.ProtoReflect.Descriptor instead.
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 DeleteDocumentsRequest ¶
type DeleteDocumentsRequest struct { Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*DeleteDocumentsRequest) Descriptor
deprecated
func (*DeleteDocumentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDocumentsRequest.ProtoReflect.Descriptor instead.
func (*DeleteDocumentsRequest) GetQuery ¶
func (x *DeleteDocumentsRequest) GetQuery() *Query
func (*DeleteDocumentsRequest) ProtoMessage ¶
func (*DeleteDocumentsRequest) ProtoMessage()
func (*DeleteDocumentsRequest) ProtoReflect ¶
func (x *DeleteDocumentsRequest) ProtoReflect() protoreflect.Message
func (*DeleteDocumentsRequest) Reset ¶
func (x *DeleteDocumentsRequest) Reset()
func (*DeleteDocumentsRequest) String ¶
func (x *DeleteDocumentsRequest) String() string
type DeleteDocumentsResponse ¶
type DeleteDocumentsResponse struct {
// contains filtered or unexported fields
}
func (*DeleteDocumentsResponse) Descriptor
deprecated
func (*DeleteDocumentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDocumentsResponse.ProtoReflect.Descriptor instead.
func (*DeleteDocumentsResponse) ProtoMessage ¶
func (*DeleteDocumentsResponse) ProtoMessage()
func (*DeleteDocumentsResponse) ProtoReflect ¶
func (x *DeleteDocumentsResponse) ProtoReflect() protoreflect.Message
func (*DeleteDocumentsResponse) Reset ¶
func (x *DeleteDocumentsResponse) Reset()
func (*DeleteDocumentsResponse) String ¶
func (x *DeleteDocumentsResponse) String() string
type DeleteIndexRequest ¶
type DeleteIndexRequest struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
func (*DeleteIndexRequest) Descriptor
deprecated
func (*DeleteIndexRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteIndexRequest.ProtoReflect.Descriptor instead.
func (*DeleteIndexRequest) GetCollectionName ¶
func (x *DeleteIndexRequest) GetCollectionName() string
func (*DeleteIndexRequest) GetFields ¶
func (x *DeleteIndexRequest) GetFields() []string
func (*DeleteIndexRequest) ProtoMessage ¶
func (*DeleteIndexRequest) ProtoMessage()
func (*DeleteIndexRequest) ProtoReflect ¶
func (x *DeleteIndexRequest) ProtoReflect() protoreflect.Message
func (*DeleteIndexRequest) Reset ¶
func (x *DeleteIndexRequest) Reset()
func (*DeleteIndexRequest) String ¶
func (x *DeleteIndexRequest) String() string
type DeleteIndexResponse ¶
type DeleteIndexResponse struct {
// contains filtered or unexported fields
}
func (*DeleteIndexResponse) Descriptor
deprecated
func (*DeleteIndexResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteIndexResponse.ProtoReflect.Descriptor instead.
func (*DeleteIndexResponse) ProtoMessage ¶
func (*DeleteIndexResponse) ProtoMessage()
func (*DeleteIndexResponse) ProtoReflect ¶
func (x *DeleteIndexResponse) ProtoReflect() protoreflect.Message
func (*DeleteIndexResponse) Reset ¶
func (x *DeleteIndexResponse) Reset()
func (*DeleteIndexResponse) String ¶
func (x *DeleteIndexResponse) String() string
type DocumentAtRevision ¶
type DocumentAtRevision struct { TransactionId uint64 `protobuf:"varint,1,opt,name=transactionId,proto3" json:"transactionId,omitempty"` DocumentId string `protobuf:"bytes,2,opt,name=documentId,proto3" json:"documentId,omitempty"` Revision uint64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"` Metadata *DocumentMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` Document *structpb.Struct `protobuf:"bytes,5,opt,name=document,proto3" json:"document,omitempty"` // contains filtered or unexported fields }
func (*DocumentAtRevision) Descriptor
deprecated
func (*DocumentAtRevision) Descriptor() ([]byte, []int)
Deprecated: Use DocumentAtRevision.ProtoReflect.Descriptor instead.
func (*DocumentAtRevision) GetDocument ¶
func (x *DocumentAtRevision) GetDocument() *structpb.Struct
func (*DocumentAtRevision) GetDocumentId ¶
func (x *DocumentAtRevision) GetDocumentId() string
func (*DocumentAtRevision) GetMetadata ¶
func (x *DocumentAtRevision) GetMetadata() *DocumentMetadata
func (*DocumentAtRevision) GetRevision ¶
func (x *DocumentAtRevision) GetRevision() uint64
func (*DocumentAtRevision) GetTransactionId ¶
func (x *DocumentAtRevision) GetTransactionId() uint64
func (*DocumentAtRevision) ProtoMessage ¶
func (*DocumentAtRevision) ProtoMessage()
func (*DocumentAtRevision) ProtoReflect ¶
func (x *DocumentAtRevision) ProtoReflect() protoreflect.Message
func (*DocumentAtRevision) Reset ¶
func (x *DocumentAtRevision) Reset()
func (*DocumentAtRevision) String ¶
func (x *DocumentAtRevision) String() string
type DocumentMetadata ¶
type DocumentMetadata struct { Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"` // contains filtered or unexported fields }
func (*DocumentMetadata) Descriptor
deprecated
func (*DocumentMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DocumentMetadata.ProtoReflect.Descriptor instead.
func (*DocumentMetadata) GetDeleted ¶
func (x *DocumentMetadata) GetDeleted() bool
func (*DocumentMetadata) ProtoMessage ¶
func (*DocumentMetadata) ProtoMessage()
func (*DocumentMetadata) ProtoReflect ¶
func (x *DocumentMetadata) ProtoReflect() protoreflect.Message
func (*DocumentMetadata) Reset ¶
func (x *DocumentMetadata) Reset()
func (*DocumentMetadata) String ¶
func (x *DocumentMetadata) String() string
type DocumentServiceClient ¶
type DocumentServiceClient interface { CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*CreateCollectionResponse, error) GetCollections(ctx context.Context, in *GetCollectionsRequest, opts ...grpc.CallOption) (*GetCollectionsResponse, error) GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error) UpdateCollection(ctx context.Context, in *UpdateCollectionRequest, opts ...grpc.CallOption) (*UpdateCollectionResponse, error) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*CreateIndexResponse, error) DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*DeleteIndexResponse, error) InsertDocuments(ctx context.Context, in *InsertDocumentsRequest, opts ...grpc.CallOption) (*InsertDocumentsResponse, error) ReplaceDocuments(ctx context.Context, in *ReplaceDocumentsRequest, opts ...grpc.CallOption) (*ReplaceDocumentsResponse, error) DeleteDocuments(ctx context.Context, in *DeleteDocumentsRequest, opts ...grpc.CallOption) (*DeleteDocumentsResponse, error) SearchDocuments(ctx context.Context, in *SearchDocumentsRequest, opts ...grpc.CallOption) (*SearchDocumentsResponse, error) CountDocuments(ctx context.Context, in *CountDocumentsRequest, opts ...grpc.CallOption) (*CountDocumentsResponse, error) AuditDocument(ctx context.Context, in *AuditDocumentRequest, opts ...grpc.CallOption) (*AuditDocumentResponse, error) ProofDocument(ctx context.Context, in *ProofDocumentRequest, opts ...grpc.CallOption) (*ProofDocumentResponse, error) }
DocumentServiceClient is the client API for DocumentService 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 NewDocumentServiceClient ¶
func NewDocumentServiceClient(cc grpc.ClientConnInterface) DocumentServiceClient
type DocumentServiceServer ¶
type DocumentServiceServer interface { CreateCollection(context.Context, *CreateCollectionRequest) (*CreateCollectionResponse, error) GetCollections(context.Context, *GetCollectionsRequest) (*GetCollectionsResponse, error) GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error) UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionResponse, error) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error) InsertDocuments(context.Context, *InsertDocumentsRequest) (*InsertDocumentsResponse, error) ReplaceDocuments(context.Context, *ReplaceDocumentsRequest) (*ReplaceDocumentsResponse, error) DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error) SearchDocuments(context.Context, *SearchDocumentsRequest) (*SearchDocumentsResponse, error) CountDocuments(context.Context, *CountDocumentsRequest) (*CountDocumentsResponse, error) AuditDocument(context.Context, *AuditDocumentRequest) (*AuditDocumentResponse, error) ProofDocument(context.Context, *ProofDocumentRequest) (*ProofDocumentResponse, error) }
DocumentServiceServer is the server API for DocumentService service. All implementations should embed UnimplementedDocumentServiceServer for forward compatibility
type Field ¶
type Field struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type FieldType `protobuf:"varint,2,opt,name=type,proto3,enum=immudb.model.FieldType" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Field) Descriptor
deprecated
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
func (*Field) ProtoReflect ¶
func (x *Field) ProtoReflect() protoreflect.Message
type FieldComparison ¶
type FieldComparison struct { Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"` Operator ComparisonOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=immudb.model.ComparisonOperator" json:"operator,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*FieldComparison) Descriptor
deprecated
func (*FieldComparison) Descriptor() ([]byte, []int)
Deprecated: Use FieldComparison.ProtoReflect.Descriptor instead.
func (*FieldComparison) GetField ¶
func (x *FieldComparison) GetField() string
func (*FieldComparison) GetOperator ¶
func (x *FieldComparison) GetOperator() ComparisonOperator
func (*FieldComparison) GetValue ¶
func (x *FieldComparison) GetValue() *structpb.Value
func (*FieldComparison) ProtoMessage ¶
func (*FieldComparison) ProtoMessage()
func (*FieldComparison) ProtoReflect ¶
func (x *FieldComparison) ProtoReflect() protoreflect.Message
func (*FieldComparison) Reset ¶
func (x *FieldComparison) Reset()
func (*FieldComparison) String ¶
func (x *FieldComparison) String() string
type FieldType ¶
type FieldType int32
func (FieldType) Descriptor ¶
func (FieldType) Descriptor() protoreflect.EnumDescriptor
func (FieldType) EnumDescriptor
deprecated
func (FieldType) Number ¶
func (x FieldType) Number() protoreflect.EnumNumber
func (FieldType) Type ¶
func (FieldType) Type() protoreflect.EnumType
type GetCollectionRequest ¶
type GetCollectionRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetCollectionRequest) Descriptor
deprecated
func (*GetCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionRequest.ProtoReflect.Descriptor instead.
func (*GetCollectionRequest) GetName ¶
func (x *GetCollectionRequest) GetName() string
func (*GetCollectionRequest) ProtoMessage ¶
func (*GetCollectionRequest) ProtoMessage()
func (*GetCollectionRequest) ProtoReflect ¶
func (x *GetCollectionRequest) ProtoReflect() protoreflect.Message
func (*GetCollectionRequest) Reset ¶
func (x *GetCollectionRequest) Reset()
func (*GetCollectionRequest) String ¶
func (x *GetCollectionRequest) String() string
type GetCollectionResponse ¶
type GetCollectionResponse struct { Collection *Collection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"` // contains filtered or unexported fields }
func (*GetCollectionResponse) Descriptor
deprecated
func (*GetCollectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionResponse.ProtoReflect.Descriptor instead.
func (*GetCollectionResponse) GetCollection ¶
func (x *GetCollectionResponse) GetCollection() *Collection
func (*GetCollectionResponse) ProtoMessage ¶
func (*GetCollectionResponse) ProtoMessage()
func (*GetCollectionResponse) ProtoReflect ¶
func (x *GetCollectionResponse) ProtoReflect() protoreflect.Message
func (*GetCollectionResponse) Reset ¶
func (x *GetCollectionResponse) Reset()
func (*GetCollectionResponse) String ¶
func (x *GetCollectionResponse) String() string
type GetCollectionsRequest ¶
type GetCollectionsRequest struct {
// contains filtered or unexported fields
}
func (*GetCollectionsRequest) Descriptor
deprecated
func (*GetCollectionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionsRequest.ProtoReflect.Descriptor instead.
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"` // 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) 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 Index ¶
type Index struct { Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` IsUnique bool `protobuf:"varint,2,opt,name=isUnique,proto3" json:"isUnique,omitempty"` // contains filtered or unexported fields }
func (*Index) Descriptor
deprecated
func (*Index) GetIsUnique ¶
func (*Index) ProtoMessage ¶
func (*Index) ProtoMessage()
func (*Index) ProtoReflect ¶
func (x *Index) ProtoReflect() protoreflect.Message
type InsertDocumentsRequest ¶
type InsertDocumentsRequest struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` Documents []*structpb.Struct `protobuf:"bytes,2,rep,name=documents,proto3" json:"documents,omitempty"` // contains filtered or unexported fields }
func (*InsertDocumentsRequest) Descriptor
deprecated
func (*InsertDocumentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertDocumentsRequest.ProtoReflect.Descriptor instead.
func (*InsertDocumentsRequest) GetCollectionName ¶
func (x *InsertDocumentsRequest) GetCollectionName() string
func (*InsertDocumentsRequest) GetDocuments ¶
func (x *InsertDocumentsRequest) GetDocuments() []*structpb.Struct
func (*InsertDocumentsRequest) ProtoMessage ¶
func (*InsertDocumentsRequest) ProtoMessage()
func (*InsertDocumentsRequest) ProtoReflect ¶
func (x *InsertDocumentsRequest) ProtoReflect() protoreflect.Message
func (*InsertDocumentsRequest) Reset ¶
func (x *InsertDocumentsRequest) Reset()
func (*InsertDocumentsRequest) String ¶
func (x *InsertDocumentsRequest) String() string
type InsertDocumentsResponse ¶
type InsertDocumentsResponse struct { TransactionId uint64 `protobuf:"varint,1,opt,name=transactionId,proto3" json:"transactionId,omitempty"` DocumentIds []string `protobuf:"bytes,2,rep,name=documentIds,proto3" json:"documentIds,omitempty"` // contains filtered or unexported fields }
func (*InsertDocumentsResponse) Descriptor
deprecated
func (*InsertDocumentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use InsertDocumentsResponse.ProtoReflect.Descriptor instead.
func (*InsertDocumentsResponse) GetDocumentIds ¶
func (x *InsertDocumentsResponse) GetDocumentIds() []string
func (*InsertDocumentsResponse) GetTransactionId ¶
func (x *InsertDocumentsResponse) GetTransactionId() uint64
func (*InsertDocumentsResponse) ProtoMessage ¶
func (*InsertDocumentsResponse) ProtoMessage()
func (*InsertDocumentsResponse) ProtoReflect ¶
func (x *InsertDocumentsResponse) ProtoReflect() protoreflect.Message
func (*InsertDocumentsResponse) Reset ¶
func (x *InsertDocumentsResponse) Reset()
func (*InsertDocumentsResponse) String ¶
func (x *InsertDocumentsResponse) String() string
type KeepAliveRequest ¶
type KeepAliveRequest struct {
// contains filtered or unexported fields
}
func (*KeepAliveRequest) Descriptor
deprecated
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveRequest.ProtoReflect.Descriptor instead.
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) ProtoReflect ¶
func (x *KeepAliveRequest) ProtoReflect() protoreflect.Message
func (*KeepAliveRequest) Reset ¶
func (x *KeepAliveRequest) Reset()
func (*KeepAliveRequest) String ¶
func (x *KeepAliveRequest) String() string
type KeepAliveResponse ¶
type KeepAliveResponse struct {
// contains filtered or unexported fields
}
func (*KeepAliveResponse) Descriptor
deprecated
func (*KeepAliveResponse) Descriptor() ([]byte, []int)
Deprecated: Use KeepAliveResponse.ProtoReflect.Descriptor instead.
func (*KeepAliveResponse) ProtoMessage ¶
func (*KeepAliveResponse) ProtoMessage()
func (*KeepAliveResponse) ProtoReflect ¶
func (x *KeepAliveResponse) ProtoReflect() protoreflect.Message
func (*KeepAliveResponse) Reset ¶
func (x *KeepAliveResponse) Reset()
func (*KeepAliveResponse) String ¶
func (x *KeepAliveResponse) String() string
type OpenSessionRequest ¶
type OpenSessionRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionRequest) Descriptor
deprecated
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.
func (*OpenSessionRequest) GetDatabase ¶
func (x *OpenSessionRequest) GetDatabase() string
func (*OpenSessionRequest) GetPassword ¶
func (x *OpenSessionRequest) GetPassword() string
func (*OpenSessionRequest) GetUsername ¶
func (x *OpenSessionRequest) GetUsername() string
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) ProtoReflect ¶
func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
func (*OpenSessionRequest) Reset ¶
func (x *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶
func (x *OpenSessionRequest) String() string
type OpenSessionResponse ¶
type OpenSessionResponse struct { SessionID string `protobuf:"bytes,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"` ServerUUID string `protobuf:"bytes,2,opt,name=serverUUID,proto3" json:"serverUUID,omitempty"` ExpirationTimestamp int32 `protobuf:"varint,3,opt,name=expirationTimestamp,proto3" json:"expirationTimestamp,omitempty"` InactivityTimestamp int32 `protobuf:"varint,4,opt,name=inactivityTimestamp,proto3" json:"inactivityTimestamp,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionResponse) Descriptor
deprecated
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.
func (*OpenSessionResponse) GetExpirationTimestamp ¶
func (x *OpenSessionResponse) GetExpirationTimestamp() int32
func (*OpenSessionResponse) GetInactivityTimestamp ¶
func (x *OpenSessionResponse) GetInactivityTimestamp() int32
func (*OpenSessionResponse) GetServerUUID ¶
func (x *OpenSessionResponse) GetServerUUID() string
func (*OpenSessionResponse) GetSessionID ¶
func (x *OpenSessionResponse) GetSessionID() string
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) ProtoReflect ¶
func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
func (*OpenSessionResponse) Reset ¶
func (x *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶
func (x *OpenSessionResponse) String() string
type OrderByClause ¶
type OrderByClause struct { Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"` Desc bool `protobuf:"varint,2,opt,name=desc,proto3" json:"desc,omitempty"` // contains filtered or unexported fields }
func (*OrderByClause) Descriptor
deprecated
func (*OrderByClause) Descriptor() ([]byte, []int)
Deprecated: Use OrderByClause.ProtoReflect.Descriptor instead.
func (*OrderByClause) GetDesc ¶
func (x *OrderByClause) GetDesc() bool
func (*OrderByClause) GetField ¶
func (x *OrderByClause) GetField() string
func (*OrderByClause) ProtoMessage ¶
func (*OrderByClause) ProtoMessage()
func (*OrderByClause) ProtoReflect ¶
func (x *OrderByClause) ProtoReflect() protoreflect.Message
func (*OrderByClause) Reset ¶
func (x *OrderByClause) Reset()
func (*OrderByClause) String ¶
func (x *OrderByClause) String() string
type ProofDocumentRequest ¶
type ProofDocumentRequest struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` DocumentId string `protobuf:"bytes,2,opt,name=documentId,proto3" json:"documentId,omitempty"` TransactionId uint64 `protobuf:"varint,3,opt,name=transactionId,proto3" json:"transactionId,omitempty"` ProofSinceTransactionId uint64 `protobuf:"varint,4,opt,name=proofSinceTransactionId,proto3" json:"proofSinceTransactionId,omitempty"` // contains filtered or unexported fields }
func (*ProofDocumentRequest) Descriptor
deprecated
func (*ProofDocumentRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProofDocumentRequest.ProtoReflect.Descriptor instead.
func (*ProofDocumentRequest) GetCollectionName ¶
func (x *ProofDocumentRequest) GetCollectionName() string
func (*ProofDocumentRequest) GetDocumentId ¶
func (x *ProofDocumentRequest) GetDocumentId() string
func (*ProofDocumentRequest) GetProofSinceTransactionId ¶
func (x *ProofDocumentRequest) GetProofSinceTransactionId() uint64
func (*ProofDocumentRequest) GetTransactionId ¶
func (x *ProofDocumentRequest) GetTransactionId() uint64
func (*ProofDocumentRequest) ProtoMessage ¶
func (*ProofDocumentRequest) ProtoMessage()
func (*ProofDocumentRequest) ProtoReflect ¶
func (x *ProofDocumentRequest) ProtoReflect() protoreflect.Message
func (*ProofDocumentRequest) Reset ¶
func (x *ProofDocumentRequest) Reset()
func (*ProofDocumentRequest) String ¶
func (x *ProofDocumentRequest) String() string
type ProofDocumentResponse ¶
type ProofDocumentResponse struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` CollectionId uint32 `protobuf:"varint,2,opt,name=collectionId,proto3" json:"collectionId,omitempty"` DocumentIdFieldName string `protobuf:"bytes,3,opt,name=documentIdFieldName,proto3" json:"documentIdFieldName,omitempty"` EncodedDocument []byte `protobuf:"bytes,4,opt,name=encodedDocument,proto3" json:"encodedDocument,omitempty"` VerifiableTx *schema.VerifiableTxV2 `protobuf:"bytes,5,opt,name=verifiableTx,proto3" json:"verifiableTx,omitempty"` // contains filtered or unexported fields }
func (*ProofDocumentResponse) Descriptor
deprecated
func (*ProofDocumentResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProofDocumentResponse.ProtoReflect.Descriptor instead.
func (*ProofDocumentResponse) GetCollectionId ¶
func (x *ProofDocumentResponse) GetCollectionId() uint32
func (*ProofDocumentResponse) GetDatabase ¶
func (x *ProofDocumentResponse) GetDatabase() string
func (*ProofDocumentResponse) GetDocumentIdFieldName ¶
func (x *ProofDocumentResponse) GetDocumentIdFieldName() string
func (*ProofDocumentResponse) GetEncodedDocument ¶
func (x *ProofDocumentResponse) GetEncodedDocument() []byte
func (*ProofDocumentResponse) GetVerifiableTx ¶
func (x *ProofDocumentResponse) GetVerifiableTx() *schema.VerifiableTxV2
func (*ProofDocumentResponse) ProtoMessage ¶
func (*ProofDocumentResponse) ProtoMessage()
func (*ProofDocumentResponse) ProtoReflect ¶
func (x *ProofDocumentResponse) ProtoReflect() protoreflect.Message
func (*ProofDocumentResponse) Reset ¶
func (x *ProofDocumentResponse) Reset()
func (*ProofDocumentResponse) String ¶
func (x *ProofDocumentResponse) String() string
type Query ¶
type Query struct { CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"` Expressions []*QueryExpression `protobuf:"bytes,2,rep,name=expressions,proto3" json:"expressions,omitempty"` OrderBy []*OrderByClause `protobuf:"bytes,3,rep,name=orderBy,proto3" json:"orderBy,omitempty"` Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*Query) Descriptor
deprecated
func (*Query) GetCollectionName ¶
func (*Query) GetExpressions ¶
func (x *Query) GetExpressions() []*QueryExpression
func (*Query) GetOrderBy ¶
func (x *Query) GetOrderBy() []*OrderByClause
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type QueryExpression ¶
type QueryExpression struct { FieldComparisons []*FieldComparison `protobuf:"bytes,1,rep,name=fieldComparisons,proto3" json:"fieldComparisons,omitempty"` // contains filtered or unexported fields }
func (*QueryExpression) Descriptor
deprecated
func (*QueryExpression) Descriptor() ([]byte, []int)
Deprecated: Use QueryExpression.ProtoReflect.Descriptor instead.
func (*QueryExpression) GetFieldComparisons ¶
func (x *QueryExpression) GetFieldComparisons() []*FieldComparison
func (*QueryExpression) ProtoMessage ¶
func (*QueryExpression) ProtoMessage()
func (*QueryExpression) ProtoReflect ¶
func (x *QueryExpression) ProtoReflect() protoreflect.Message
func (*QueryExpression) Reset ¶
func (x *QueryExpression) Reset()
func (*QueryExpression) String ¶
func (x *QueryExpression) String() string
type ReplaceDocumentsRequest ¶
type ReplaceDocumentsRequest struct { Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Document *structpb.Struct `protobuf:"bytes,2,opt,name=document,proto3" json:"document,omitempty"` // contains filtered or unexported fields }
func (*ReplaceDocumentsRequest) Descriptor
deprecated
func (*ReplaceDocumentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReplaceDocumentsRequest.ProtoReflect.Descriptor instead.
func (*ReplaceDocumentsRequest) GetDocument ¶
func (x *ReplaceDocumentsRequest) GetDocument() *structpb.Struct
func (*ReplaceDocumentsRequest) GetQuery ¶
func (x *ReplaceDocumentsRequest) GetQuery() *Query
func (*ReplaceDocumentsRequest) ProtoMessage ¶
func (*ReplaceDocumentsRequest) ProtoMessage()
func (*ReplaceDocumentsRequest) ProtoReflect ¶
func (x *ReplaceDocumentsRequest) ProtoReflect() protoreflect.Message
func (*ReplaceDocumentsRequest) Reset ¶
func (x *ReplaceDocumentsRequest) Reset()
func (*ReplaceDocumentsRequest) String ¶
func (x *ReplaceDocumentsRequest) String() string
type ReplaceDocumentsResponse ¶
type ReplaceDocumentsResponse struct { Revisions []*DocumentAtRevision `protobuf:"bytes,1,rep,name=revisions,proto3" json:"revisions,omitempty"` // contains filtered or unexported fields }
func (*ReplaceDocumentsResponse) Descriptor
deprecated
func (*ReplaceDocumentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReplaceDocumentsResponse.ProtoReflect.Descriptor instead.
func (*ReplaceDocumentsResponse) GetRevisions ¶
func (x *ReplaceDocumentsResponse) GetRevisions() []*DocumentAtRevision
func (*ReplaceDocumentsResponse) ProtoMessage ¶
func (*ReplaceDocumentsResponse) ProtoMessage()
func (*ReplaceDocumentsResponse) ProtoReflect ¶
func (x *ReplaceDocumentsResponse) ProtoReflect() protoreflect.Message
func (*ReplaceDocumentsResponse) Reset ¶
func (x *ReplaceDocumentsResponse) Reset()
func (*ReplaceDocumentsResponse) String ¶
func (x *ReplaceDocumentsResponse) String() string
type SearchDocumentsRequest ¶
type SearchDocumentsRequest struct { SearchId string `protobuf:"bytes,1,opt,name=searchId,proto3" json:"searchId,omitempty"` Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Page uint32 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"` PageSize uint32 `protobuf:"varint,4,opt,name=pageSize,proto3" json:"pageSize,omitempty"` KeepOpen bool `protobuf:"varint,5,opt,name=keepOpen,proto3" json:"keepOpen,omitempty"` // contains filtered or unexported fields }
func (*SearchDocumentsRequest) Descriptor
deprecated
func (*SearchDocumentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchDocumentsRequest.ProtoReflect.Descriptor instead.
func (*SearchDocumentsRequest) GetKeepOpen ¶
func (x *SearchDocumentsRequest) GetKeepOpen() bool
func (*SearchDocumentsRequest) GetPage ¶
func (x *SearchDocumentsRequest) GetPage() uint32
func (*SearchDocumentsRequest) GetPageSize ¶
func (x *SearchDocumentsRequest) GetPageSize() uint32
func (*SearchDocumentsRequest) GetQuery ¶
func (x *SearchDocumentsRequest) GetQuery() *Query
func (*SearchDocumentsRequest) GetSearchId ¶
func (x *SearchDocumentsRequest) GetSearchId() string
func (*SearchDocumentsRequest) ProtoMessage ¶
func (*SearchDocumentsRequest) ProtoMessage()
func (*SearchDocumentsRequest) ProtoReflect ¶
func (x *SearchDocumentsRequest) ProtoReflect() protoreflect.Message
func (*SearchDocumentsRequest) Reset ¶
func (x *SearchDocumentsRequest) Reset()
func (*SearchDocumentsRequest) String ¶
func (x *SearchDocumentsRequest) String() string
type SearchDocumentsResponse ¶
type SearchDocumentsResponse struct { SearchId string `protobuf:"bytes,1,opt,name=searchId,proto3" json:"searchId,omitempty"` Revisions []*DocumentAtRevision `protobuf:"bytes,2,rep,name=revisions,proto3" json:"revisions,omitempty"` // contains filtered or unexported fields }
func (*SearchDocumentsResponse) Descriptor
deprecated
func (*SearchDocumentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchDocumentsResponse.ProtoReflect.Descriptor instead.
func (*SearchDocumentsResponse) GetRevisions ¶
func (x *SearchDocumentsResponse) GetRevisions() []*DocumentAtRevision
func (*SearchDocumentsResponse) GetSearchId ¶
func (x *SearchDocumentsResponse) GetSearchId() string
func (*SearchDocumentsResponse) ProtoMessage ¶
func (*SearchDocumentsResponse) ProtoMessage()
func (*SearchDocumentsResponse) ProtoReflect ¶
func (x *SearchDocumentsResponse) ProtoReflect() protoreflect.Message
func (*SearchDocumentsResponse) Reset ¶
func (x *SearchDocumentsResponse) Reset()
func (*SearchDocumentsResponse) String ¶
func (x *SearchDocumentsResponse) String() string
type UnimplementedAuthorizationServiceServer ¶
type UnimplementedAuthorizationServiceServer struct { }
UnimplementedAuthorizationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedAuthorizationServiceServer) CloseSession ¶
func (UnimplementedAuthorizationServiceServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
func (UnimplementedAuthorizationServiceServer) KeepAlive ¶
func (UnimplementedAuthorizationServiceServer) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)
func (UnimplementedAuthorizationServiceServer) OpenSession ¶
func (UnimplementedAuthorizationServiceServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
type UnimplementedDocumentServiceServer ¶
type UnimplementedDocumentServiceServer struct { }
UnimplementedDocumentServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedDocumentServiceServer) AuditDocument ¶
func (UnimplementedDocumentServiceServer) AuditDocument(context.Context, *AuditDocumentRequest) (*AuditDocumentResponse, error)
func (UnimplementedDocumentServiceServer) CountDocuments ¶
func (UnimplementedDocumentServiceServer) CountDocuments(context.Context, *CountDocumentsRequest) (*CountDocumentsResponse, error)
func (UnimplementedDocumentServiceServer) CreateCollection ¶
func (UnimplementedDocumentServiceServer) CreateCollection(context.Context, *CreateCollectionRequest) (*CreateCollectionResponse, error)
func (UnimplementedDocumentServiceServer) CreateIndex ¶
func (UnimplementedDocumentServiceServer) CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error)
func (UnimplementedDocumentServiceServer) DeleteCollection ¶
func (UnimplementedDocumentServiceServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
func (UnimplementedDocumentServiceServer) DeleteDocuments ¶
func (UnimplementedDocumentServiceServer) DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error)
func (UnimplementedDocumentServiceServer) DeleteIndex ¶
func (UnimplementedDocumentServiceServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error)
func (UnimplementedDocumentServiceServer) GetCollection ¶
func (UnimplementedDocumentServiceServer) GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error)
func (UnimplementedDocumentServiceServer) GetCollections ¶
func (UnimplementedDocumentServiceServer) GetCollections(context.Context, *GetCollectionsRequest) (*GetCollectionsResponse, error)
func (UnimplementedDocumentServiceServer) InsertDocuments ¶
func (UnimplementedDocumentServiceServer) InsertDocuments(context.Context, *InsertDocumentsRequest) (*InsertDocumentsResponse, error)
func (UnimplementedDocumentServiceServer) ProofDocument ¶
func (UnimplementedDocumentServiceServer) ProofDocument(context.Context, *ProofDocumentRequest) (*ProofDocumentResponse, error)
func (UnimplementedDocumentServiceServer) ReplaceDocuments ¶
func (UnimplementedDocumentServiceServer) ReplaceDocuments(context.Context, *ReplaceDocumentsRequest) (*ReplaceDocumentsResponse, error)
func (UnimplementedDocumentServiceServer) SearchDocuments ¶
func (UnimplementedDocumentServiceServer) SearchDocuments(context.Context, *SearchDocumentsRequest) (*SearchDocumentsResponse, error)
func (UnimplementedDocumentServiceServer) UpdateCollection ¶
func (UnimplementedDocumentServiceServer) UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionResponse, error)
type UnsafeAuthorizationServiceServer ¶
type UnsafeAuthorizationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAuthorizationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthorizationServiceServer will result in compilation errors.
type UnsafeDocumentServiceServer ¶
type UnsafeDocumentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDocumentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DocumentServiceServer will result in compilation errors.
type UpdateCollectionRequest ¶
type UpdateCollectionRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DocumentIdFieldName string `protobuf:"bytes,2,opt,name=documentIdFieldName,proto3" json:"documentIdFieldName,omitempty"` // contains filtered or unexported fields }
func (*UpdateCollectionRequest) Descriptor
deprecated
func (*UpdateCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCollectionRequest.ProtoReflect.Descriptor instead.
func (*UpdateCollectionRequest) GetDocumentIdFieldName ¶
func (x *UpdateCollectionRequest) GetDocumentIdFieldName() string
func (*UpdateCollectionRequest) GetName ¶
func (x *UpdateCollectionRequest) GetName() string
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 UpdateCollectionResponse ¶
type UpdateCollectionResponse struct {
// contains filtered or unexported fields
}
func (*UpdateCollectionResponse) Descriptor
deprecated
func (*UpdateCollectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCollectionResponse.ProtoReflect.Descriptor instead.
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