threads_pb

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2022 License: MIT Imports: 8 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "threads.pb.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewDB",
			Handler:    _API_NewDB_Handler,
		},
		{
			MethodName: "NewDBFromAddr",
			Handler:    _API_NewDBFromAddr_Handler,
		},
		{
			MethodName: "ListDBs",
			Handler:    _API_ListDBs_Handler,
		},
		{
			MethodName: "GetDBInfo",
			Handler:    _API_GetDBInfo_Handler,
		},
		{
			MethodName: "DeleteDB",
			Handler:    _API_DeleteDB_Handler,
		},
		{
			MethodName: "NewCollection",
			Handler:    _API_NewCollection_Handler,
		},
		{
			MethodName: "UpdateCollection",
			Handler:    _API_UpdateCollection_Handler,
		},
		{
			MethodName: "DeleteCollection",
			Handler:    _API_DeleteCollection_Handler,
		},
		{
			MethodName: "GetCollectionInfo",
			Handler:    _API_GetCollectionInfo_Handler,
		},
		{
			MethodName: "GetCollectionIndexes",
			Handler:    _API_GetCollectionIndexes_Handler,
		},
		{
			MethodName: "ListCollections",
			Handler:    _API_ListCollections_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _API_Create_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _API_Verify_Handler,
		},
		{
			MethodName: "Save",
			Handler:    _API_Save_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _API_Delete_Handler,
		},
		{
			MethodName: "Has",
			Handler:    _API_Has_Handler,
		},
		{
			MethodName: "Find",
			Handler:    _API_Find_Handler,
		},
		{
			MethodName: "FindByID",
			Handler:    _API_FindByID_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetToken",
			Handler:       _API_GetToken_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ReadTransaction",
			Handler:       _API_ReadTransaction_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "WriteTransaction",
			Handler:       _API_WriteTransaction_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _API_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "threads.proto",
}

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

View Source 
var File_threads_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServer 

func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

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) Descriptor() ([]byte, []int)

Deprecated: Use FindReply.ProtoReflect.Descriptor instead.

func (*FindReply) GetInstances added in v0.1.12 

func (x *FindReply) GetInstances() [][]byte

func (*FindReply) GetTransactionError added in v1.0.0 

func (x *FindReply) GetTransactionError() string

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

func (*FindReply) Reset added in v0.1.12 

func (x *FindReply) Reset()

func (*FindReply) String added in v0.1.12 

func (x *FindReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use HasReply.ProtoReflect.Descriptor instead.

func (*HasReply) GetExists added in v0.1.12 

func (x *HasReply) GetExists() bool

func (*HasReply) GetTransactionError added in v1.0.0 

func (x *HasReply) GetTransactionError() string

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

func (*HasReply) Reset added in v0.1.12 

func (x *HasReply) Reset()

func (*HasReply) String added in v0.1.12 

func (x *HasReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetPath added in v0.1.19 

func (x *Index) GetPath() string

func (*Index) GetUnique added in v0.1.19 

func (x *Index) GetUnique() bool

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

func (*Index) Reset added in v0.1.19 

func (x *Index) Reset()

func (*Index) String added in v0.1.19 

func (x *Index) String() string

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"`
	LogKey      []byte              `protobuf:"bytes,7,opt,name=logKey,proto3" json:"logKey,omitempty"`
	Name        string              `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Collections []*CollectionConfig `protobuf:"bytes,3,rep,name=collections,proto3" json:"collections,omitempty"`
	Block       bool                `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"`
	// Deprecated: Do not use.
	ThreadKey []byte `protobuf:"bytes,6,opt,name=threadKey,proto3" json:"threadKey,omitempty"`
	// contains filtered or unexported fields
}

@todo: Clean up tag numbers with next major release

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 deprecated added in v1.0.1 

func (x *NewDBFromAddrRequest) GetThreadKey() []byte

Deprecated: Do not use.

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"`
	Key         []byte              `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	LogKey      []byte              `protobuf:"bytes,7,opt,name=logKey,proto3" json:"logKey,omitempty"`
	Name        string              `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Collections []*CollectionConfig `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	// Deprecated: Do not use.
	Block bool `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

@todo: Clean up tag numbers with next major release

func (*NewDBRequest) Descriptor deprecated added in v0.1.12 

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

Deprecated: Use NewDBRequest.ProtoReflect.Descriptor instead.

func (*NewDBRequest) GetBlock deprecated added in v1.0.1 

func (x *NewDBRequest) GetBlock() bool

Deprecated: Do not use.

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) GetKey added in v1.0.2 

func (x *NewDBRequest) GetKey() []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) 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) Descriptor() ([]byte, []int)

Deprecated: Use SaveReply.ProtoReflect.Descriptor instead.

func (*SaveReply) GetTransactionError added in v1.0.0 

func (x *SaveReply) GetTransactionError() string

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

func (*SaveReply) Reset added in v0.1.12 

func (x *SaveReply) Reset()

func (*SaveReply) String added in v0.1.12 

func (x *SaveReply) String() string

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 must 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 UnsafeAPIServer added in v1.1.1 

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

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

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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.