Documentation
¶
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_GetTokenClient
- type API_GetTokenServer
- type API_ListenClient
- type API_ListenServer
- type API_ReadTransactionClient
- type API_ReadTransactionServer
- type API_WriteTransactionClient
- type API_WriteTransactionServer
- type CollectionConfig
- func (*CollectionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionConfig) GetIndexes() []*Index
- func (x *CollectionConfig) GetName() string
- func (x *CollectionConfig) GetReadFilter() string
- func (x *CollectionConfig) GetSchema() []byte
- func (x *CollectionConfig) GetWriteValidator() string
- func (*CollectionConfig) ProtoMessage()
- func (x *CollectionConfig) ProtoReflect() protoreflect.Message
- func (x *CollectionConfig) Reset()
- func (x *CollectionConfig) String() string
- type CreateReply
- func (*CreateReply) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReply) GetInstanceIDs() []string
- func (x *CreateReply) GetTransactionError() string
- func (*CreateReply) ProtoMessage()
- func (x *CreateReply) ProtoReflect() protoreflect.Message
- func (x *CreateReply) Reset()
- func (x *CreateReply) String() string
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRequest) GetCollectionName() string
- func (x *CreateRequest) GetDbID() []byte
- func (x *CreateRequest) GetInstances() [][]byte
- func (*CreateRequest) ProtoMessage()
- func (x *CreateRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRequest) Reset()
- func (x *CreateRequest) String() string
- type DeleteCollectionReply
- type DeleteCollectionRequest
- func (*DeleteCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCollectionRequest) GetDbID() []byte
- func (x *DeleteCollectionRequest) GetName() string
- func (*DeleteCollectionRequest) ProtoMessage()
- func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCollectionRequest) Reset()
- func (x *DeleteCollectionRequest) String() string
- type DeleteDBReply
- type DeleteDBRequest
- type DeleteReply
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetCollectionName() string
- func (x *DeleteRequest) GetDbID() []byte
- func (x *DeleteRequest) GetInstanceIDs() []string
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DiscardReply
- type DiscardRequest
- type FindByIDReply
- func (*FindByIDReply) Descriptor() ([]byte, []int)deprecated
- func (x *FindByIDReply) GetInstance() []byte
- func (x *FindByIDReply) GetTransactionError() string
- func (*FindByIDReply) ProtoMessage()
- func (x *FindByIDReply) ProtoReflect() protoreflect.Message
- func (x *FindByIDReply) Reset()
- func (x *FindByIDReply) String() string
- type FindByIDRequest
- func (*FindByIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindByIDRequest) GetCollectionName() string
- func (x *FindByIDRequest) GetDbID() []byte
- func (x *FindByIDRequest) GetInstanceID() string
- func (*FindByIDRequest) ProtoMessage()
- func (x *FindByIDRequest) ProtoReflect() protoreflect.Message
- func (x *FindByIDRequest) Reset()
- func (x *FindByIDRequest) String() string
- type FindReply
- func (*FindReply) Descriptor() ([]byte, []int)deprecated
- func (x *FindReply) GetInstances() [][]byte
- func (x *FindReply) GetTransactionError() string
- func (*FindReply) ProtoMessage()
- func (x *FindReply) ProtoReflect() protoreflect.Message
- func (x *FindReply) Reset()
- func (x *FindReply) String() string
- type FindRequest
- func (*FindRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindRequest) GetCollectionName() string
- func (x *FindRequest) GetDbID() []byte
- func (x *FindRequest) GetQueryJSON() []byte
- func (*FindRequest) ProtoMessage()
- func (x *FindRequest) ProtoReflect() protoreflect.Message
- func (x *FindRequest) Reset()
- func (x *FindRequest) String() string
- type GetCollectionIndexesReply
- func (*GetCollectionIndexesReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionIndexesReply) GetIndexes() []*Index
- func (*GetCollectionIndexesReply) ProtoMessage()
- func (x *GetCollectionIndexesReply) ProtoReflect() protoreflect.Message
- func (x *GetCollectionIndexesReply) Reset()
- func (x *GetCollectionIndexesReply) String() string
- type GetCollectionIndexesRequest
- func (*GetCollectionIndexesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionIndexesRequest) GetDbID() []byte
- func (x *GetCollectionIndexesRequest) GetName() string
- func (*GetCollectionIndexesRequest) ProtoMessage()
- func (x *GetCollectionIndexesRequest) ProtoReflect() protoreflect.Message
- func (x *GetCollectionIndexesRequest) Reset()
- func (x *GetCollectionIndexesRequest) String() string
- type GetCollectionInfoReply
- func (*GetCollectionInfoReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionInfoReply) GetIndexes() []*Index
- func (x *GetCollectionInfoReply) GetName() string
- func (x *GetCollectionInfoReply) GetReadFilter() string
- func (x *GetCollectionInfoReply) GetSchema() []byte
- func (x *GetCollectionInfoReply) GetWriteValidator() string
- func (*GetCollectionInfoReply) ProtoMessage()
- func (x *GetCollectionInfoReply) ProtoReflect() protoreflect.Message
- func (x *GetCollectionInfoReply) Reset()
- func (x *GetCollectionInfoReply) String() string
- type GetCollectionInfoRequest
- func (*GetCollectionInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCollectionInfoRequest) GetDbID() []byte
- func (x *GetCollectionInfoRequest) GetName() string
- func (*GetCollectionInfoRequest) ProtoMessage()
- func (x *GetCollectionInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetCollectionInfoRequest) Reset()
- func (x *GetCollectionInfoRequest) String() string
- type GetDBInfoReply
- func (*GetDBInfoReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetDBInfoReply) GetAddrs() [][]byte
- func (x *GetDBInfoReply) GetKey() []byte
- func (x *GetDBInfoReply) GetName() string
- func (*GetDBInfoReply) ProtoMessage()
- func (x *GetDBInfoReply) ProtoReflect() protoreflect.Message
- func (x *GetDBInfoReply) Reset()
- func (x *GetDBInfoReply) String() string
- type GetDBInfoRequest
- type GetTokenReply
- func (*GetTokenReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenReply) GetChallenge() []byte
- func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload
- func (x *GetTokenReply) GetToken() string
- func (*GetTokenReply) ProtoMessage()
- func (x *GetTokenReply) ProtoReflect() protoreflect.Message
- func (x *GetTokenReply) Reset()
- func (x *GetTokenReply) String() string
- type GetTokenReply_Challenge
- type GetTokenReply_Token
- type GetTokenRequest
- func (*GetTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenRequest) GetKey() string
- func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload
- func (x *GetTokenRequest) GetSignature() []byte
- func (*GetTokenRequest) ProtoMessage()
- func (x *GetTokenRequest) ProtoReflect() protoreflect.Message
- func (x *GetTokenRequest) Reset()
- func (x *GetTokenRequest) String() string
- type GetTokenRequest_Key
- type GetTokenRequest_Signature
- type HasReply
- type HasRequest
- func (*HasRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HasRequest) GetCollectionName() string
- func (x *HasRequest) GetDbID() []byte
- func (x *HasRequest) GetInstanceIDs() []string
- func (*HasRequest) ProtoMessage()
- func (x *HasRequest) ProtoReflect() protoreflect.Message
- func (x *HasRequest) Reset()
- func (x *HasRequest) String() string
- type Index
- type ListCollectionsReply
- func (*ListCollectionsReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListCollectionsReply) GetCollections() []*GetCollectionInfoReply
- func (*ListCollectionsReply) ProtoMessage()
- func (x *ListCollectionsReply) ProtoReflect() protoreflect.Message
- func (x *ListCollectionsReply) Reset()
- func (x *ListCollectionsReply) String() string
- type ListCollectionsRequest
- func (*ListCollectionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListCollectionsRequest) GetDbID() []byte
- func (*ListCollectionsRequest) ProtoMessage()
- func (x *ListCollectionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListCollectionsRequest) Reset()
- func (x *ListCollectionsRequest) String() string
- type ListDBsReply
- type ListDBsReply_DB
- func (*ListDBsReply_DB) Descriptor() ([]byte, []int)deprecated
- func (x *ListDBsReply_DB) GetDbID() []byte
- func (x *ListDBsReply_DB) GetInfo() *GetDBInfoReply
- func (*ListDBsReply_DB) ProtoMessage()
- func (x *ListDBsReply_DB) ProtoReflect() protoreflect.Message
- func (x *ListDBsReply_DB) Reset()
- func (x *ListDBsReply_DB) String() string
- type ListDBsRequest
- type ListenReply
- func (*ListenReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListenReply) GetAction() ListenReply_Action
- func (x *ListenReply) GetCollectionName() string
- func (x *ListenReply) GetInstance() []byte
- func (x *ListenReply) GetInstanceID() string
- func (*ListenReply) ProtoMessage()
- func (x *ListenReply) ProtoReflect() protoreflect.Message
- func (x *ListenReply) Reset()
- func (x *ListenReply) String() string
- type ListenReply_Action
- func (ListenReply_Action) Descriptor() protoreflect.EnumDescriptor
- func (x ListenReply_Action) Enum() *ListenReply_Action
- func (ListenReply_Action) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListenReply_Action) Number() protoreflect.EnumNumber
- func (x ListenReply_Action) String() string
- func (ListenReply_Action) Type() protoreflect.EnumType
- type ListenRequest
- func (*ListenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenRequest) GetDbID() []byte
- func (x *ListenRequest) GetFilters() []*ListenRequest_Filter
- func (*ListenRequest) ProtoMessage()
- func (x *ListenRequest) ProtoReflect() protoreflect.Message
- func (x *ListenRequest) Reset()
- func (x *ListenRequest) String() string
- type ListenRequest_Filter
- func (*ListenRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListenRequest_Filter) GetAction() ListenRequest_Filter_Action
- func (x *ListenRequest_Filter) GetCollectionName() string
- func (x *ListenRequest_Filter) GetInstanceID() string
- func (*ListenRequest_Filter) ProtoMessage()
- func (x *ListenRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListenRequest_Filter) Reset()
- func (x *ListenRequest_Filter) String() string
- type ListenRequest_Filter_Action
- func (ListenRequest_Filter_Action) Descriptor() protoreflect.EnumDescriptor
- func (x ListenRequest_Filter_Action) Enum() *ListenRequest_Filter_Action
- func (ListenRequest_Filter_Action) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListenRequest_Filter_Action) Number() protoreflect.EnumNumber
- func (x ListenRequest_Filter_Action) String() string
- func (ListenRequest_Filter_Action) Type() protoreflect.EnumType
- type NewCollectionReply
- type NewCollectionRequest
- func (*NewCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewCollectionRequest) GetConfig() *CollectionConfig
- func (x *NewCollectionRequest) GetDbID() []byte
- func (*NewCollectionRequest) ProtoMessage()
- func (x *NewCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *NewCollectionRequest) Reset()
- func (x *NewCollectionRequest) String() string
- type NewDBFromAddrRequest
- func (*NewDBFromAddrRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewDBFromAddrRequest) GetAddr() []byte
- func (x *NewDBFromAddrRequest) GetBlock() bool
- func (x *NewDBFromAddrRequest) GetCollections() []*CollectionConfig
- func (x *NewDBFromAddrRequest) GetKey() []byte
- func (x *NewDBFromAddrRequest) GetLogKey() []byte
- func (x *NewDBFromAddrRequest) GetName() string
- func (x *NewDBFromAddrRequest) GetThreadKey() []byte
- func (*NewDBFromAddrRequest) ProtoMessage()
- func (x *NewDBFromAddrRequest) ProtoReflect() protoreflect.Message
- func (x *NewDBFromAddrRequest) Reset()
- func (x *NewDBFromAddrRequest) String() string
- type NewDBReply
- type NewDBRequest
- func (*NewDBRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewDBRequest) GetBlock() bool
- func (x *NewDBRequest) GetCollections() []*CollectionConfig
- func (x *NewDBRequest) GetDbID() []byte
- func (x *NewDBRequest) GetLogKey() []byte
- func (x *NewDBRequest) GetName() string
- func (x *NewDBRequest) GetThreadKey() []byte
- func (*NewDBRequest) ProtoMessage()
- func (x *NewDBRequest) ProtoReflect() protoreflect.Message
- func (x *NewDBRequest) Reset()
- func (x *NewDBRequest) String() string
- type ReadTransactionReply
- func (*ReadTransactionReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTransactionReply) GetFindByIDReply() *FindByIDReply
- func (x *ReadTransactionReply) GetFindReply() *FindReply
- func (x *ReadTransactionReply) GetHasReply() *HasReply
- func (m *ReadTransactionReply) GetOption() isReadTransactionReply_Option
- func (*ReadTransactionReply) ProtoMessage()
- func (x *ReadTransactionReply) ProtoReflect() protoreflect.Message
- func (x *ReadTransactionReply) Reset()
- func (x *ReadTransactionReply) String() string
- type ReadTransactionReply_FindByIDReply
- type ReadTransactionReply_FindReply
- type ReadTransactionReply_HasReply
- type ReadTransactionRequest
- func (*ReadTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTransactionRequest) GetFindByIDRequest() *FindByIDRequest
- func (x *ReadTransactionRequest) GetFindRequest() *FindRequest
- func (x *ReadTransactionRequest) GetHasRequest() *HasRequest
- func (m *ReadTransactionRequest) GetOption() isReadTransactionRequest_Option
- func (x *ReadTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest
- func (*ReadTransactionRequest) ProtoMessage()
- func (x *ReadTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *ReadTransactionRequest) Reset()
- func (x *ReadTransactionRequest) String() string
- type ReadTransactionRequest_FindByIDRequest
- type ReadTransactionRequest_FindRequest
- type ReadTransactionRequest_HasRequest
- type ReadTransactionRequest_StartTransactionRequest
- type SaveReply
- type SaveRequest
- func (*SaveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SaveRequest) GetCollectionName() string
- func (x *SaveRequest) GetDbID() []byte
- func (x *SaveRequest) GetInstances() [][]byte
- func (*SaveRequest) ProtoMessage()
- func (x *SaveRequest) ProtoReflect() protoreflect.Message
- func (x *SaveRequest) Reset()
- func (x *SaveRequest) String() string
- type StartTransactionRequest
- func (*StartTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartTransactionRequest) GetCollectionName() string
- func (x *StartTransactionRequest) GetDbID() []byte
- func (*StartTransactionRequest) ProtoMessage()
- func (x *StartTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *StartTransactionRequest) Reset()
- func (x *StartTransactionRequest) String() string
- type UnimplementedAPIServer
- func (*UnimplementedAPIServer) Create(context.Context, *CreateRequest) (*CreateReply, error)
- func (*UnimplementedAPIServer) Delete(context.Context, *DeleteRequest) (*DeleteReply, error)
- func (*UnimplementedAPIServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionReply, error)
- func (*UnimplementedAPIServer) DeleteDB(context.Context, *DeleteDBRequest) (*DeleteDBReply, error)
- func (*UnimplementedAPIServer) Find(context.Context, *FindRequest) (*FindReply, error)
- func (*UnimplementedAPIServer) FindByID(context.Context, *FindByIDRequest) (*FindByIDReply, error)
- func (*UnimplementedAPIServer) GetCollectionIndexes(context.Context, *GetCollectionIndexesRequest) (*GetCollectionIndexesReply, error)
- func (*UnimplementedAPIServer) GetCollectionInfo(context.Context, *GetCollectionInfoRequest) (*GetCollectionInfoReply, error)
- func (*UnimplementedAPIServer) GetDBInfo(context.Context, *GetDBInfoRequest) (*GetDBInfoReply, error)
- func (*UnimplementedAPIServer) GetToken(API_GetTokenServer) error
- func (*UnimplementedAPIServer) Has(context.Context, *HasRequest) (*HasReply, error)
- func (*UnimplementedAPIServer) ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsReply, error)
- func (*UnimplementedAPIServer) ListDBs(context.Context, *ListDBsRequest) (*ListDBsReply, error)
- func (*UnimplementedAPIServer) Listen(*ListenRequest, API_ListenServer) error
- func (*UnimplementedAPIServer) NewCollection(context.Context, *NewCollectionRequest) (*NewCollectionReply, error)
- func (*UnimplementedAPIServer) NewDB(context.Context, *NewDBRequest) (*NewDBReply, error)
- func (*UnimplementedAPIServer) NewDBFromAddr(context.Context, *NewDBFromAddrRequest) (*NewDBReply, error)
- func (*UnimplementedAPIServer) ReadTransaction(API_ReadTransactionServer) error
- func (*UnimplementedAPIServer) Save(context.Context, *SaveRequest) (*SaveReply, error)
- func (*UnimplementedAPIServer) UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionReply, error)
- func (*UnimplementedAPIServer) Verify(context.Context, *VerifyRequest) (*VerifyReply, error)
- func (*UnimplementedAPIServer) WriteTransaction(API_WriteTransactionServer) error
- type UpdateCollectionReply
- type UpdateCollectionRequest
- func (*UpdateCollectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCollectionRequest) GetConfig() *CollectionConfig
- func (x *UpdateCollectionRequest) GetDbID() []byte
- func (*UpdateCollectionRequest) ProtoMessage()
- func (x *UpdateCollectionRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateCollectionRequest) Reset()
- func (x *UpdateCollectionRequest) String() string
- type VerifyReply
- type VerifyRequest
- func (*VerifyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyRequest) GetCollectionName() string
- func (x *VerifyRequest) GetDbID() []byte
- func (x *VerifyRequest) GetInstances() [][]byte
- func (*VerifyRequest) ProtoMessage()
- func (x *VerifyRequest) ProtoReflect() protoreflect.Message
- func (x *VerifyRequest) Reset()
- func (x *VerifyRequest) String() string
- type WriteTransactionReply
- func (*WriteTransactionReply) Descriptor() ([]byte, []int)deprecated
- func (x *WriteTransactionReply) GetCreateReply() *CreateReply
- func (x *WriteTransactionReply) GetDeleteReply() *DeleteReply
- func (x *WriteTransactionReply) GetDiscardReply() *DiscardReply
- func (x *WriteTransactionReply) GetFindByIDReply() *FindByIDReply
- func (x *WriteTransactionReply) GetFindReply() *FindReply
- func (x *WriteTransactionReply) GetHasReply() *HasReply
- func (m *WriteTransactionReply) GetOption() isWriteTransactionReply_Option
- func (x *WriteTransactionReply) GetSaveReply() *SaveReply
- func (x *WriteTransactionReply) GetVerifyReply() *VerifyReply
- func (*WriteTransactionReply) ProtoMessage()
- func (x *WriteTransactionReply) ProtoReflect() protoreflect.Message
- func (x *WriteTransactionReply) Reset()
- func (x *WriteTransactionReply) String() string
- type WriteTransactionReply_CreateReply
- type WriteTransactionReply_DeleteReply
- type WriteTransactionReply_DiscardReply
- type WriteTransactionReply_FindByIDReply
- type WriteTransactionReply_FindReply
- type WriteTransactionReply_HasReply
- type WriteTransactionReply_SaveReply
- type WriteTransactionReply_VerifyReply
- type WriteTransactionRequest
- func (*WriteTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteTransactionRequest) GetCreateRequest() *CreateRequest
- func (x *WriteTransactionRequest) GetDeleteRequest() *DeleteRequest
- func (x *WriteTransactionRequest) GetDiscardRequest() *DiscardRequest
- func (x *WriteTransactionRequest) GetFindByIDRequest() *FindByIDRequest
- func (x *WriteTransactionRequest) GetFindRequest() *FindRequest
- func (x *WriteTransactionRequest) GetHasRequest() *HasRequest
- func (m *WriteTransactionRequest) GetOption() isWriteTransactionRequest_Option
- func (x *WriteTransactionRequest) GetSaveRequest() *SaveRequest
- func (x *WriteTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest
- func (x *WriteTransactionRequest) GetVerifyRequest() *VerifyRequest
- func (*WriteTransactionRequest) ProtoMessage()
- func (x *WriteTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *WriteTransactionRequest) Reset()
- func (x *WriteTransactionRequest) String() string
- type WriteTransactionRequest_CreateRequest
- type WriteTransactionRequest_DeleteRequest
- type WriteTransactionRequest_DiscardRequest
- type WriteTransactionRequest_FindByIDRequest
- type WriteTransactionRequest_FindRequest
- type WriteTransactionRequest_HasRequest
- type WriteTransactionRequest_SaveRequest
- type WriteTransactionRequest_StartTransactionRequest
- type WriteTransactionRequest_VerifyRequest
Constants ¶
This section is empty.
Variables ¶
var ( ListenRequest_Filter_Action_name = map[int32]string{ 0: "ALL", 1: "CREATE", 2: "SAVE", 3: "DELETE", } ListenRequest_Filter_Action_value = map[string]int32{ "ALL": 0, "CREATE": 1, "SAVE": 2, "DELETE": 3, } )
Enum value maps for ListenRequest_Filter_Action.
var ( ListenReply_Action_name = map[int32]string{ 0: "CREATE", 1: "SAVE", 2: "DELETE", } ListenReply_Action_value = map[string]int32{ "CREATE": 0, "SAVE": 1, "DELETE": 2, } )
Enum value maps for ListenReply_Action.
var File_threads_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface {
GetToken(ctx context.Context, opts ...grpc.CallOption) (API_GetTokenClient, error)
NewDB(ctx context.Context, in *NewDBRequest, opts ...grpc.CallOption) (*NewDBReply, error)
NewDBFromAddr(ctx context.Context, in *NewDBFromAddrRequest, opts ...grpc.CallOption) (*NewDBReply, error)
ListDBs(ctx context.Context, in *ListDBsRequest, opts ...grpc.CallOption) (*ListDBsReply, error)
GetDBInfo(ctx context.Context, in *GetDBInfoRequest, opts ...grpc.CallOption) (*GetDBInfoReply, error)
DeleteDB(ctx context.Context, in *DeleteDBRequest, opts ...grpc.CallOption) (*DeleteDBReply, error)
NewCollection(ctx context.Context, in *NewCollectionRequest, opts ...grpc.CallOption) (*NewCollectionReply, error)
UpdateCollection(ctx context.Context, in *UpdateCollectionRequest, opts ...grpc.CallOption) (*UpdateCollectionReply, error)
DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionReply, error)
GetCollectionInfo(ctx context.Context, in *GetCollectionInfoRequest, opts ...grpc.CallOption) (*GetCollectionInfoReply, error)
// Deprecated: Do not use.
GetCollectionIndexes(ctx context.Context, in *GetCollectionIndexesRequest, opts ...grpc.CallOption) (*GetCollectionIndexesReply, error)
ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsReply, error)
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, error)
Verify(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyReply, error)
Save(ctx context.Context, in *SaveRequest, opts ...grpc.CallOption) (*SaveReply, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error)
Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasReply, error)
Find(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindReply, error)
FindByID(ctx context.Context, in *FindByIDRequest, opts ...grpc.CallOption) (*FindByIDReply, error)
ReadTransaction(ctx context.Context, opts ...grpc.CallOption) (API_ReadTransactionClient, error)
WriteTransaction(ctx context.Context, opts ...grpc.CallOption) (API_WriteTransactionClient, error)
Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error)
}
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc grpc.ClientConnInterface) APIClient
type APIServer ¶
type APIServer interface {
GetToken(API_GetTokenServer) error
NewDB(context.Context, *NewDBRequest) (*NewDBReply, error)
NewDBFromAddr(context.Context, *NewDBFromAddrRequest) (*NewDBReply, error)
ListDBs(context.Context, *ListDBsRequest) (*ListDBsReply, error)
GetDBInfo(context.Context, *GetDBInfoRequest) (*GetDBInfoReply, error)
DeleteDB(context.Context, *DeleteDBRequest) (*DeleteDBReply, error)
NewCollection(context.Context, *NewCollectionRequest) (*NewCollectionReply, error)
UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionReply, error)
DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionReply, error)
GetCollectionInfo(context.Context, *GetCollectionInfoRequest) (*GetCollectionInfoReply, error)
// Deprecated: Do not use.
GetCollectionIndexes(context.Context, *GetCollectionIndexesRequest) (*GetCollectionIndexesReply, error)
ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsReply, error)
Create(context.Context, *CreateRequest) (*CreateReply, error)
Verify(context.Context, *VerifyRequest) (*VerifyReply, error)
Save(context.Context, *SaveRequest) (*SaveReply, error)
Delete(context.Context, *DeleteRequest) (*DeleteReply, error)
Has(context.Context, *HasRequest) (*HasReply, error)
Find(context.Context, *FindRequest) (*FindReply, error)
FindByID(context.Context, *FindByIDRequest) (*FindByIDReply, error)
ReadTransaction(API_ReadTransactionServer) error
WriteTransaction(API_WriteTransactionServer) error
Listen(*ListenRequest, API_ListenServer) error
}
APIServer is the server API for API service.
type API_GetTokenClient ¶ added in v0.1.13
type API_GetTokenClient interface {
Send(*GetTokenRequest) error
Recv() (*GetTokenReply, error)
grpc.ClientStream
}
type API_GetTokenServer ¶ added in v0.1.13
type API_GetTokenServer interface {
Send(*GetTokenReply) error
Recv() (*GetTokenRequest, error)
grpc.ServerStream
}
type API_ListenClient ¶
type API_ListenClient interface {
Recv() (*ListenReply, error)
grpc.ClientStream
}
type API_ListenServer ¶
type API_ListenServer interface {
Send(*ListenReply) error
grpc.ServerStream
}
type API_ReadTransactionClient ¶
type API_ReadTransactionClient interface {
Send(*ReadTransactionRequest) error
Recv() (*ReadTransactionReply, error)
grpc.ClientStream
}
type API_ReadTransactionServer ¶
type API_ReadTransactionServer interface {
Send(*ReadTransactionReply) error
Recv() (*ReadTransactionRequest, error)
grpc.ServerStream
}
type API_WriteTransactionClient ¶
type API_WriteTransactionClient interface {
Send(*WriteTransactionRequest) error
Recv() (*WriteTransactionReply, error)
grpc.ClientStream
}
type API_WriteTransactionServer ¶
type API_WriteTransactionServer interface {
Send(*WriteTransactionReply) error
Recv() (*WriteTransactionRequest, error)
grpc.ServerStream
}
type CollectionConfig ¶ added in v0.1.12
type CollectionConfig struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Schema []byte `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
Indexes []*Index `protobuf:"bytes,3,rep,name=indexes,proto3" json:"indexes,omitempty"`
WriteValidator string `protobuf:"bytes,4,opt,name=writeValidator,proto3" json:"writeValidator,omitempty"`
ReadFilter string `protobuf:"bytes,5,opt,name=readFilter,proto3" json:"readFilter,omitempty"`
// contains filtered or unexported fields
}
func (*CollectionConfig) Descriptor
deprecated
added in
v0.1.12
func (*CollectionConfig) Descriptor() ([]byte, []int)
Deprecated: Use CollectionConfig.ProtoReflect.Descriptor instead.
func (*CollectionConfig) GetIndexes ¶ added in v0.1.12
func (x *CollectionConfig) GetIndexes() []*Index
func (*CollectionConfig) GetName ¶ added in v0.1.12
func (x *CollectionConfig) GetName() string
func (*CollectionConfig) GetReadFilter ¶ added in v1.0.0
func (x *CollectionConfig) GetReadFilter() string
func (*CollectionConfig) GetSchema ¶ added in v0.1.12
func (x *CollectionConfig) GetSchema() []byte
func (*CollectionConfig) GetWriteValidator ¶ added in v1.0.0
func (x *CollectionConfig) GetWriteValidator() string
func (*CollectionConfig) ProtoMessage ¶ added in v0.1.12
func (*CollectionConfig) ProtoMessage()
func (*CollectionConfig) ProtoReflect ¶ added in v1.0.1
func (x *CollectionConfig) ProtoReflect() protoreflect.Message
func (*CollectionConfig) Reset ¶ added in v0.1.12
func (x *CollectionConfig) Reset()
func (*CollectionConfig) String ¶ added in v0.1.12
func (x *CollectionConfig) String() string
type CreateReply ¶ added in v0.1.12
type CreateReply struct {
InstanceIDs []string `protobuf:"bytes,1,rep,name=instanceIDs,proto3" json:"instanceIDs,omitempty"`
TransactionError string `protobuf:"bytes,2,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*CreateReply) Descriptor
deprecated
added in
v0.1.12
func (*CreateReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateReply.ProtoReflect.Descriptor instead.
func (*CreateReply) GetInstanceIDs ¶ added in v0.1.13
func (x *CreateReply) GetInstanceIDs() []string
func (*CreateReply) GetTransactionError ¶ added in v1.0.0
func (x *CreateReply) GetTransactionError() string
func (*CreateReply) ProtoMessage ¶ added in v0.1.12
func (*CreateReply) ProtoMessage()
func (*CreateReply) ProtoReflect ¶ added in v1.0.1
func (x *CreateReply) ProtoReflect() protoreflect.Message
func (*CreateReply) Reset ¶ added in v0.1.12
func (x *CreateReply) Reset()
func (*CreateReply) String ¶ added in v0.1.12
func (x *CreateReply) String() string
type CreateRequest ¶ added in v0.1.12
type CreateRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
Instances [][]byte `protobuf:"bytes,3,rep,name=instances,proto3" json:"instances,omitempty"`
// contains filtered or unexported fields
}
func (*CreateRequest) Descriptor
deprecated
added in
v0.1.12
func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetCollectionName ¶ added in v0.1.12
func (x *CreateRequest) GetCollectionName() string
func (*CreateRequest) GetDbID ¶ added in v0.1.12
func (x *CreateRequest) GetDbID() []byte
func (*CreateRequest) GetInstances ¶ added in v0.1.13
func (x *CreateRequest) GetInstances() [][]byte
func (*CreateRequest) ProtoMessage ¶ added in v0.1.12
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶ added in v1.0.1
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶ added in v0.1.12
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶ added in v0.1.12
func (x *CreateRequest) String() string
type DeleteCollectionReply ¶ added in v0.1.19
type DeleteCollectionReply struct {
// contains filtered or unexported fields
}
func (*DeleteCollectionReply) Descriptor
deprecated
added in
v0.1.19
func (*DeleteCollectionReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCollectionReply.ProtoReflect.Descriptor instead.
func (*DeleteCollectionReply) ProtoMessage ¶ added in v0.1.19
func (*DeleteCollectionReply) ProtoMessage()
func (*DeleteCollectionReply) ProtoReflect ¶ added in v1.0.1
func (x *DeleteCollectionReply) ProtoReflect() protoreflect.Message
func (*DeleteCollectionReply) Reset ¶ added in v0.1.19
func (x *DeleteCollectionReply) Reset()
func (*DeleteCollectionReply) String ¶ added in v0.1.19
func (x *DeleteCollectionReply) String() string
type DeleteCollectionRequest ¶ added in v0.1.19
type DeleteCollectionRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteCollectionRequest) Descriptor
deprecated
added in
v0.1.19
func (*DeleteCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCollectionRequest.ProtoReflect.Descriptor instead.
func (*DeleteCollectionRequest) GetDbID ¶ added in v0.1.19
func (x *DeleteCollectionRequest) GetDbID() []byte
func (*DeleteCollectionRequest) GetName ¶ added in v0.1.19
func (x *DeleteCollectionRequest) GetName() string
func (*DeleteCollectionRequest) ProtoMessage ¶ added in v0.1.19
func (*DeleteCollectionRequest) ProtoMessage()
func (*DeleteCollectionRequest) ProtoReflect ¶ added in v1.0.1
func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message
func (*DeleteCollectionRequest) Reset ¶ added in v0.1.19
func (x *DeleteCollectionRequest) Reset()
func (*DeleteCollectionRequest) String ¶ added in v0.1.19
func (x *DeleteCollectionRequest) String() string
type DeleteDBReply ¶ added in v0.1.15
type DeleteDBReply struct {
// contains filtered or unexported fields
}
func (*DeleteDBReply) Descriptor
deprecated
added in
v0.1.15
func (*DeleteDBReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDBReply.ProtoReflect.Descriptor instead.
func (*DeleteDBReply) ProtoMessage ¶ added in v0.1.15
func (*DeleteDBReply) ProtoMessage()
func (*DeleteDBReply) ProtoReflect ¶ added in v1.0.1
func (x *DeleteDBReply) ProtoReflect() protoreflect.Message
func (*DeleteDBReply) Reset ¶ added in v0.1.15
func (x *DeleteDBReply) Reset()
func (*DeleteDBReply) String ¶ added in v0.1.15
func (x *DeleteDBReply) String() string
type DeleteDBRequest ¶ added in v0.1.15
type DeleteDBRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteDBRequest) Descriptor
deprecated
added in
v0.1.15
func (*DeleteDBRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDBRequest.ProtoReflect.Descriptor instead.
func (*DeleteDBRequest) GetDbID ¶ added in v0.1.15
func (x *DeleteDBRequest) GetDbID() []byte
func (*DeleteDBRequest) ProtoMessage ¶ added in v0.1.15
func (*DeleteDBRequest) ProtoMessage()
func (*DeleteDBRequest) ProtoReflect ¶ added in v1.0.1
func (x *DeleteDBRequest) ProtoReflect() protoreflect.Message
func (*DeleteDBRequest) Reset ¶ added in v0.1.15
func (x *DeleteDBRequest) Reset()
func (*DeleteDBRequest) String ¶ added in v0.1.15
func (x *DeleteDBRequest) String() string
type DeleteReply ¶ added in v0.1.12
type DeleteReply struct {
TransactionError string `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteReply) Descriptor
deprecated
added in
v0.1.12
func (*DeleteReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteReply.ProtoReflect.Descriptor instead.
func (*DeleteReply) GetTransactionError ¶ added in v1.0.0
func (x *DeleteReply) GetTransactionError() string
func (*DeleteReply) ProtoMessage ¶ added in v0.1.12
func (*DeleteReply) ProtoMessage()
func (*DeleteReply) ProtoReflect ¶ added in v1.0.1
func (x *DeleteReply) ProtoReflect() protoreflect.Message
func (*DeleteReply) Reset ¶ added in v0.1.12
func (x *DeleteReply) Reset()
func (*DeleteReply) String ¶ added in v0.1.12
func (x *DeleteReply) String() string
type DeleteRequest ¶ added in v0.1.12
type DeleteRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
InstanceIDs []string `protobuf:"bytes,3,rep,name=instanceIDs,proto3" json:"instanceIDs,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRequest) Descriptor
deprecated
added in
v0.1.12
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetCollectionName ¶ added in v0.1.12
func (x *DeleteRequest) GetCollectionName() string
func (*DeleteRequest) GetDbID ¶ added in v0.1.12
func (x *DeleteRequest) GetDbID() []byte
func (*DeleteRequest) GetInstanceIDs ¶ added in v0.1.12
func (x *DeleteRequest) GetInstanceIDs() []string
func (*DeleteRequest) ProtoMessage ¶ added in v0.1.12
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶ added in v1.0.1
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶ added in v0.1.12
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶ added in v0.1.12
func (x *DeleteRequest) String() string
type DiscardReply ¶ added in v1.0.0
type DiscardReply struct {
// contains filtered or unexported fields
}
func (*DiscardReply) Descriptor
deprecated
added in
v1.0.0
func (*DiscardReply) Descriptor() ([]byte, []int)
Deprecated: Use DiscardReply.ProtoReflect.Descriptor instead.
func (*DiscardReply) ProtoMessage ¶ added in v1.0.0
func (*DiscardReply) ProtoMessage()
func (*DiscardReply) ProtoReflect ¶ added in v1.0.1
func (x *DiscardReply) ProtoReflect() protoreflect.Message
func (*DiscardReply) Reset ¶ added in v1.0.0
func (x *DiscardReply) Reset()
func (*DiscardReply) String ¶ added in v1.0.0
func (x *DiscardReply) String() string
type DiscardRequest ¶ added in v1.0.0
type DiscardRequest struct {
// contains filtered or unexported fields
}
func (*DiscardRequest) Descriptor
deprecated
added in
v1.0.0
func (*DiscardRequest) Descriptor() ([]byte, []int)
Deprecated: Use DiscardRequest.ProtoReflect.Descriptor instead.
func (*DiscardRequest) ProtoMessage ¶ added in v1.0.0
func (*DiscardRequest) ProtoMessage()
func (*DiscardRequest) ProtoReflect ¶ added in v1.0.1
func (x *DiscardRequest) ProtoReflect() protoreflect.Message
func (*DiscardRequest) Reset ¶ added in v1.0.0
func (x *DiscardRequest) Reset()
func (*DiscardRequest) String ¶ added in v1.0.0
func (x *DiscardRequest) String() string
type FindByIDReply ¶ added in v0.1.12
type FindByIDReply struct {
Instance []byte `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
TransactionError string `protobuf:"bytes,2,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*FindByIDReply) Descriptor
deprecated
added in
v0.1.12
func (*FindByIDReply) Descriptor() ([]byte, []int)
Deprecated: Use FindByIDReply.ProtoReflect.Descriptor instead.
func (*FindByIDReply) GetInstance ¶ added in v0.1.12
func (x *FindByIDReply) GetInstance() []byte
func (*FindByIDReply) GetTransactionError ¶ added in v1.0.0
func (x *FindByIDReply) GetTransactionError() string
func (*FindByIDReply) ProtoMessage ¶ added in v0.1.12
func (*FindByIDReply) ProtoMessage()
func (*FindByIDReply) ProtoReflect ¶ added in v1.0.1
func (x *FindByIDReply) ProtoReflect() protoreflect.Message
func (*FindByIDReply) Reset ¶ added in v0.1.12
func (x *FindByIDReply) Reset()
func (*FindByIDReply) String ¶ added in v0.1.12
func (x *FindByIDReply) String() string
type FindByIDRequest ¶ added in v0.1.12
type FindByIDRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
InstanceID string `protobuf:"bytes,3,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
// contains filtered or unexported fields
}
func (*FindByIDRequest) Descriptor
deprecated
added in
v0.1.12
func (*FindByIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindByIDRequest.ProtoReflect.Descriptor instead.
func (*FindByIDRequest) GetCollectionName ¶ added in v0.1.12
func (x *FindByIDRequest) GetCollectionName() string
func (*FindByIDRequest) GetDbID ¶ added in v0.1.12
func (x *FindByIDRequest) GetDbID() []byte
func (*FindByIDRequest) GetInstanceID ¶ added in v0.1.12
func (x *FindByIDRequest) GetInstanceID() string
func (*FindByIDRequest) ProtoMessage ¶ added in v0.1.12
func (*FindByIDRequest) ProtoMessage()
func (*FindByIDRequest) ProtoReflect ¶ added in v1.0.1
func (x *FindByIDRequest) ProtoReflect() protoreflect.Message
func (*FindByIDRequest) Reset ¶ added in v0.1.12
func (x *FindByIDRequest) Reset()
func (*FindByIDRequest) String ¶ added in v0.1.12
func (x *FindByIDRequest) String() string
type FindReply ¶ added in v0.1.12
type FindReply struct {
Instances [][]byte `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
TransactionError string `protobuf:"bytes,2,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*FindReply) Descriptor
deprecated
added in
v0.1.12
func (*FindReply) GetInstances ¶ added in v0.1.12
func (*FindReply) GetTransactionError ¶ added in v1.0.0
func (*FindReply) ProtoMessage ¶ added in v0.1.12
func (*FindReply) ProtoMessage()
func (*FindReply) ProtoReflect ¶ added in v1.0.1
func (x *FindReply) ProtoReflect() protoreflect.Message
type FindRequest ¶ added in v0.1.12
type FindRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
QueryJSON []byte `protobuf:"bytes,3,opt,name=queryJSON,proto3" json:"queryJSON,omitempty"`
// contains filtered or unexported fields
}
func (*FindRequest) Descriptor
deprecated
added in
v0.1.12
func (*FindRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindRequest.ProtoReflect.Descriptor instead.
func (*FindRequest) GetCollectionName ¶ added in v0.1.12
func (x *FindRequest) GetCollectionName() string
func (*FindRequest) GetDbID ¶ added in v0.1.12
func (x *FindRequest) GetDbID() []byte
func (*FindRequest) GetQueryJSON ¶ added in v0.1.12
func (x *FindRequest) GetQueryJSON() []byte
func (*FindRequest) ProtoMessage ¶ added in v0.1.12
func (*FindRequest) ProtoMessage()
func (*FindRequest) ProtoReflect ¶ added in v1.0.1
func (x *FindRequest) ProtoReflect() protoreflect.Message
func (*FindRequest) Reset ¶ added in v0.1.12
func (x *FindRequest) Reset()
func (*FindRequest) String ¶ added in v0.1.12
func (x *FindRequest) String() string
type GetCollectionIndexesReply ¶ added in v0.1.19
type GetCollectionIndexesReply struct {
Indexes []*Index `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"`
// contains filtered or unexported fields
}
func (*GetCollectionIndexesReply) Descriptor
deprecated
added in
v0.1.19
func (*GetCollectionIndexesReply) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionIndexesReply.ProtoReflect.Descriptor instead.
func (*GetCollectionIndexesReply) GetIndexes ¶ added in v0.1.19
func (x *GetCollectionIndexesReply) GetIndexes() []*Index
func (*GetCollectionIndexesReply) ProtoMessage ¶ added in v0.1.19
func (*GetCollectionIndexesReply) ProtoMessage()
func (*GetCollectionIndexesReply) ProtoReflect ¶ added in v1.0.1
func (x *GetCollectionIndexesReply) ProtoReflect() protoreflect.Message
func (*GetCollectionIndexesReply) Reset ¶ added in v0.1.19
func (x *GetCollectionIndexesReply) Reset()
func (*GetCollectionIndexesReply) String ¶ added in v0.1.19
func (x *GetCollectionIndexesReply) String() string
type GetCollectionIndexesRequest ¶ added in v0.1.19
type GetCollectionIndexesRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetCollectionIndexesRequest) Descriptor
deprecated
added in
v0.1.19
func (*GetCollectionIndexesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionIndexesRequest.ProtoReflect.Descriptor instead.
func (*GetCollectionIndexesRequest) GetDbID ¶ added in v0.1.19
func (x *GetCollectionIndexesRequest) GetDbID() []byte
func (*GetCollectionIndexesRequest) GetName ¶ added in v0.1.19
func (x *GetCollectionIndexesRequest) GetName() string
func (*GetCollectionIndexesRequest) ProtoMessage ¶ added in v0.1.19
func (*GetCollectionIndexesRequest) ProtoMessage()
func (*GetCollectionIndexesRequest) ProtoReflect ¶ added in v1.0.1
func (x *GetCollectionIndexesRequest) ProtoReflect() protoreflect.Message
func (*GetCollectionIndexesRequest) Reset ¶ added in v0.1.19
func (x *GetCollectionIndexesRequest) Reset()
func (*GetCollectionIndexesRequest) String ¶ added in v0.1.19
func (x *GetCollectionIndexesRequest) String() string
type GetCollectionInfoReply ¶ added in v0.1.22
type GetCollectionInfoReply struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Schema []byte `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
Indexes []*Index `protobuf:"bytes,3,rep,name=indexes,proto3" json:"indexes,omitempty"`
WriteValidator string `protobuf:"bytes,4,opt,name=writeValidator,proto3" json:"writeValidator,omitempty"`
ReadFilter string `protobuf:"bytes,5,opt,name=readFilter,proto3" json:"readFilter,omitempty"`
// contains filtered or unexported fields
}
func (*GetCollectionInfoReply) Descriptor
deprecated
added in
v0.1.22
func (*GetCollectionInfoReply) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionInfoReply.ProtoReflect.Descriptor instead.
func (*GetCollectionInfoReply) GetIndexes ¶ added in v0.1.22
func (x *GetCollectionInfoReply) GetIndexes() []*Index
func (*GetCollectionInfoReply) GetName ¶ added in v0.1.22
func (x *GetCollectionInfoReply) GetName() string
func (*GetCollectionInfoReply) GetReadFilter ¶ added in v1.0.0
func (x *GetCollectionInfoReply) GetReadFilter() string
func (*GetCollectionInfoReply) GetSchema ¶ added in v0.1.22
func (x *GetCollectionInfoReply) GetSchema() []byte
func (*GetCollectionInfoReply) GetWriteValidator ¶ added in v1.0.0
func (x *GetCollectionInfoReply) GetWriteValidator() string
func (*GetCollectionInfoReply) ProtoMessage ¶ added in v0.1.22
func (*GetCollectionInfoReply) ProtoMessage()
func (*GetCollectionInfoReply) ProtoReflect ¶ added in v1.0.1
func (x *GetCollectionInfoReply) ProtoReflect() protoreflect.Message
func (*GetCollectionInfoReply) Reset ¶ added in v0.1.22
func (x *GetCollectionInfoReply) Reset()
func (*GetCollectionInfoReply) String ¶ added in v0.1.22
func (x *GetCollectionInfoReply) String() string
type GetCollectionInfoRequest ¶ added in v0.1.22
type GetCollectionInfoRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetCollectionInfoRequest) Descriptor
deprecated
added in
v0.1.22
func (*GetCollectionInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCollectionInfoRequest.ProtoReflect.Descriptor instead.
func (*GetCollectionInfoRequest) GetDbID ¶ added in v0.1.22
func (x *GetCollectionInfoRequest) GetDbID() []byte
func (*GetCollectionInfoRequest) GetName ¶ added in v0.1.22
func (x *GetCollectionInfoRequest) GetName() string
func (*GetCollectionInfoRequest) ProtoMessage ¶ added in v0.1.22
func (*GetCollectionInfoRequest) ProtoMessage()
func (*GetCollectionInfoRequest) ProtoReflect ¶ added in v1.0.1
func (x *GetCollectionInfoRequest) ProtoReflect() protoreflect.Message
func (*GetCollectionInfoRequest) Reset ¶ added in v0.1.22
func (x *GetCollectionInfoRequest) Reset()
func (*GetCollectionInfoRequest) String ¶ added in v0.1.22
func (x *GetCollectionInfoRequest) String() string
type GetDBInfoReply ¶ added in v0.1.12
type GetDBInfoReply struct {
Addrs [][]byte `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetDBInfoReply) Descriptor
deprecated
added in
v0.1.12
func (*GetDBInfoReply) Descriptor() ([]byte, []int)
Deprecated: Use GetDBInfoReply.ProtoReflect.Descriptor instead.
func (*GetDBInfoReply) GetAddrs ¶ added in v0.1.13
func (x *GetDBInfoReply) GetAddrs() [][]byte
func (*GetDBInfoReply) GetKey ¶ added in v0.1.13
func (x *GetDBInfoReply) GetKey() []byte
func (*GetDBInfoReply) GetName ¶ added in v0.1.19
func (x *GetDBInfoReply) GetName() string
func (*GetDBInfoReply) ProtoMessage ¶ added in v0.1.12
func (*GetDBInfoReply) ProtoMessage()
func (*GetDBInfoReply) ProtoReflect ¶ added in v1.0.1
func (x *GetDBInfoReply) ProtoReflect() protoreflect.Message
func (*GetDBInfoReply) Reset ¶ added in v0.1.12
func (x *GetDBInfoReply) Reset()
func (*GetDBInfoReply) String ¶ added in v0.1.12
func (x *GetDBInfoReply) String() string
type GetDBInfoRequest ¶ added in v0.1.12
type GetDBInfoRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
// contains filtered or unexported fields
}
func (*GetDBInfoRequest) Descriptor
deprecated
added in
v0.1.12
func (*GetDBInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDBInfoRequest.ProtoReflect.Descriptor instead.
func (*GetDBInfoRequest) GetDbID ¶ added in v0.1.12
func (x *GetDBInfoRequest) GetDbID() []byte
func (*GetDBInfoRequest) ProtoMessage ¶ added in v0.1.12
func (*GetDBInfoRequest) ProtoMessage()
func (*GetDBInfoRequest) ProtoReflect ¶ added in v1.0.1
func (x *GetDBInfoRequest) ProtoReflect() protoreflect.Message
func (*GetDBInfoRequest) Reset ¶ added in v0.1.12
func (x *GetDBInfoRequest) Reset()
func (*GetDBInfoRequest) String ¶ added in v0.1.12
func (x *GetDBInfoRequest) String() string
type GetTokenReply ¶ added in v0.1.13
type GetTokenReply struct {
// Types that are assignable to Payload:
// *GetTokenReply_Challenge
// *GetTokenReply_Token
Payload isGetTokenReply_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*GetTokenReply) Descriptor
deprecated
added in
v0.1.13
func (*GetTokenReply) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenReply.ProtoReflect.Descriptor instead.
func (*GetTokenReply) GetChallenge ¶ added in v0.1.13
func (x *GetTokenReply) GetChallenge() []byte
func (*GetTokenReply) GetPayload ¶ added in v0.1.13
func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload
func (*GetTokenReply) GetToken ¶ added in v0.1.13
func (x *GetTokenReply) GetToken() string
func (*GetTokenReply) ProtoMessage ¶ added in v0.1.13
func (*GetTokenReply) ProtoMessage()
func (*GetTokenReply) ProtoReflect ¶ added in v1.0.1
func (x *GetTokenReply) ProtoReflect() protoreflect.Message
func (*GetTokenReply) Reset ¶ added in v0.1.13
func (x *GetTokenReply) Reset()
func (*GetTokenReply) String ¶ added in v0.1.13
func (x *GetTokenReply) String() string
type GetTokenReply_Challenge ¶ added in v0.1.13
type GetTokenReply_Challenge struct {
Challenge []byte `protobuf:"bytes,1,opt,name=challenge,proto3,oneof"`
}
type GetTokenReply_Token ¶ added in v0.1.13
type GetTokenReply_Token struct {
Token string `protobuf:"bytes,2,opt,name=token,proto3,oneof"`
}
type GetTokenRequest ¶ added in v0.1.13
type GetTokenRequest struct {
// Types that are assignable to Payload:
// *GetTokenRequest_Key
// *GetTokenRequest_Signature
Payload isGetTokenRequest_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*GetTokenRequest) Descriptor
deprecated
added in
v0.1.13
func (*GetTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenRequest.ProtoReflect.Descriptor instead.
func (*GetTokenRequest) GetKey ¶ added in v0.1.13
func (x *GetTokenRequest) GetKey() string
func (*GetTokenRequest) GetPayload ¶ added in v0.1.13
func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload
func (*GetTokenRequest) GetSignature ¶ added in v0.1.13
func (x *GetTokenRequest) GetSignature() []byte
func (*GetTokenRequest) ProtoMessage ¶ added in v0.1.13
func (*GetTokenRequest) ProtoMessage()
func (*GetTokenRequest) ProtoReflect ¶ added in v1.0.1
func (x *GetTokenRequest) ProtoReflect() protoreflect.Message
func (*GetTokenRequest) Reset ¶ added in v0.1.13
func (x *GetTokenRequest) Reset()
func (*GetTokenRequest) String ¶ added in v0.1.13
func (x *GetTokenRequest) String() string
type GetTokenRequest_Key ¶ added in v0.1.13
type GetTokenRequest_Key struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}
type GetTokenRequest_Signature ¶ added in v0.1.13
type GetTokenRequest_Signature struct {
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3,oneof"`
}
type HasReply ¶ added in v0.1.12
type HasReply struct {
Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
TransactionError string `protobuf:"bytes,2,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*HasReply) Descriptor
deprecated
added in
v0.1.12
func (*HasReply) GetTransactionError ¶ added in v1.0.0
func (*HasReply) ProtoMessage ¶ added in v0.1.12
func (*HasReply) ProtoMessage()
func (*HasReply) ProtoReflect ¶ added in v1.0.1
func (x *HasReply) ProtoReflect() protoreflect.Message
type HasRequest ¶ added in v0.1.12
type HasRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
InstanceIDs []string `protobuf:"bytes,3,rep,name=instanceIDs,proto3" json:"instanceIDs,omitempty"`
// contains filtered or unexported fields
}
func (*HasRequest) Descriptor
deprecated
added in
v0.1.12
func (*HasRequest) Descriptor() ([]byte, []int)
Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.
func (*HasRequest) GetCollectionName ¶ added in v0.1.12
func (x *HasRequest) GetCollectionName() string
func (*HasRequest) GetDbID ¶ added in v0.1.12
func (x *HasRequest) GetDbID() []byte
func (*HasRequest) GetInstanceIDs ¶ added in v0.1.12
func (x *HasRequest) GetInstanceIDs() []string
func (*HasRequest) ProtoMessage ¶ added in v0.1.12
func (*HasRequest) ProtoMessage()
func (*HasRequest) ProtoReflect ¶ added in v1.0.1
func (x *HasRequest) ProtoReflect() protoreflect.Message
func (*HasRequest) Reset ¶ added in v0.1.12
func (x *HasRequest) Reset()
func (*HasRequest) String ¶ added in v0.1.12
func (x *HasRequest) String() string
type Index ¶ added in v0.1.19
type Index struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Unique bool `protobuf:"varint,2,opt,name=unique,proto3" json:"unique,omitempty"`
// contains filtered or unexported fields
}
func (*Index) Descriptor
deprecated
added in
v0.1.19
func (*Index) ProtoMessage ¶ added in v0.1.19
func (*Index) ProtoMessage()
func (*Index) ProtoReflect ¶ added in v1.0.1
func (x *Index) ProtoReflect() protoreflect.Message
type ListCollectionsReply ¶ added in v0.1.22
type ListCollectionsReply struct {
Collections []*GetCollectionInfoReply `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
// contains filtered or unexported fields
}
func (*ListCollectionsReply) Descriptor
deprecated
added in
v0.1.22
func (*ListCollectionsReply) Descriptor() ([]byte, []int)
Deprecated: Use ListCollectionsReply.ProtoReflect.Descriptor instead.
func (*ListCollectionsReply) GetCollections ¶ added in v0.1.22
func (x *ListCollectionsReply) GetCollections() []*GetCollectionInfoReply
func (*ListCollectionsReply) ProtoMessage ¶ added in v0.1.22
func (*ListCollectionsReply) ProtoMessage()
func (*ListCollectionsReply) ProtoReflect ¶ added in v1.0.1
func (x *ListCollectionsReply) ProtoReflect() protoreflect.Message
func (*ListCollectionsReply) Reset ¶ added in v0.1.22
func (x *ListCollectionsReply) Reset()
func (*ListCollectionsReply) String ¶ added in v0.1.22
func (x *ListCollectionsReply) String() string
type ListCollectionsRequest ¶ added in v0.1.22
type ListCollectionsRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
// contains filtered or unexported fields
}
func (*ListCollectionsRequest) Descriptor
deprecated
added in
v0.1.22
func (*ListCollectionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListCollectionsRequest.ProtoReflect.Descriptor instead.
func (*ListCollectionsRequest) GetDbID ¶ added in v0.1.22
func (x *ListCollectionsRequest) GetDbID() []byte
func (*ListCollectionsRequest) ProtoMessage ¶ added in v0.1.22
func (*ListCollectionsRequest) ProtoMessage()
func (*ListCollectionsRequest) ProtoReflect ¶ added in v1.0.1
func (x *ListCollectionsRequest) ProtoReflect() protoreflect.Message
func (*ListCollectionsRequest) Reset ¶ added in v0.1.22
func (x *ListCollectionsRequest) Reset()
func (*ListCollectionsRequest) String ¶ added in v0.1.22
func (x *ListCollectionsRequest) String() string
type ListDBsReply ¶ added in v0.1.19
type ListDBsReply struct {
Dbs []*ListDBsReply_DB `protobuf:"bytes,1,rep,name=dbs,proto3" json:"dbs,omitempty"`
// contains filtered or unexported fields
}
func (*ListDBsReply) Descriptor
deprecated
added in
v0.1.19
func (*ListDBsReply) Descriptor() ([]byte, []int)
Deprecated: Use ListDBsReply.ProtoReflect.Descriptor instead.
func (*ListDBsReply) GetDbs ¶ added in v0.1.19
func (x *ListDBsReply) GetDbs() []*ListDBsReply_DB
func (*ListDBsReply) ProtoMessage ¶ added in v0.1.19
func (*ListDBsReply) ProtoMessage()
func (*ListDBsReply) ProtoReflect ¶ added in v1.0.1
func (x *ListDBsReply) ProtoReflect() protoreflect.Message
func (*ListDBsReply) Reset ¶ added in v0.1.19
func (x *ListDBsReply) Reset()
func (*ListDBsReply) String ¶ added in v0.1.19
func (x *ListDBsReply) String() string
type ListDBsReply_DB ¶ added in v0.1.19
type ListDBsReply_DB struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Info *GetDBInfoReply `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
// contains filtered or unexported fields
}
func (*ListDBsReply_DB) Descriptor
deprecated
added in
v0.1.19
func (*ListDBsReply_DB) Descriptor() ([]byte, []int)
Deprecated: Use ListDBsReply_DB.ProtoReflect.Descriptor instead.
func (*ListDBsReply_DB) GetDbID ¶ added in v0.1.19
func (x *ListDBsReply_DB) GetDbID() []byte
func (*ListDBsReply_DB) GetInfo ¶ added in v0.1.19
func (x *ListDBsReply_DB) GetInfo() *GetDBInfoReply
func (*ListDBsReply_DB) ProtoMessage ¶ added in v0.1.19
func (*ListDBsReply_DB) ProtoMessage()
func (*ListDBsReply_DB) ProtoReflect ¶ added in v1.0.1
func (x *ListDBsReply_DB) ProtoReflect() protoreflect.Message
func (*ListDBsReply_DB) Reset ¶ added in v0.1.19
func (x *ListDBsReply_DB) Reset()
func (*ListDBsReply_DB) String ¶ added in v0.1.19
func (x *ListDBsReply_DB) String() string
type ListDBsRequest ¶ added in v0.1.19
type ListDBsRequest struct {
// contains filtered or unexported fields
}
func (*ListDBsRequest) Descriptor
deprecated
added in
v0.1.19
func (*ListDBsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDBsRequest.ProtoReflect.Descriptor instead.
func (*ListDBsRequest) ProtoMessage ¶ added in v0.1.19
func (*ListDBsRequest) ProtoMessage()
func (*ListDBsRequest) ProtoReflect ¶ added in v1.0.1
func (x *ListDBsRequest) ProtoReflect() protoreflect.Message
func (*ListDBsRequest) Reset ¶ added in v0.1.19
func (x *ListDBsRequest) Reset()
func (*ListDBsRequest) String ¶ added in v0.1.19
func (x *ListDBsRequest) String() string
type ListenReply ¶
type ListenReply struct {
CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
InstanceID string `protobuf:"bytes,2,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
Action ListenReply_Action `protobuf:"varint,3,opt,name=action,proto3,enum=threads.pb.ListenReply_Action" json:"action,omitempty"`
Instance []byte `protobuf:"bytes,4,opt,name=instance,proto3" json:"instance,omitempty"`
// contains filtered or unexported fields
}
func (*ListenReply) Descriptor
deprecated
func (*ListenReply) Descriptor() ([]byte, []int)
Deprecated: Use ListenReply.ProtoReflect.Descriptor instead.
func (*ListenReply) GetAction ¶
func (x *ListenReply) GetAction() ListenReply_Action
func (*ListenReply) GetCollectionName ¶ added in v0.1.12
func (x *ListenReply) GetCollectionName() string
func (*ListenReply) GetInstance ¶ added in v0.1.12
func (x *ListenReply) GetInstance() []byte
func (*ListenReply) GetInstanceID ¶ added in v0.1.12
func (x *ListenReply) GetInstanceID() string
func (*ListenReply) ProtoMessage ¶
func (*ListenReply) ProtoMessage()
func (*ListenReply) ProtoReflect ¶ added in v1.0.1
func (x *ListenReply) ProtoReflect() protoreflect.Message
func (*ListenReply) Reset ¶
func (x *ListenReply) Reset()
func (*ListenReply) String ¶
func (x *ListenReply) String() string
type ListenReply_Action ¶
type ListenReply_Action int32
const ( ListenReply_CREATE ListenReply_Action = 0 ListenReply_SAVE ListenReply_Action = 1 ListenReply_DELETE ListenReply_Action = 2 )
func (ListenReply_Action) Descriptor ¶ added in v1.0.1
func (ListenReply_Action) Descriptor() protoreflect.EnumDescriptor
func (ListenReply_Action) Enum ¶ added in v1.0.1
func (x ListenReply_Action) Enum() *ListenReply_Action
func (ListenReply_Action) EnumDescriptor
deprecated
func (ListenReply_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use ListenReply_Action.Descriptor instead.
func (ListenReply_Action) Number ¶ added in v1.0.1
func (x ListenReply_Action) Number() protoreflect.EnumNumber
func (ListenReply_Action) String ¶
func (x ListenReply_Action) String() string
func (ListenReply_Action) Type ¶ added in v1.0.1
func (ListenReply_Action) Type() protoreflect.EnumType
type ListenRequest ¶
type ListenRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Filters []*ListenRequest_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
// contains filtered or unexported fields
}
func (*ListenRequest) Descriptor
deprecated
func (*ListenRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.
func (*ListenRequest) GetDbID ¶ added in v0.1.12
func (x *ListenRequest) GetDbID() []byte
func (*ListenRequest) GetFilters ¶
func (x *ListenRequest) GetFilters() []*ListenRequest_Filter
func (*ListenRequest) ProtoMessage ¶
func (*ListenRequest) ProtoMessage()
func (*ListenRequest) ProtoReflect ¶ added in v1.0.1
func (x *ListenRequest) ProtoReflect() protoreflect.Message
func (*ListenRequest) Reset ¶
func (x *ListenRequest) Reset()
func (*ListenRequest) String ¶
func (x *ListenRequest) String() string
type ListenRequest_Filter ¶
type ListenRequest_Filter struct {
CollectionName string `protobuf:"bytes,1,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
InstanceID string `protobuf:"bytes,2,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
Action ListenRequest_Filter_Action `protobuf:"varint,3,opt,name=action,proto3,enum=threads.pb.ListenRequest_Filter_Action" json:"action,omitempty"`
// contains filtered or unexported fields
}
func (*ListenRequest_Filter) Descriptor
deprecated
func (*ListenRequest_Filter) Descriptor() ([]byte, []int)
Deprecated: Use ListenRequest_Filter.ProtoReflect.Descriptor instead.
func (*ListenRequest_Filter) GetAction ¶
func (x *ListenRequest_Filter) GetAction() ListenRequest_Filter_Action
func (*ListenRequest_Filter) GetCollectionName ¶ added in v0.1.12
func (x *ListenRequest_Filter) GetCollectionName() string
func (*ListenRequest_Filter) GetInstanceID ¶ added in v0.1.12
func (x *ListenRequest_Filter) GetInstanceID() string
func (*ListenRequest_Filter) ProtoMessage ¶
func (*ListenRequest_Filter) ProtoMessage()
func (*ListenRequest_Filter) ProtoReflect ¶ added in v1.0.1
func (x *ListenRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListenRequest_Filter) Reset ¶
func (x *ListenRequest_Filter) Reset()
func (*ListenRequest_Filter) String ¶
func (x *ListenRequest_Filter) String() string
type ListenRequest_Filter_Action ¶
type ListenRequest_Filter_Action int32
const ( ListenRequest_Filter_ALL ListenRequest_Filter_Action = 0 ListenRequest_Filter_CREATE ListenRequest_Filter_Action = 1 ListenRequest_Filter_SAVE ListenRequest_Filter_Action = 2 ListenRequest_Filter_DELETE ListenRequest_Filter_Action = 3 )
func (ListenRequest_Filter_Action) Descriptor ¶ added in v1.0.1
func (ListenRequest_Filter_Action) Descriptor() protoreflect.EnumDescriptor
func (ListenRequest_Filter_Action) Enum ¶ added in v1.0.1
func (x ListenRequest_Filter_Action) Enum() *ListenRequest_Filter_Action
func (ListenRequest_Filter_Action) EnumDescriptor
deprecated
func (ListenRequest_Filter_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use ListenRequest_Filter_Action.Descriptor instead.
func (ListenRequest_Filter_Action) Number ¶ added in v1.0.1
func (x ListenRequest_Filter_Action) Number() protoreflect.EnumNumber
func (ListenRequest_Filter_Action) String ¶
func (x ListenRequest_Filter_Action) String() string
func (ListenRequest_Filter_Action) Type ¶ added in v1.0.1
func (ListenRequest_Filter_Action) Type() protoreflect.EnumType
type NewCollectionReply ¶ added in v0.1.12
type NewCollectionReply struct {
// contains filtered or unexported fields
}
func (*NewCollectionReply) Descriptor
deprecated
added in
v0.1.12
func (*NewCollectionReply) Descriptor() ([]byte, []int)
Deprecated: Use NewCollectionReply.ProtoReflect.Descriptor instead.
func (*NewCollectionReply) ProtoMessage ¶ added in v0.1.12
func (*NewCollectionReply) ProtoMessage()
func (*NewCollectionReply) ProtoReflect ¶ added in v1.0.1
func (x *NewCollectionReply) ProtoReflect() protoreflect.Message
func (*NewCollectionReply) Reset ¶ added in v0.1.12
func (x *NewCollectionReply) Reset()
func (*NewCollectionReply) String ¶ added in v0.1.12
func (x *NewCollectionReply) String() string
type NewCollectionRequest ¶ added in v0.1.12
type NewCollectionRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Config *CollectionConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*NewCollectionRequest) Descriptor
deprecated
added in
v0.1.12
func (*NewCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewCollectionRequest.ProtoReflect.Descriptor instead.
func (*NewCollectionRequest) GetConfig ¶ added in v0.1.12
func (x *NewCollectionRequest) GetConfig() *CollectionConfig
func (*NewCollectionRequest) GetDbID ¶ added in v0.1.12
func (x *NewCollectionRequest) GetDbID() []byte
func (*NewCollectionRequest) ProtoMessage ¶ added in v0.1.12
func (*NewCollectionRequest) ProtoMessage()
func (*NewCollectionRequest) ProtoReflect ¶ added in v1.0.1
func (x *NewCollectionRequest) ProtoReflect() protoreflect.Message
func (*NewCollectionRequest) Reset ¶ added in v0.1.12
func (x *NewCollectionRequest) Reset()
func (*NewCollectionRequest) String ¶ added in v0.1.12
func (x *NewCollectionRequest) String() string
type NewDBFromAddrRequest ¶ added in v0.1.12
type NewDBFromAddrRequest struct {
Addr []byte `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Collections []*CollectionConfig `protobuf:"bytes,3,rep,name=collections,proto3" json:"collections,omitempty"`
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
Block bool `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"`
ThreadKey []byte `protobuf:"bytes,6,opt,name=threadKey,proto3" json:"threadKey,omitempty"`
LogKey []byte `protobuf:"bytes,7,opt,name=logKey,proto3" json:"logKey,omitempty"`
// contains filtered or unexported fields
}
func (*NewDBFromAddrRequest) Descriptor
deprecated
added in
v0.1.12
func (*NewDBFromAddrRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewDBFromAddrRequest.ProtoReflect.Descriptor instead.
func (*NewDBFromAddrRequest) GetAddr ¶ added in v0.1.13
func (x *NewDBFromAddrRequest) GetAddr() []byte
func (*NewDBFromAddrRequest) GetBlock ¶ added in v0.1.22
func (x *NewDBFromAddrRequest) GetBlock() bool
func (*NewDBFromAddrRequest) GetCollections ¶ added in v0.1.12
func (x *NewDBFromAddrRequest) GetCollections() []*CollectionConfig
func (*NewDBFromAddrRequest) GetKey ¶ added in v0.1.13
func (x *NewDBFromAddrRequest) GetKey() []byte
func (*NewDBFromAddrRequest) GetLogKey ¶ added in v1.0.1
func (x *NewDBFromAddrRequest) GetLogKey() []byte
func (*NewDBFromAddrRequest) GetName ¶ added in v0.1.19
func (x *NewDBFromAddrRequest) GetName() string
func (*NewDBFromAddrRequest) GetThreadKey ¶ added in v1.0.1
func (x *NewDBFromAddrRequest) GetThreadKey() []byte
func (*NewDBFromAddrRequest) ProtoMessage ¶ added in v0.1.12
func (*NewDBFromAddrRequest) ProtoMessage()
func (*NewDBFromAddrRequest) ProtoReflect ¶ added in v1.0.1
func (x *NewDBFromAddrRequest) ProtoReflect() protoreflect.Message
func (*NewDBFromAddrRequest) Reset ¶ added in v0.1.12
func (x *NewDBFromAddrRequest) Reset()
func (*NewDBFromAddrRequest) String ¶ added in v0.1.12
func (x *NewDBFromAddrRequest) String() string
type NewDBReply ¶ added in v0.1.12
type NewDBReply struct {
// contains filtered or unexported fields
}
func (*NewDBReply) Descriptor
deprecated
added in
v0.1.12
func (*NewDBReply) Descriptor() ([]byte, []int)
Deprecated: Use NewDBReply.ProtoReflect.Descriptor instead.
func (*NewDBReply) ProtoMessage ¶ added in v0.1.12
func (*NewDBReply) ProtoMessage()
func (*NewDBReply) ProtoReflect ¶ added in v1.0.1
func (x *NewDBReply) ProtoReflect() protoreflect.Message
func (*NewDBReply) Reset ¶ added in v0.1.12
func (x *NewDBReply) Reset()
func (*NewDBReply) String ¶ added in v0.1.12
func (x *NewDBReply) String() string
type NewDBRequest ¶ added in v0.1.12
type NewDBRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Collections []*CollectionConfig `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Block bool `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"`
ThreadKey []byte `protobuf:"bytes,6,opt,name=threadKey,proto3" json:"threadKey,omitempty"`
LogKey []byte `protobuf:"bytes,7,opt,name=logKey,proto3" json:"logKey,omitempty"`
// contains filtered or unexported fields
}
func (*NewDBRequest) Descriptor
deprecated
added in
v0.1.12
func (*NewDBRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewDBRequest.ProtoReflect.Descriptor instead.
func (*NewDBRequest) GetBlock ¶ added in v1.0.1
func (x *NewDBRequest) GetBlock() bool
func (*NewDBRequest) GetCollections ¶ added in v0.1.13
func (x *NewDBRequest) GetCollections() []*CollectionConfig
func (*NewDBRequest) GetDbID ¶ added in v0.1.12
func (x *NewDBRequest) GetDbID() []byte
func (*NewDBRequest) GetLogKey ¶ added in v1.0.1
func (x *NewDBRequest) GetLogKey() []byte
func (*NewDBRequest) GetName ¶ added in v0.1.19
func (x *NewDBRequest) GetName() string
func (*NewDBRequest) GetThreadKey ¶ added in v1.0.1
func (x *NewDBRequest) GetThreadKey() []byte
func (*NewDBRequest) ProtoMessage ¶ added in v0.1.12
func (*NewDBRequest) ProtoMessage()
func (*NewDBRequest) ProtoReflect ¶ added in v1.0.1
func (x *NewDBRequest) ProtoReflect() protoreflect.Message
func (*NewDBRequest) Reset ¶ added in v0.1.12
func (x *NewDBRequest) Reset()
func (*NewDBRequest) String ¶ added in v0.1.12
func (x *NewDBRequest) String() string
type ReadTransactionReply ¶
type ReadTransactionReply struct {
// Types that are assignable to Option:
// *ReadTransactionReply_HasReply
// *ReadTransactionReply_FindReply
// *ReadTransactionReply_FindByIDReply
Option isReadTransactionReply_Option `protobuf_oneof:"option"`
// contains filtered or unexported fields
}
func (*ReadTransactionReply) Descriptor
deprecated
func (*ReadTransactionReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadTransactionReply.ProtoReflect.Descriptor instead.
func (*ReadTransactionReply) GetFindByIDReply ¶ added in v0.1.12
func (x *ReadTransactionReply) GetFindByIDReply() *FindByIDReply
func (*ReadTransactionReply) GetFindReply ¶ added in v0.1.12
func (x *ReadTransactionReply) GetFindReply() *FindReply
func (*ReadTransactionReply) GetHasReply ¶ added in v0.1.12
func (x *ReadTransactionReply) GetHasReply() *HasReply
func (*ReadTransactionReply) GetOption ¶
func (m *ReadTransactionReply) GetOption() isReadTransactionReply_Option
func (*ReadTransactionReply) ProtoMessage ¶
func (*ReadTransactionReply) ProtoMessage()
func (*ReadTransactionReply) ProtoReflect ¶ added in v1.0.1
func (x *ReadTransactionReply) ProtoReflect() protoreflect.Message
func (*ReadTransactionReply) Reset ¶
func (x *ReadTransactionReply) Reset()
func (*ReadTransactionReply) String ¶
func (x *ReadTransactionReply) String() string
type ReadTransactionReply_FindByIDReply ¶ added in v0.1.12
type ReadTransactionReply_FindByIDReply struct {
FindByIDReply *FindByIDReply `protobuf:"bytes,3,opt,name=findByIDReply,proto3,oneof"`
}
type ReadTransactionReply_FindReply ¶ added in v0.1.12
type ReadTransactionReply_FindReply struct {
FindReply *FindReply `protobuf:"bytes,2,opt,name=findReply,proto3,oneof"`
}
type ReadTransactionReply_HasReply ¶ added in v0.1.12
type ReadTransactionReply_HasReply struct {
HasReply *HasReply `protobuf:"bytes,1,opt,name=hasReply,proto3,oneof"`
}
type ReadTransactionRequest ¶
type ReadTransactionRequest struct {
// Types that are assignable to Option:
// *ReadTransactionRequest_StartTransactionRequest
// *ReadTransactionRequest_HasRequest
// *ReadTransactionRequest_FindRequest
// *ReadTransactionRequest_FindByIDRequest
Option isReadTransactionRequest_Option `protobuf_oneof:"option"`
// contains filtered or unexported fields
}
func (*ReadTransactionRequest) Descriptor
deprecated
func (*ReadTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadTransactionRequest.ProtoReflect.Descriptor instead.
func (*ReadTransactionRequest) GetFindByIDRequest ¶ added in v0.1.12
func (x *ReadTransactionRequest) GetFindByIDRequest() *FindByIDRequest
func (*ReadTransactionRequest) GetFindRequest ¶ added in v0.1.12
func (x *ReadTransactionRequest) GetFindRequest() *FindRequest
func (*ReadTransactionRequest) GetHasRequest ¶ added in v0.1.12
func (x *ReadTransactionRequest) GetHasRequest() *HasRequest
func (*ReadTransactionRequest) GetOption ¶
func (m *ReadTransactionRequest) GetOption() isReadTransactionRequest_Option
func (*ReadTransactionRequest) GetStartTransactionRequest ¶
func (x *ReadTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest
func (*ReadTransactionRequest) ProtoMessage ¶
func (*ReadTransactionRequest) ProtoMessage()
func (*ReadTransactionRequest) ProtoReflect ¶ added in v1.0.1
func (x *ReadTransactionRequest) ProtoReflect() protoreflect.Message
func (*ReadTransactionRequest) Reset ¶
func (x *ReadTransactionRequest) Reset()
func (*ReadTransactionRequest) String ¶
func (x *ReadTransactionRequest) String() string
type ReadTransactionRequest_FindByIDRequest ¶ added in v0.1.12
type ReadTransactionRequest_FindByIDRequest struct {
FindByIDRequest *FindByIDRequest `protobuf:"bytes,4,opt,name=findByIDRequest,proto3,oneof"`
}
type ReadTransactionRequest_FindRequest ¶ added in v0.1.12
type ReadTransactionRequest_FindRequest struct {
FindRequest *FindRequest `protobuf:"bytes,3,opt,name=findRequest,proto3,oneof"`
}
type ReadTransactionRequest_HasRequest ¶ added in v0.1.12
type ReadTransactionRequest_HasRequest struct {
HasRequest *HasRequest `protobuf:"bytes,2,opt,name=hasRequest,proto3,oneof"`
}
type ReadTransactionRequest_StartTransactionRequest ¶
type ReadTransactionRequest_StartTransactionRequest struct {
StartTransactionRequest *StartTransactionRequest `protobuf:"bytes,1,opt,name=startTransactionRequest,proto3,oneof"`
}
type SaveReply ¶ added in v0.1.12
type SaveReply struct {
TransactionError string `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*SaveReply) Descriptor
deprecated
added in
v0.1.12
func (*SaveReply) GetTransactionError ¶ added in v1.0.0
func (*SaveReply) ProtoMessage ¶ added in v0.1.12
func (*SaveReply) ProtoMessage()
func (*SaveReply) ProtoReflect ¶ added in v1.0.1
func (x *SaveReply) ProtoReflect() protoreflect.Message
type SaveRequest ¶ added in v0.1.12
type SaveRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
Instances [][]byte `protobuf:"bytes,3,rep,name=instances,proto3" json:"instances,omitempty"`
// contains filtered or unexported fields
}
func (*SaveRequest) Descriptor
deprecated
added in
v0.1.12
func (*SaveRequest) Descriptor() ([]byte, []int)
Deprecated: Use SaveRequest.ProtoReflect.Descriptor instead.
func (*SaveRequest) GetCollectionName ¶ added in v0.1.12
func (x *SaveRequest) GetCollectionName() string
func (*SaveRequest) GetDbID ¶ added in v0.1.12
func (x *SaveRequest) GetDbID() []byte
func (*SaveRequest) GetInstances ¶ added in v0.1.13
func (x *SaveRequest) GetInstances() [][]byte
func (*SaveRequest) ProtoMessage ¶ added in v0.1.12
func (*SaveRequest) ProtoMessage()
func (*SaveRequest) ProtoReflect ¶ added in v1.0.1
func (x *SaveRequest) ProtoReflect() protoreflect.Message
func (*SaveRequest) Reset ¶ added in v0.1.12
func (x *SaveRequest) Reset()
func (*SaveRequest) String ¶ added in v0.1.12
func (x *SaveRequest) String() string
type StartTransactionRequest ¶
type StartTransactionRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
// contains filtered or unexported fields
}
func (*StartTransactionRequest) Descriptor
deprecated
func (*StartTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartTransactionRequest.ProtoReflect.Descriptor instead.
func (*StartTransactionRequest) GetCollectionName ¶ added in v0.1.12
func (x *StartTransactionRequest) GetCollectionName() string
func (*StartTransactionRequest) GetDbID ¶ added in v0.1.12
func (x *StartTransactionRequest) GetDbID() []byte
func (*StartTransactionRequest) ProtoMessage ¶
func (*StartTransactionRequest) ProtoMessage()
func (*StartTransactionRequest) ProtoReflect ¶ added in v1.0.1
func (x *StartTransactionRequest) ProtoReflect() protoreflect.Message
func (*StartTransactionRequest) Reset ¶
func (x *StartTransactionRequest) Reset()
func (*StartTransactionRequest) String ¶
func (x *StartTransactionRequest) String() string
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct {
}
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) Create ¶ added in v0.1.12
func (*UnimplementedAPIServer) Create(context.Context, *CreateRequest) (*CreateReply, error)
func (*UnimplementedAPIServer) Delete ¶ added in v0.1.12
func (*UnimplementedAPIServer) Delete(context.Context, *DeleteRequest) (*DeleteReply, error)
func (*UnimplementedAPIServer) DeleteCollection ¶ added in v0.1.19
func (*UnimplementedAPIServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionReply, error)
func (*UnimplementedAPIServer) DeleteDB ¶ added in v0.1.15
func (*UnimplementedAPIServer) DeleteDB(context.Context, *DeleteDBRequest) (*DeleteDBReply, error)
func (*UnimplementedAPIServer) Find ¶ added in v0.1.12
func (*UnimplementedAPIServer) Find(context.Context, *FindRequest) (*FindReply, error)
func (*UnimplementedAPIServer) FindByID ¶ added in v0.1.12
func (*UnimplementedAPIServer) FindByID(context.Context, *FindByIDRequest) (*FindByIDReply, error)
func (*UnimplementedAPIServer) GetCollectionIndexes ¶ added in v0.1.19
func (*UnimplementedAPIServer) GetCollectionIndexes(context.Context, *GetCollectionIndexesRequest) (*GetCollectionIndexesReply, error)
func (*UnimplementedAPIServer) GetCollectionInfo ¶ added in v0.1.22
func (*UnimplementedAPIServer) GetCollectionInfo(context.Context, *GetCollectionInfoRequest) (*GetCollectionInfoReply, error)
func (*UnimplementedAPIServer) GetDBInfo ¶ added in v0.1.12
func (*UnimplementedAPIServer) GetDBInfo(context.Context, *GetDBInfoRequest) (*GetDBInfoReply, error)
func (*UnimplementedAPIServer) GetToken ¶ added in v0.1.13
func (*UnimplementedAPIServer) GetToken(API_GetTokenServer) error
func (*UnimplementedAPIServer) Has ¶ added in v0.1.12
func (*UnimplementedAPIServer) Has(context.Context, *HasRequest) (*HasReply, error)
func (*UnimplementedAPIServer) ListCollections ¶ added in v0.1.22
func (*UnimplementedAPIServer) ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsReply, error)
func (*UnimplementedAPIServer) ListDBs ¶ added in v0.1.19
func (*UnimplementedAPIServer) ListDBs(context.Context, *ListDBsRequest) (*ListDBsReply, error)
func (*UnimplementedAPIServer) Listen ¶
func (*UnimplementedAPIServer) Listen(*ListenRequest, API_ListenServer) error
func (*UnimplementedAPIServer) NewCollection ¶ added in v0.1.12
func (*UnimplementedAPIServer) NewCollection(context.Context, *NewCollectionRequest) (*NewCollectionReply, error)
func (*UnimplementedAPIServer) NewDB ¶ added in v0.1.12
func (*UnimplementedAPIServer) NewDB(context.Context, *NewDBRequest) (*NewDBReply, error)
func (*UnimplementedAPIServer) NewDBFromAddr ¶ added in v0.1.12
func (*UnimplementedAPIServer) NewDBFromAddr(context.Context, *NewDBFromAddrRequest) (*NewDBReply, error)
func (*UnimplementedAPIServer) ReadTransaction ¶
func (*UnimplementedAPIServer) ReadTransaction(API_ReadTransactionServer) error
func (*UnimplementedAPIServer) Save ¶ added in v0.1.12
func (*UnimplementedAPIServer) Save(context.Context, *SaveRequest) (*SaveReply, error)
func (*UnimplementedAPIServer) UpdateCollection ¶ added in v0.1.19
func (*UnimplementedAPIServer) UpdateCollection(context.Context, *UpdateCollectionRequest) (*UpdateCollectionReply, error)
func (*UnimplementedAPIServer) Verify ¶ added in v1.0.0
func (*UnimplementedAPIServer) Verify(context.Context, *VerifyRequest) (*VerifyReply, error)
func (*UnimplementedAPIServer) WriteTransaction ¶
func (*UnimplementedAPIServer) WriteTransaction(API_WriteTransactionServer) error
type UpdateCollectionReply ¶ added in v0.1.19
type UpdateCollectionReply struct {
// contains filtered or unexported fields
}
func (*UpdateCollectionReply) Descriptor
deprecated
added in
v0.1.19
func (*UpdateCollectionReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCollectionReply.ProtoReflect.Descriptor instead.
func (*UpdateCollectionReply) ProtoMessage ¶ added in v0.1.19
func (*UpdateCollectionReply) ProtoMessage()
func (*UpdateCollectionReply) ProtoReflect ¶ added in v1.0.1
func (x *UpdateCollectionReply) ProtoReflect() protoreflect.Message
func (*UpdateCollectionReply) Reset ¶ added in v0.1.19
func (x *UpdateCollectionReply) Reset()
func (*UpdateCollectionReply) String ¶ added in v0.1.19
func (x *UpdateCollectionReply) String() string
type UpdateCollectionRequest ¶ added in v0.1.19
type UpdateCollectionRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
Config *CollectionConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateCollectionRequest) Descriptor
deprecated
added in
v0.1.19
func (*UpdateCollectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCollectionRequest.ProtoReflect.Descriptor instead.
func (*UpdateCollectionRequest) GetConfig ¶ added in v0.1.19
func (x *UpdateCollectionRequest) GetConfig() *CollectionConfig
func (*UpdateCollectionRequest) GetDbID ¶ added in v0.1.19
func (x *UpdateCollectionRequest) GetDbID() []byte
func (*UpdateCollectionRequest) ProtoMessage ¶ added in v0.1.19
func (*UpdateCollectionRequest) ProtoMessage()
func (*UpdateCollectionRequest) ProtoReflect ¶ added in v1.0.1
func (x *UpdateCollectionRequest) ProtoReflect() protoreflect.Message
func (*UpdateCollectionRequest) Reset ¶ added in v0.1.19
func (x *UpdateCollectionRequest) Reset()
func (*UpdateCollectionRequest) String ¶ added in v0.1.19
func (x *UpdateCollectionRequest) String() string
type VerifyReply ¶ added in v1.0.0
type VerifyReply struct {
TransactionError string `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
// contains filtered or unexported fields
}
func (*VerifyReply) Descriptor
deprecated
added in
v1.0.0
func (*VerifyReply) Descriptor() ([]byte, []int)
Deprecated: Use VerifyReply.ProtoReflect.Descriptor instead.
func (*VerifyReply) GetTransactionError ¶ added in v1.0.0
func (x *VerifyReply) GetTransactionError() string
func (*VerifyReply) ProtoMessage ¶ added in v1.0.0
func (*VerifyReply) ProtoMessage()
func (*VerifyReply) ProtoReflect ¶ added in v1.0.1
func (x *VerifyReply) ProtoReflect() protoreflect.Message
func (*VerifyReply) Reset ¶ added in v1.0.0
func (x *VerifyReply) Reset()
func (*VerifyReply) String ¶ added in v1.0.0
func (x *VerifyReply) String() string
type VerifyRequest ¶ added in v1.0.0
type VerifyRequest struct {
DbID []byte `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
Instances [][]byte `protobuf:"bytes,3,rep,name=instances,proto3" json:"instances,omitempty"`
// contains filtered or unexported fields
}
func (*VerifyRequest) Descriptor
deprecated
added in
v1.0.0
func (*VerifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifyRequest.ProtoReflect.Descriptor instead.
func (*VerifyRequest) GetCollectionName ¶ added in v1.0.0
func (x *VerifyRequest) GetCollectionName() string
func (*VerifyRequest) GetDbID ¶ added in v1.0.0
func (x *VerifyRequest) GetDbID() []byte
func (*VerifyRequest) GetInstances ¶ added in v1.0.0
func (x *VerifyRequest) GetInstances() [][]byte
func (*VerifyRequest) ProtoMessage ¶ added in v1.0.0
func (*VerifyRequest) ProtoMessage()
func (*VerifyRequest) ProtoReflect ¶ added in v1.0.1
func (x *VerifyRequest) ProtoReflect() protoreflect.Message
func (*VerifyRequest) Reset ¶ added in v1.0.0
func (x *VerifyRequest) Reset()
func (*VerifyRequest) String ¶ added in v1.0.0
func (x *VerifyRequest) String() string
type WriteTransactionReply ¶
type WriteTransactionReply struct {
// Types that are assignable to Option:
// *WriteTransactionReply_CreateReply
// *WriteTransactionReply_VerifyReply
// *WriteTransactionReply_SaveReply
// *WriteTransactionReply_DeleteReply
// *WriteTransactionReply_HasReply
// *WriteTransactionReply_FindReply
// *WriteTransactionReply_FindByIDReply
// *WriteTransactionReply_DiscardReply
Option isWriteTransactionReply_Option `protobuf_oneof:"option"`
// contains filtered or unexported fields
}
func (*WriteTransactionReply) Descriptor
deprecated
func (*WriteTransactionReply) Descriptor() ([]byte, []int)
Deprecated: Use WriteTransactionReply.ProtoReflect.Descriptor instead.
func (*WriteTransactionReply) GetCreateReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetCreateReply() *CreateReply
func (*WriteTransactionReply) GetDeleteReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetDeleteReply() *DeleteReply
func (*WriteTransactionReply) GetDiscardReply ¶ added in v1.0.0
func (x *WriteTransactionReply) GetDiscardReply() *DiscardReply
func (*WriteTransactionReply) GetFindByIDReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetFindByIDReply() *FindByIDReply
func (*WriteTransactionReply) GetFindReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetFindReply() *FindReply
func (*WriteTransactionReply) GetHasReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetHasReply() *HasReply
func (*WriteTransactionReply) GetOption ¶
func (m *WriteTransactionReply) GetOption() isWriteTransactionReply_Option
func (*WriteTransactionReply) GetSaveReply ¶ added in v0.1.12
func (x *WriteTransactionReply) GetSaveReply() *SaveReply
func (*WriteTransactionReply) GetVerifyReply ¶ added in v1.0.0
func (x *WriteTransactionReply) GetVerifyReply() *VerifyReply
func (*WriteTransactionReply) ProtoMessage ¶
func (*WriteTransactionReply) ProtoMessage()
func (*WriteTransactionReply) ProtoReflect ¶ added in v1.0.1
func (x *WriteTransactionReply) ProtoReflect() protoreflect.Message
func (*WriteTransactionReply) Reset ¶
func (x *WriteTransactionReply) Reset()
func (*WriteTransactionReply) String ¶
func (x *WriteTransactionReply) String() string
type WriteTransactionReply_CreateReply ¶ added in v0.1.12
type WriteTransactionReply_CreateReply struct {
CreateReply *CreateReply `protobuf:"bytes,1,opt,name=createReply,proto3,oneof"`
}
type WriteTransactionReply_DeleteReply ¶ added in v0.1.12
type WriteTransactionReply_DeleteReply struct {
DeleteReply *DeleteReply `protobuf:"bytes,3,opt,name=deleteReply,proto3,oneof"`
}
type WriteTransactionReply_DiscardReply ¶ added in v1.0.0
type WriteTransactionReply_DiscardReply struct {
DiscardReply *DiscardReply `protobuf:"bytes,8,opt,name=discardReply,proto3,oneof"`
}
type WriteTransactionReply_FindByIDReply ¶ added in v0.1.12
type WriteTransactionReply_FindByIDReply struct {
FindByIDReply *FindByIDReply `protobuf:"bytes,6,opt,name=findByIDReply,proto3,oneof"`
}
type WriteTransactionReply_FindReply ¶ added in v0.1.12
type WriteTransactionReply_FindReply struct {
FindReply *FindReply `protobuf:"bytes,5,opt,name=findReply,proto3,oneof"`
}
type WriteTransactionReply_HasReply ¶ added in v0.1.12
type WriteTransactionReply_HasReply struct {
HasReply *HasReply `protobuf:"bytes,4,opt,name=hasReply,proto3,oneof"`
}
type WriteTransactionReply_SaveReply ¶ added in v0.1.12
type WriteTransactionReply_SaveReply struct {
SaveReply *SaveReply `protobuf:"bytes,2,opt,name=saveReply,proto3,oneof"`
}
type WriteTransactionReply_VerifyReply ¶ added in v1.0.0
type WriteTransactionReply_VerifyReply struct {
VerifyReply *VerifyReply `protobuf:"bytes,7,opt,name=verifyReply,proto3,oneof"`
}
type WriteTransactionRequest ¶
type WriteTransactionRequest struct {
// Types that are assignable to Option:
// *WriteTransactionRequest_StartTransactionRequest
// *WriteTransactionRequest_CreateRequest
// *WriteTransactionRequest_VerifyRequest
// *WriteTransactionRequest_SaveRequest
// *WriteTransactionRequest_DeleteRequest
// *WriteTransactionRequest_HasRequest
// *WriteTransactionRequest_FindRequest
// *WriteTransactionRequest_FindByIDRequest
// *WriteTransactionRequest_DiscardRequest
Option isWriteTransactionRequest_Option `protobuf_oneof:"option"`
// contains filtered or unexported fields
}
func (*WriteTransactionRequest) Descriptor
deprecated
func (*WriteTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteTransactionRequest.ProtoReflect.Descriptor instead.
func (*WriteTransactionRequest) GetCreateRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetCreateRequest() *CreateRequest
func (*WriteTransactionRequest) GetDeleteRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetDeleteRequest() *DeleteRequest
func (*WriteTransactionRequest) GetDiscardRequest ¶ added in v1.0.0
func (x *WriteTransactionRequest) GetDiscardRequest() *DiscardRequest
func (*WriteTransactionRequest) GetFindByIDRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetFindByIDRequest() *FindByIDRequest
func (*WriteTransactionRequest) GetFindRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetFindRequest() *FindRequest
func (*WriteTransactionRequest) GetHasRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetHasRequest() *HasRequest
func (*WriteTransactionRequest) GetOption ¶
func (m *WriteTransactionRequest) GetOption() isWriteTransactionRequest_Option
func (*WriteTransactionRequest) GetSaveRequest ¶ added in v0.1.12
func (x *WriteTransactionRequest) GetSaveRequest() *SaveRequest
func (*WriteTransactionRequest) GetStartTransactionRequest ¶
func (x *WriteTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest
func (*WriteTransactionRequest) GetVerifyRequest ¶ added in v1.0.0
func (x *WriteTransactionRequest) GetVerifyRequest() *VerifyRequest
func (*WriteTransactionRequest) ProtoMessage ¶
func (*WriteTransactionRequest) ProtoMessage()
func (*WriteTransactionRequest) ProtoReflect ¶ added in v1.0.1
func (x *WriteTransactionRequest) ProtoReflect() protoreflect.Message
func (*WriteTransactionRequest) Reset ¶
func (x *WriteTransactionRequest) Reset()
func (*WriteTransactionRequest) String ¶
func (x *WriteTransactionRequest) String() string
type WriteTransactionRequest_CreateRequest ¶ added in v0.1.12
type WriteTransactionRequest_CreateRequest struct {
CreateRequest *CreateRequest `protobuf:"bytes,2,opt,name=createRequest,proto3,oneof"`
}
type WriteTransactionRequest_DeleteRequest ¶ added in v0.1.12
type WriteTransactionRequest_DeleteRequest struct {
DeleteRequest *DeleteRequest `protobuf:"bytes,4,opt,name=deleteRequest,proto3,oneof"`
}
type WriteTransactionRequest_DiscardRequest ¶ added in v1.0.0
type WriteTransactionRequest_DiscardRequest struct {
DiscardRequest *DiscardRequest `protobuf:"bytes,9,opt,name=discardRequest,proto3,oneof"`
}
type WriteTransactionRequest_FindByIDRequest ¶ added in v0.1.12
type WriteTransactionRequest_FindByIDRequest struct {
FindByIDRequest *FindByIDRequest `protobuf:"bytes,7,opt,name=findByIDRequest,proto3,oneof"`
}
type WriteTransactionRequest_FindRequest ¶ added in v0.1.12
type WriteTransactionRequest_FindRequest struct {
FindRequest *FindRequest `protobuf:"bytes,6,opt,name=findRequest,proto3,oneof"`
}
type WriteTransactionRequest_HasRequest ¶ added in v0.1.12
type WriteTransactionRequest_HasRequest struct {
HasRequest *HasRequest `protobuf:"bytes,5,opt,name=hasRequest,proto3,oneof"`
}
type WriteTransactionRequest_SaveRequest ¶ added in v0.1.12
type WriteTransactionRequest_SaveRequest struct {
SaveRequest *SaveRequest `protobuf:"bytes,3,opt,name=saveRequest,proto3,oneof"`
}
type WriteTransactionRequest_StartTransactionRequest ¶
type WriteTransactionRequest_StartTransactionRequest struct {
StartTransactionRequest *StartTransactionRequest `protobuf:"bytes,1,opt,name=startTransactionRequest,proto3,oneof"`
}
type WriteTransactionRequest_VerifyRequest ¶ added in v1.0.0
type WriteTransactionRequest_VerifyRequest struct {
VerifyRequest *VerifyRequest `protobuf:"bytes,8,opt,name=verifyRequest,proto3,oneof"`
}