threads_pb

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ListenReply_Action_name = map[int32]string{
	0: "CREATE",
	1: "SAVE",
	2: "DELETE",
}
View Source 
var ListenReply_Action_value = map[string]int32{
	"CREATE": 0,
	"SAVE":   1,
	"DELETE": 2,
}
View Source 
var ListenRequest_Filter_Action_name = map[int32]string{
	0: "ALL",
	1: "CREATE",
	2: "SAVE",
	3: "DELETE",
}
View Source 
var ListenRequest_Filter_Action_value = map[string]int32{
	"ALL":    0,
	"CREATE": 1,
	"SAVE":   2,
	"DELETE": 3,
}

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, 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)
	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.ClientConn) 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)
	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 

type API_GetTokenClient interface {
	Send(*GetTokenRequest) error
	Recv() (*GetTokenReply, error)
	grpc.ClientStream
}

type API_GetTokenServer 

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 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CollectionConfig) Descriptor 

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

func (*CollectionConfig) GetIndexes 

func (m *CollectionConfig) GetIndexes() []*Index

func (*CollectionConfig) GetName 

func (m *CollectionConfig) GetName() string

func (*CollectionConfig) GetReadFilter 

func (m *CollectionConfig) GetReadFilter() string

func (*CollectionConfig) GetSchema 

func (m *CollectionConfig) GetSchema() []byte

func (*CollectionConfig) GetWriteValidator 

func (m *CollectionConfig) GetWriteValidator() string

func (*CollectionConfig) ProtoMessage 

func (*CollectionConfig) ProtoMessage()

func (*CollectionConfig) Reset 

func (m *CollectionConfig) Reset()

func (*CollectionConfig) String 

func (m *CollectionConfig) String() string

func (*CollectionConfig) XXX_DiscardUnknown 

func (m *CollectionConfig) XXX_DiscardUnknown()

func (*CollectionConfig) XXX_Marshal 

func (m *CollectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectionConfig) XXX_Merge 

func (m *CollectionConfig) XXX_Merge(src proto.Message)

func (*CollectionConfig) XXX_Size 

func (m *CollectionConfig) XXX_Size() int

func (*CollectionConfig) XXX_Unmarshal 

func (m *CollectionConfig) XXX_Unmarshal(b []byte) error

type CreateReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateReply) Descriptor 

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

func (*CreateReply) GetInstanceIDs 

func (m *CreateReply) GetInstanceIDs() []string

func (*CreateReply) GetTransactionError 

func (m *CreateReply) GetTransactionError() string

func (*CreateReply) ProtoMessage 

func (*CreateReply) ProtoMessage()

func (*CreateReply) Reset 

func (m *CreateReply) Reset()

func (*CreateReply) String 

func (m *CreateReply) String() string

func (*CreateReply) XXX_DiscardUnknown 

func (m *CreateReply) XXX_DiscardUnknown()

func (*CreateReply) XXX_Marshal 

func (m *CreateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateReply) XXX_Merge 

func (m *CreateReply) XXX_Merge(src proto.Message)

func (*CreateReply) XXX_Size 

func (m *CreateReply) XXX_Size() int

func (*CreateReply) XXX_Unmarshal 

func (m *CreateReply) XXX_Unmarshal(b []byte) error

type CreateRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetCollectionName 

func (m *CreateRequest) GetCollectionName() string

func (*CreateRequest) GetDbID 

func (m *CreateRequest) GetDbID() []byte

func (*CreateRequest) GetInstances 

func (m *CreateRequest) GetInstances() [][]byte

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

type DeleteCollectionReply 

type DeleteCollectionReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteCollectionReply) Descriptor 

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

func (*DeleteCollectionReply) ProtoMessage 

func (*DeleteCollectionReply) ProtoMessage()

func (*DeleteCollectionReply) Reset 

func (m *DeleteCollectionReply) Reset()

func (*DeleteCollectionReply) String 

func (m *DeleteCollectionReply) String() string

func (*DeleteCollectionReply) XXX_DiscardUnknown 

func (m *DeleteCollectionReply) XXX_DiscardUnknown()

func (*DeleteCollectionReply) XXX_Marshal 

func (m *DeleteCollectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteCollectionReply) XXX_Merge 

func (m *DeleteCollectionReply) XXX_Merge(src proto.Message)

func (*DeleteCollectionReply) XXX_Size 

func (m *DeleteCollectionReply) XXX_Size() int

func (*DeleteCollectionReply) XXX_Unmarshal 

func (m *DeleteCollectionReply) XXX_Unmarshal(b []byte) error

type DeleteCollectionRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteCollectionRequest) Descriptor 

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

func (*DeleteCollectionRequest) GetDbID 

func (m *DeleteCollectionRequest) GetDbID() []byte

func (*DeleteCollectionRequest) GetName 

func (m *DeleteCollectionRequest) GetName() string

func (*DeleteCollectionRequest) ProtoMessage 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) Reset 

func (m *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String 

func (m *DeleteCollectionRequest) String() string

func (*DeleteCollectionRequest) XXX_DiscardUnknown 

func (m *DeleteCollectionRequest) XXX_DiscardUnknown()

func (*DeleteCollectionRequest) XXX_Marshal 

func (m *DeleteCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteCollectionRequest) XXX_Merge 

func (m *DeleteCollectionRequest) XXX_Merge(src proto.Message)

func (*DeleteCollectionRequest) XXX_Size 

func (m *DeleteCollectionRequest) XXX_Size() int

func (*DeleteCollectionRequest) XXX_Unmarshal 

func (m *DeleteCollectionRequest) XXX_Unmarshal(b []byte) error

type DeleteDBReply 

type DeleteDBReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDBReply) Descriptor 

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

func (*DeleteDBReply) ProtoMessage 

func (*DeleteDBReply) ProtoMessage()

func (*DeleteDBReply) Reset 

func (m *DeleteDBReply) Reset()

func (*DeleteDBReply) String 

func (m *DeleteDBReply) String() string

func (*DeleteDBReply) XXX_DiscardUnknown 

func (m *DeleteDBReply) XXX_DiscardUnknown()

func (*DeleteDBReply) XXX_Marshal 

func (m *DeleteDBReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDBReply) XXX_Merge 

func (m *DeleteDBReply) XXX_Merge(src proto.Message)

func (*DeleteDBReply) XXX_Size 

func (m *DeleteDBReply) XXX_Size() int

func (*DeleteDBReply) XXX_Unmarshal 

func (m *DeleteDBReply) XXX_Unmarshal(b []byte) error

type DeleteDBRequest 

type DeleteDBRequest struct {
	DbID                 []byte   `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDBRequest) Descriptor 

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

func (*DeleteDBRequest) GetDbID 

func (m *DeleteDBRequest) GetDbID() []byte

func (*DeleteDBRequest) ProtoMessage 

func (*DeleteDBRequest) ProtoMessage()

func (*DeleteDBRequest) Reset 

func (m *DeleteDBRequest) Reset()

func (*DeleteDBRequest) String 

func (m *DeleteDBRequest) String() string

func (*DeleteDBRequest) XXX_DiscardUnknown 

func (m *DeleteDBRequest) XXX_DiscardUnknown()

func (*DeleteDBRequest) XXX_Marshal 

func (m *DeleteDBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDBRequest) XXX_Merge 

func (m *DeleteDBRequest) XXX_Merge(src proto.Message)

func (*DeleteDBRequest) XXX_Size 

func (m *DeleteDBRequest) XXX_Size() int

func (*DeleteDBRequest) XXX_Unmarshal 

func (m *DeleteDBRequest) XXX_Unmarshal(b []byte) error

type DeleteReply 

type DeleteReply struct {
	TransactionError     string   `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteReply) Descriptor 

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

func (*DeleteReply) GetTransactionError 

func (m *DeleteReply) GetTransactionError() string

func (*DeleteReply) ProtoMessage 

func (*DeleteReply) ProtoMessage()

func (*DeleteReply) Reset 

func (m *DeleteReply) Reset()

func (*DeleteReply) String 

func (m *DeleteReply) String() string

func (*DeleteReply) XXX_DiscardUnknown 

func (m *DeleteReply) XXX_DiscardUnknown()

func (*DeleteReply) XXX_Marshal 

func (m *DeleteReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteReply) XXX_Merge 

func (m *DeleteReply) XXX_Merge(src proto.Message)

func (*DeleteReply) XXX_Size 

func (m *DeleteReply) XXX_Size() int

func (*DeleteReply) XXX_Unmarshal 

func (m *DeleteReply) XXX_Unmarshal(b []byte) error

type DeleteRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetCollectionName 

func (m *DeleteRequest) GetCollectionName() string

func (*DeleteRequest) GetDbID 

func (m *DeleteRequest) GetDbID() []byte

func (*DeleteRequest) GetInstanceIDs 

func (m *DeleteRequest) GetInstanceIDs() []string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DiscardReply 

type DiscardReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscardReply) Descriptor 

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

func (*DiscardReply) ProtoMessage 

func (*DiscardReply) ProtoMessage()

func (*DiscardReply) Reset 

func (m *DiscardReply) Reset()

func (*DiscardReply) String 

func (m *DiscardReply) String() string

func (*DiscardReply) XXX_DiscardUnknown 

func (m *DiscardReply) XXX_DiscardUnknown()

func (*DiscardReply) XXX_Marshal 

func (m *DiscardReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscardReply) XXX_Merge 

func (m *DiscardReply) XXX_Merge(src proto.Message)

func (*DiscardReply) XXX_Size 

func (m *DiscardReply) XXX_Size() int

func (*DiscardReply) XXX_Unmarshal 

func (m *DiscardReply) XXX_Unmarshal(b []byte) error

type DiscardRequest 

type DiscardRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscardRequest) Descriptor 

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

func (*DiscardRequest) ProtoMessage 

func (*DiscardRequest) ProtoMessage()

func (*DiscardRequest) Reset 

func (m *DiscardRequest) Reset()

func (*DiscardRequest) String 

func (m *DiscardRequest) String() string

func (*DiscardRequest) XXX_DiscardUnknown 

func (m *DiscardRequest) XXX_DiscardUnknown()

func (*DiscardRequest) XXX_Marshal 

func (m *DiscardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscardRequest) XXX_Merge 

func (m *DiscardRequest) XXX_Merge(src proto.Message)

func (*DiscardRequest) XXX_Size 

func (m *DiscardRequest) XXX_Size() int

func (*DiscardRequest) XXX_Unmarshal 

func (m *DiscardRequest) XXX_Unmarshal(b []byte) error

type FindByIDReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindByIDReply) Descriptor 

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

func (*FindByIDReply) GetInstance 

func (m *FindByIDReply) GetInstance() []byte

func (*FindByIDReply) GetTransactionError 

func (m *FindByIDReply) GetTransactionError() string

func (*FindByIDReply) ProtoMessage 

func (*FindByIDReply) ProtoMessage()

func (*FindByIDReply) Reset 

func (m *FindByIDReply) Reset()

func (*FindByIDReply) String 

func (m *FindByIDReply) String() string

func (*FindByIDReply) XXX_DiscardUnknown 

func (m *FindByIDReply) XXX_DiscardUnknown()

func (*FindByIDReply) XXX_Marshal 

func (m *FindByIDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindByIDReply) XXX_Merge 

func (m *FindByIDReply) XXX_Merge(src proto.Message)

func (*FindByIDReply) XXX_Size 

func (m *FindByIDReply) XXX_Size() int

func (*FindByIDReply) XXX_Unmarshal 

func (m *FindByIDReply) XXX_Unmarshal(b []byte) error

type FindByIDRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindByIDRequest) Descriptor 

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

func (*FindByIDRequest) GetCollectionName 

func (m *FindByIDRequest) GetCollectionName() string

func (*FindByIDRequest) GetDbID 

func (m *FindByIDRequest) GetDbID() []byte

func (*FindByIDRequest) GetInstanceID 

func (m *FindByIDRequest) GetInstanceID() string

func (*FindByIDRequest) ProtoMessage 

func (*FindByIDRequest) ProtoMessage()

func (*FindByIDRequest) Reset 

func (m *FindByIDRequest) Reset()

func (*FindByIDRequest) String 

func (m *FindByIDRequest) String() string

func (*FindByIDRequest) XXX_DiscardUnknown 

func (m *FindByIDRequest) XXX_DiscardUnknown()

func (*FindByIDRequest) XXX_Marshal 

func (m *FindByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindByIDRequest) XXX_Merge 

func (m *FindByIDRequest) XXX_Merge(src proto.Message)

func (*FindByIDRequest) XXX_Size 

func (m *FindByIDRequest) XXX_Size() int

func (*FindByIDRequest) XXX_Unmarshal 

func (m *FindByIDRequest) XXX_Unmarshal(b []byte) error

type FindReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindReply) Descriptor 

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

func (*FindReply) GetInstances 

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

func (*FindReply) GetTransactionError 

func (m *FindReply) GetTransactionError() string

func (*FindReply) ProtoMessage 

func (*FindReply) ProtoMessage()

func (*FindReply) Reset 

func (m *FindReply) Reset()

func (*FindReply) String 

func (m *FindReply) String() string

func (*FindReply) XXX_DiscardUnknown 

func (m *FindReply) XXX_DiscardUnknown()

func (*FindReply) XXX_Marshal 

func (m *FindReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindReply) XXX_Merge 

func (m *FindReply) XXX_Merge(src proto.Message)

func (*FindReply) XXX_Size 

func (m *FindReply) XXX_Size() int

func (*FindReply) XXX_Unmarshal 

func (m *FindReply) XXX_Unmarshal(b []byte) error

type FindRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindRequest) Descriptor 

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

func (*FindRequest) GetCollectionName 

func (m *FindRequest) GetCollectionName() string

func (*FindRequest) GetDbID 

func (m *FindRequest) GetDbID() []byte

func (*FindRequest) GetQueryJSON 

func (m *FindRequest) GetQueryJSON() []byte

func (*FindRequest) ProtoMessage 

func (*FindRequest) ProtoMessage()

func (*FindRequest) Reset 

func (m *FindRequest) Reset()

func (*FindRequest) String 

func (m *FindRequest) String() string

func (*FindRequest) XXX_DiscardUnknown 

func (m *FindRequest) XXX_DiscardUnknown()

func (*FindRequest) XXX_Marshal 

func (m *FindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindRequest) XXX_Merge 

func (m *FindRequest) XXX_Merge(src proto.Message)

func (*FindRequest) XXX_Size 

func (m *FindRequest) XXX_Size() int

func (*FindRequest) XXX_Unmarshal 

func (m *FindRequest) XXX_Unmarshal(b []byte) error

type GetCollectionIndexesReply 

type GetCollectionIndexesReply struct {
	Indexes              []*Index `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCollectionIndexesReply) Descriptor 

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

func (*GetCollectionIndexesReply) GetIndexes 

func (m *GetCollectionIndexesReply) GetIndexes() []*Index

func (*GetCollectionIndexesReply) ProtoMessage 

func (*GetCollectionIndexesReply) ProtoMessage()

func (*GetCollectionIndexesReply) Reset 

func (m *GetCollectionIndexesReply) Reset()

func (*GetCollectionIndexesReply) String 

func (m *GetCollectionIndexesReply) String() string

func (*GetCollectionIndexesReply) XXX_DiscardUnknown 

func (m *GetCollectionIndexesReply) XXX_DiscardUnknown()

func (*GetCollectionIndexesReply) XXX_Marshal 

func (m *GetCollectionIndexesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionIndexesReply) XXX_Merge 

func (m *GetCollectionIndexesReply) XXX_Merge(src proto.Message)

func (*GetCollectionIndexesReply) XXX_Size 

func (m *GetCollectionIndexesReply) XXX_Size() int

func (*GetCollectionIndexesReply) XXX_Unmarshal 

func (m *GetCollectionIndexesReply) XXX_Unmarshal(b []byte) error

type GetCollectionIndexesRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCollectionIndexesRequest) Descriptor 

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

func (*GetCollectionIndexesRequest) GetDbID 

func (m *GetCollectionIndexesRequest) GetDbID() []byte

func (*GetCollectionIndexesRequest) GetName 

func (m *GetCollectionIndexesRequest) GetName() string

func (*GetCollectionIndexesRequest) ProtoMessage 

func (*GetCollectionIndexesRequest) ProtoMessage()

func (*GetCollectionIndexesRequest) Reset 

func (m *GetCollectionIndexesRequest) Reset()

func (*GetCollectionIndexesRequest) String 

func (m *GetCollectionIndexesRequest) String() string

func (*GetCollectionIndexesRequest) XXX_DiscardUnknown 

func (m *GetCollectionIndexesRequest) XXX_DiscardUnknown()

func (*GetCollectionIndexesRequest) XXX_Marshal 

func (m *GetCollectionIndexesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionIndexesRequest) XXX_Merge 

func (m *GetCollectionIndexesRequest) XXX_Merge(src proto.Message)

func (*GetCollectionIndexesRequest) XXX_Size 

func (m *GetCollectionIndexesRequest) XXX_Size() int

func (*GetCollectionIndexesRequest) XXX_Unmarshal 

func (m *GetCollectionIndexesRequest) XXX_Unmarshal(b []byte) error

type GetCollectionInfoReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCollectionInfoReply) Descriptor 

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

func (*GetCollectionInfoReply) GetIndexes 

func (m *GetCollectionInfoReply) GetIndexes() []*Index

func (*GetCollectionInfoReply) GetName 

func (m *GetCollectionInfoReply) GetName() string

func (*GetCollectionInfoReply) GetReadFilter 

func (m *GetCollectionInfoReply) GetReadFilter() string

func (*GetCollectionInfoReply) GetSchema 

func (m *GetCollectionInfoReply) GetSchema() []byte

func (*GetCollectionInfoReply) GetWriteValidator 

func (m *GetCollectionInfoReply) GetWriteValidator() string

func (*GetCollectionInfoReply) ProtoMessage 

func (*GetCollectionInfoReply) ProtoMessage()

func (*GetCollectionInfoReply) Reset 

func (m *GetCollectionInfoReply) Reset()

func (*GetCollectionInfoReply) String 

func (m *GetCollectionInfoReply) String() string

func (*GetCollectionInfoReply) XXX_DiscardUnknown 

func (m *GetCollectionInfoReply) XXX_DiscardUnknown()

func (*GetCollectionInfoReply) XXX_Marshal 

func (m *GetCollectionInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionInfoReply) XXX_Merge 

func (m *GetCollectionInfoReply) XXX_Merge(src proto.Message)

func (*GetCollectionInfoReply) XXX_Size 

func (m *GetCollectionInfoReply) XXX_Size() int

func (*GetCollectionInfoReply) XXX_Unmarshal 

func (m *GetCollectionInfoReply) XXX_Unmarshal(b []byte) error

type GetCollectionInfoRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCollectionInfoRequest) Descriptor 

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

func (*GetCollectionInfoRequest) GetDbID 

func (m *GetCollectionInfoRequest) GetDbID() []byte

func (*GetCollectionInfoRequest) GetName 

func (m *GetCollectionInfoRequest) GetName() string

func (*GetCollectionInfoRequest) ProtoMessage 

func (*GetCollectionInfoRequest) ProtoMessage()

func (*GetCollectionInfoRequest) Reset 

func (m *GetCollectionInfoRequest) Reset()

func (*GetCollectionInfoRequest) String 

func (m *GetCollectionInfoRequest) String() string

func (*GetCollectionInfoRequest) XXX_DiscardUnknown 

func (m *GetCollectionInfoRequest) XXX_DiscardUnknown()

func (*GetCollectionInfoRequest) XXX_Marshal 

func (m *GetCollectionInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionInfoRequest) XXX_Merge 

func (m *GetCollectionInfoRequest) XXX_Merge(src proto.Message)

func (*GetCollectionInfoRequest) XXX_Size 

func (m *GetCollectionInfoRequest) XXX_Size() int

func (*GetCollectionInfoRequest) XXX_Unmarshal 

func (m *GetCollectionInfoRequest) XXX_Unmarshal(b []byte) error

type GetDBInfoReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDBInfoReply) Descriptor 

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

func (*GetDBInfoReply) GetAddrs 

func (m *GetDBInfoReply) GetAddrs() [][]byte

func (*GetDBInfoReply) GetKey 

func (m *GetDBInfoReply) GetKey() []byte

func (*GetDBInfoReply) GetName 

func (m *GetDBInfoReply) GetName() string

func (*GetDBInfoReply) ProtoMessage 

func (*GetDBInfoReply) ProtoMessage()

func (*GetDBInfoReply) Reset 

func (m *GetDBInfoReply) Reset()

func (*GetDBInfoReply) String 

func (m *GetDBInfoReply) String() string

func (*GetDBInfoReply) XXX_DiscardUnknown 

func (m *GetDBInfoReply) XXX_DiscardUnknown()

func (*GetDBInfoReply) XXX_Marshal 

func (m *GetDBInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDBInfoReply) XXX_Merge 

func (m *GetDBInfoReply) XXX_Merge(src proto.Message)

func (*GetDBInfoReply) XXX_Size 

func (m *GetDBInfoReply) XXX_Size() int

func (*GetDBInfoReply) XXX_Unmarshal 

func (m *GetDBInfoReply) XXX_Unmarshal(b []byte) error

type GetDBInfoRequest 

type GetDBInfoRequest struct {
	DbID                 []byte   `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDBInfoRequest) Descriptor 

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

func (*GetDBInfoRequest) GetDbID 

func (m *GetDBInfoRequest) GetDbID() []byte

func (*GetDBInfoRequest) ProtoMessage 

func (*GetDBInfoRequest) ProtoMessage()

func (*GetDBInfoRequest) Reset 

func (m *GetDBInfoRequest) Reset()

func (*GetDBInfoRequest) String 

func (m *GetDBInfoRequest) String() string

func (*GetDBInfoRequest) XXX_DiscardUnknown 

func (m *GetDBInfoRequest) XXX_DiscardUnknown()

func (*GetDBInfoRequest) XXX_Marshal 

func (m *GetDBInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDBInfoRequest) XXX_Merge 

func (m *GetDBInfoRequest) XXX_Merge(src proto.Message)

func (*GetDBInfoRequest) XXX_Size 

func (m *GetDBInfoRequest) XXX_Size() int

func (*GetDBInfoRequest) XXX_Unmarshal 

func (m *GetDBInfoRequest) XXX_Unmarshal(b []byte) error

type GetTokenReply 

type GetTokenReply struct {
	// Types that are valid to be assigned to Payload:
	//	*GetTokenReply_Challenge
	//	*GetTokenReply_Token
	Payload              isGetTokenReply_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetTokenReply) Descriptor 

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

func (*GetTokenReply) GetChallenge 

func (m *GetTokenReply) GetChallenge() []byte

func (*GetTokenReply) GetPayload 

func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload

func (*GetTokenReply) GetToken 

func (m *GetTokenReply) GetToken() string

func (*GetTokenReply) ProtoMessage 

func (*GetTokenReply) ProtoMessage()

func (*GetTokenReply) Reset 

func (m *GetTokenReply) Reset()

func (*GetTokenReply) String 

func (m *GetTokenReply) String() string

func (*GetTokenReply) XXX_DiscardUnknown 

func (m *GetTokenReply) XXX_DiscardUnknown()

func (*GetTokenReply) XXX_Marshal 

func (m *GetTokenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTokenReply) XXX_Merge 

func (m *GetTokenReply) XXX_Merge(src proto.Message)

func (*GetTokenReply) XXX_OneofWrappers 

func (*GetTokenReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenReply) XXX_Size 

func (m *GetTokenReply) XXX_Size() int

func (*GetTokenReply) XXX_Unmarshal 

func (m *GetTokenReply) XXX_Unmarshal(b []byte) error

type GetTokenReply_Challenge 

type GetTokenReply_Challenge struct {
	Challenge []byte `protobuf:"bytes,1,opt,name=challenge,proto3,oneof"`
}

type GetTokenReply_Token 

type GetTokenReply_Token struct {
	Token string `protobuf:"bytes,2,opt,name=token,proto3,oneof"`
}

type GetTokenRequest 

type GetTokenRequest struct {
	// Types that are valid to be assigned to Payload:
	//	*GetTokenRequest_Key
	//	*GetTokenRequest_Signature
	Payload              isGetTokenRequest_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetTokenRequest) Descriptor 

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

func (*GetTokenRequest) GetKey 

func (m *GetTokenRequest) GetKey() string

func (*GetTokenRequest) GetPayload 

func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload

func (*GetTokenRequest) GetSignature 

func (m *GetTokenRequest) GetSignature() []byte

func (*GetTokenRequest) ProtoMessage 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) Reset 

func (m *GetTokenRequest) Reset()

func (*GetTokenRequest) String 

func (m *GetTokenRequest) String() string

func (*GetTokenRequest) XXX_DiscardUnknown 

func (m *GetTokenRequest) XXX_DiscardUnknown()

func (*GetTokenRequest) XXX_Marshal 

func (m *GetTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTokenRequest) XXX_Merge 

func (m *GetTokenRequest) XXX_Merge(src proto.Message)

func (*GetTokenRequest) XXX_OneofWrappers 

func (*GetTokenRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenRequest) XXX_Size 

func (m *GetTokenRequest) XXX_Size() int

func (*GetTokenRequest) XXX_Unmarshal 

func (m *GetTokenRequest) XXX_Unmarshal(b []byte) error

type GetTokenRequest_Key 

type GetTokenRequest_Key struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}

type GetTokenRequest_Signature 

type GetTokenRequest_Signature struct {
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3,oneof"`
}

type HasReply 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HasReply) Descriptor 

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

func (*HasReply) GetExists 

func (m *HasReply) GetExists() bool

func (*HasReply) GetTransactionError 

func (m *HasReply) GetTransactionError() string

func (*HasReply) ProtoMessage 

func (*HasReply) ProtoMessage()

func (*HasReply) Reset 

func (m *HasReply) Reset()

func (*HasReply) String 

func (m *HasReply) String() string

func (*HasReply) XXX_DiscardUnknown 

func (m *HasReply) XXX_DiscardUnknown()

func (*HasReply) XXX_Marshal 

func (m *HasReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HasReply) XXX_Merge 

func (m *HasReply) XXX_Merge(src proto.Message)

func (*HasReply) XXX_Size 

func (m *HasReply) XXX_Size() int

func (*HasReply) XXX_Unmarshal 

func (m *HasReply) XXX_Unmarshal(b []byte) error

type HasRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HasRequest) Descriptor 

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

func (*HasRequest) GetCollectionName 

func (m *HasRequest) GetCollectionName() string

func (*HasRequest) GetDbID 

func (m *HasRequest) GetDbID() []byte

func (*HasRequest) GetInstanceIDs 

func (m *HasRequest) GetInstanceIDs() []string

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) Reset 

func (m *HasRequest) Reset()

func (*HasRequest) String 

func (m *HasRequest) String() string

func (*HasRequest) XXX_DiscardUnknown 

func (m *HasRequest) XXX_DiscardUnknown()

func (*HasRequest) XXX_Marshal 

func (m *HasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HasRequest) XXX_Merge 

func (m *HasRequest) XXX_Merge(src proto.Message)

func (*HasRequest) XXX_Size 

func (m *HasRequest) XXX_Size() int

func (*HasRequest) XXX_Unmarshal 

func (m *HasRequest) XXX_Unmarshal(b []byte) error

type Index 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Index) Descriptor 

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

func (*Index) GetPath 

func (m *Index) GetPath() string

func (*Index) GetUnique 

func (m *Index) GetUnique() bool

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) String 

func (m *Index) String() string

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index) XXX_Merge 

func (m *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

func (m *Index) XXX_Unmarshal(b []byte) error

type ListCollectionsReply 

type ListCollectionsReply struct {
	Collections          []*GetCollectionInfoReply `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ListCollectionsReply) Descriptor 

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

func (*ListCollectionsReply) GetCollections 

func (m *ListCollectionsReply) GetCollections() []*GetCollectionInfoReply

func (*ListCollectionsReply) ProtoMessage 

func (*ListCollectionsReply) ProtoMessage()

func (*ListCollectionsReply) Reset 

func (m *ListCollectionsReply) Reset()

func (*ListCollectionsReply) String 

func (m *ListCollectionsReply) String() string

func (*ListCollectionsReply) XXX_DiscardUnknown 

func (m *ListCollectionsReply) XXX_DiscardUnknown()

func (*ListCollectionsReply) XXX_Marshal 

func (m *ListCollectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListCollectionsReply) XXX_Merge 

func (m *ListCollectionsReply) XXX_Merge(src proto.Message)

func (*ListCollectionsReply) XXX_Size 

func (m *ListCollectionsReply) XXX_Size() int

func (*ListCollectionsReply) XXX_Unmarshal 

func (m *ListCollectionsReply) XXX_Unmarshal(b []byte) error

type ListCollectionsRequest 

type ListCollectionsRequest struct {
	DbID                 []byte   `protobuf:"bytes,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListCollectionsRequest) Descriptor 

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

func (*ListCollectionsRequest) GetDbID 

func (m *ListCollectionsRequest) GetDbID() []byte

func (*ListCollectionsRequest) ProtoMessage 

func (*ListCollectionsRequest) ProtoMessage()

func (*ListCollectionsRequest) Reset 

func (m *ListCollectionsRequest) Reset()

func (*ListCollectionsRequest) String 

func (m *ListCollectionsRequest) String() string

func (*ListCollectionsRequest) XXX_DiscardUnknown 

func (m *ListCollectionsRequest) XXX_DiscardUnknown()

func (*ListCollectionsRequest) XXX_Marshal 

func (m *ListCollectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListCollectionsRequest) XXX_Merge 

func (m *ListCollectionsRequest) XXX_Merge(src proto.Message)

func (*ListCollectionsRequest) XXX_Size 

func (m *ListCollectionsRequest) XXX_Size() int

func (*ListCollectionsRequest) XXX_Unmarshal 

func (m *ListCollectionsRequest) XXX_Unmarshal(b []byte) error

type ListDBsReply 

type ListDBsReply struct {
	Dbs                  []*ListDBsReply_DB `protobuf:"bytes,1,rep,name=dbs,proto3" json:"dbs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListDBsReply) Descriptor 

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

func (*ListDBsReply) GetDbs 

func (m *ListDBsReply) GetDbs() []*ListDBsReply_DB

func (*ListDBsReply) ProtoMessage 

func (*ListDBsReply) ProtoMessage()

func (*ListDBsReply) Reset 

func (m *ListDBsReply) Reset()

func (*ListDBsReply) String 

func (m *ListDBsReply) String() string

func (*ListDBsReply) XXX_DiscardUnknown 

func (m *ListDBsReply) XXX_DiscardUnknown()

func (*ListDBsReply) XXX_Marshal 

func (m *ListDBsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDBsReply) XXX_Merge 

func (m *ListDBsReply) XXX_Merge(src proto.Message)

func (*ListDBsReply) XXX_Size 

func (m *ListDBsReply) XXX_Size() int

func (*ListDBsReply) XXX_Unmarshal 

func (m *ListDBsReply) XXX_Unmarshal(b []byte) error

type ListDBsReply_DB 

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListDBsReply_DB) Descriptor 

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

func (*ListDBsReply_DB) GetDbID 

func (m *ListDBsReply_DB) GetDbID() []byte

func (*ListDBsReply_DB) GetInfo 

func (m *ListDBsReply_DB) GetInfo() *GetDBInfoReply

func (*ListDBsReply_DB) ProtoMessage 

func (*ListDBsReply_DB) ProtoMessage()

func (*ListDBsReply_DB) Reset 

func (m *ListDBsReply_DB) Reset()

func (*ListDBsReply_DB) String 

func (m *ListDBsReply_DB) String() string

func (*ListDBsReply_DB) XXX_DiscardUnknown 

func (m *ListDBsReply_DB) XXX_DiscardUnknown()

func (*ListDBsReply_DB) XXX_Marshal 

func (m *ListDBsReply_DB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDBsReply_DB) XXX_Merge 

func (m *ListDBsReply_DB) XXX_Merge(src proto.Message)

func (*ListDBsReply_DB) XXX_Size 

func (m *ListDBsReply_DB) XXX_Size() int

func (*ListDBsReply_DB) XXX_Unmarshal 

func (m *ListDBsReply_DB) XXX_Unmarshal(b []byte) error

type ListDBsRequest 

type ListDBsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDBsRequest) Descriptor 

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

func (*ListDBsRequest) ProtoMessage 

func (*ListDBsRequest) ProtoMessage()

func (*ListDBsRequest) Reset 

func (m *ListDBsRequest) Reset()

func (*ListDBsRequest) String 

func (m *ListDBsRequest) String() string

func (*ListDBsRequest) XXX_DiscardUnknown 

func (m *ListDBsRequest) XXX_DiscardUnknown()

func (*ListDBsRequest) XXX_Marshal 

func (m *ListDBsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDBsRequest) XXX_Merge 

func (m *ListDBsRequest) XXX_Merge(src proto.Message)

func (*ListDBsRequest) XXX_Size 

func (m *ListDBsRequest) XXX_Size() int

func (*ListDBsRequest) XXX_Unmarshal 

func (m *ListDBsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListenReply) Descriptor 

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

func (*ListenReply) GetAction 

func (m *ListenReply) GetAction() ListenReply_Action

func (*ListenReply) GetCollectionName 

func (m *ListenReply) GetCollectionName() string

func (*ListenReply) GetInstance 

func (m *ListenReply) GetInstance() []byte

func (*ListenReply) GetInstanceID 

func (m *ListenReply) GetInstanceID() string

func (*ListenReply) ProtoMessage 

func (*ListenReply) ProtoMessage()

func (*ListenReply) Reset 

func (m *ListenReply) Reset()

func (*ListenReply) String 

func (m *ListenReply) String() string

func (*ListenReply) XXX_DiscardUnknown 

func (m *ListenReply) XXX_DiscardUnknown()

func (*ListenReply) XXX_Marshal 

func (m *ListenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenReply) XXX_Merge 

func (m *ListenReply) XXX_Merge(src proto.Message)

func (*ListenReply) XXX_Size 

func (m *ListenReply) XXX_Size() int

func (*ListenReply) XXX_Unmarshal 

func (m *ListenReply) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (ListenReply_Action) String 

func (x ListenReply_Action) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetDbID 

func (m *ListenRequest) GetDbID() []byte

func (*ListenRequest) GetFilters 

func (m *ListenRequest) GetFilters() []*ListenRequest_Filter

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenRequest) XXX_Merge 

func (m *ListenRequest) XXX_Merge(src proto.Message)

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

func (m *ListenRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ListenRequest_Filter) Descriptor 

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

func (*ListenRequest_Filter) GetAction 

func (m *ListenRequest_Filter) GetAction() ListenRequest_Filter_Action

func (*ListenRequest_Filter) GetCollectionName 

func (m *ListenRequest_Filter) GetCollectionName() string

func (*ListenRequest_Filter) GetInstanceID 

func (m *ListenRequest_Filter) GetInstanceID() string

func (*ListenRequest_Filter) ProtoMessage 

func (*ListenRequest_Filter) ProtoMessage()

func (*ListenRequest_Filter) Reset 

func (m *ListenRequest_Filter) Reset()

func (*ListenRequest_Filter) String 

func (m *ListenRequest_Filter) String() string

func (*ListenRequest_Filter) XXX_DiscardUnknown 

func (m *ListenRequest_Filter) XXX_DiscardUnknown()

func (*ListenRequest_Filter) XXX_Marshal 

func (m *ListenRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenRequest_Filter) XXX_Merge 

func (m *ListenRequest_Filter) XXX_Merge(src proto.Message)

func (*ListenRequest_Filter) XXX_Size 

func (m *ListenRequest_Filter) XXX_Size() int

func (*ListenRequest_Filter) XXX_Unmarshal 

func (m *ListenRequest_Filter) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (ListenRequest_Filter_Action) String 

func (x ListenRequest_Filter_Action) String() string

type NewCollectionReply 

type NewCollectionReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewCollectionReply) Descriptor 

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

func (*NewCollectionReply) ProtoMessage 

func (*NewCollectionReply) ProtoMessage()

func (*NewCollectionReply) Reset 

func (m *NewCollectionReply) Reset()

func (*NewCollectionReply) String 

func (m *NewCollectionReply) String() string

func (*NewCollectionReply) XXX_DiscardUnknown 

func (m *NewCollectionReply) XXX_DiscardUnknown()

func (*NewCollectionReply) XXX_Marshal 

func (m *NewCollectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewCollectionReply) XXX_Merge 

func (m *NewCollectionReply) XXX_Merge(src proto.Message)

func (*NewCollectionReply) XXX_Size 

func (m *NewCollectionReply) XXX_Size() int

func (*NewCollectionReply) XXX_Unmarshal 

func (m *NewCollectionReply) XXX_Unmarshal(b []byte) error

type NewCollectionRequest 

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*NewCollectionRequest) Descriptor 

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

func (*NewCollectionRequest) GetConfig 

func (m *NewCollectionRequest) GetConfig() *CollectionConfig

func (*NewCollectionRequest) GetDbID 

func (m *NewCollectionRequest) GetDbID() []byte

func (*NewCollectionRequest) ProtoMessage 

func (*NewCollectionRequest) ProtoMessage()

func (*NewCollectionRequest) Reset 

func (m *NewCollectionRequest) Reset()

func (*NewCollectionRequest) String 

func (m *NewCollectionRequest) String() string

func (*NewCollectionRequest) XXX_DiscardUnknown 

func (m *NewCollectionRequest) XXX_DiscardUnknown()

func (*NewCollectionRequest) XXX_Marshal 

func (m *NewCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewCollectionRequest) XXX_Merge 

func (m *NewCollectionRequest) XXX_Merge(src proto.Message)

func (*NewCollectionRequest) XXX_Size 

func (m *NewCollectionRequest) XXX_Size() int

func (*NewCollectionRequest) XXX_Unmarshal 

func (m *NewCollectionRequest) XXX_Unmarshal(b []byte) error

type NewDBFromAddrRequest 

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*NewDBFromAddrRequest) Descriptor 

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

func (*NewDBFromAddrRequest) GetAddr 

func (m *NewDBFromAddrRequest) GetAddr() []byte

func (*NewDBFromAddrRequest) GetBlock 

func (m *NewDBFromAddrRequest) GetBlock() bool

func (*NewDBFromAddrRequest) GetCollections 

func (m *NewDBFromAddrRequest) GetCollections() []*CollectionConfig

func (*NewDBFromAddrRequest) GetKey 

func (m *NewDBFromAddrRequest) GetKey() []byte

func (*NewDBFromAddrRequest) GetName 

func (m *NewDBFromAddrRequest) GetName() string

func (*NewDBFromAddrRequest) ProtoMessage 

func (*NewDBFromAddrRequest) ProtoMessage()

func (*NewDBFromAddrRequest) Reset 

func (m *NewDBFromAddrRequest) Reset()

func (*NewDBFromAddrRequest) String 

func (m *NewDBFromAddrRequest) String() string

func (*NewDBFromAddrRequest) XXX_DiscardUnknown 

func (m *NewDBFromAddrRequest) XXX_DiscardUnknown()

func (*NewDBFromAddrRequest) XXX_Marshal 

func (m *NewDBFromAddrRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewDBFromAddrRequest) XXX_Merge 

func (m *NewDBFromAddrRequest) XXX_Merge(src proto.Message)

func (*NewDBFromAddrRequest) XXX_Size 

func (m *NewDBFromAddrRequest) XXX_Size() int

func (*NewDBFromAddrRequest) XXX_Unmarshal 

func (m *NewDBFromAddrRequest) XXX_Unmarshal(b []byte) error

type NewDBReply 

type NewDBReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewDBReply) Descriptor 

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

func (*NewDBReply) ProtoMessage 

func (*NewDBReply) ProtoMessage()

func (*NewDBReply) Reset 

func (m *NewDBReply) Reset()

func (*NewDBReply) String 

func (m *NewDBReply) String() string

func (*NewDBReply) XXX_DiscardUnknown 

func (m *NewDBReply) XXX_DiscardUnknown()

func (*NewDBReply) XXX_Marshal 

func (m *NewDBReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewDBReply) XXX_Merge 

func (m *NewDBReply) XXX_Merge(src proto.Message)

func (*NewDBReply) XXX_Size 

func (m *NewDBReply) XXX_Size() int

func (*NewDBReply) XXX_Unmarshal 

func (m *NewDBReply) XXX_Unmarshal(b []byte) error

type NewDBRequest 

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*NewDBRequest) Descriptor 

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

func (*NewDBRequest) GetCollections 

func (m *NewDBRequest) GetCollections() []*CollectionConfig

func (*NewDBRequest) GetDbID 

func (m *NewDBRequest) GetDbID() []byte

func (*NewDBRequest) GetName 

func (m *NewDBRequest) GetName() string

func (*NewDBRequest) ProtoMessage 

func (*NewDBRequest) ProtoMessage()

func (*NewDBRequest) Reset 

func (m *NewDBRequest) Reset()

func (*NewDBRequest) String 

func (m *NewDBRequest) String() string

func (*NewDBRequest) XXX_DiscardUnknown 

func (m *NewDBRequest) XXX_DiscardUnknown()

func (*NewDBRequest) XXX_Marshal 

func (m *NewDBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewDBRequest) XXX_Merge 

func (m *NewDBRequest) XXX_Merge(src proto.Message)

func (*NewDBRequest) XXX_Size 

func (m *NewDBRequest) XXX_Size() int

func (*NewDBRequest) XXX_Unmarshal 

func (m *NewDBRequest) XXX_Unmarshal(b []byte) error

type ReadTransactionReply 

type ReadTransactionReply struct {
	// Types that are valid to be assigned to Option:
	//	*ReadTransactionReply_HasReply
	//	*ReadTransactionReply_FindReply
	//	*ReadTransactionReply_FindByIDReply
	Option               isReadTransactionReply_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ReadTransactionReply) Descriptor 

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

func (*ReadTransactionReply) GetFindByIDReply 

func (m *ReadTransactionReply) GetFindByIDReply() *FindByIDReply

func (*ReadTransactionReply) GetFindReply 

func (m *ReadTransactionReply) GetFindReply() *FindReply

func (*ReadTransactionReply) GetHasReply 

func (m *ReadTransactionReply) GetHasReply() *HasReply

func (*ReadTransactionReply) GetOption 

func (m *ReadTransactionReply) GetOption() isReadTransactionReply_Option

func (*ReadTransactionReply) ProtoMessage 

func (*ReadTransactionReply) ProtoMessage()

func (*ReadTransactionReply) Reset 

func (m *ReadTransactionReply) Reset()

func (*ReadTransactionReply) String 

func (m *ReadTransactionReply) String() string

func (*ReadTransactionReply) XXX_DiscardUnknown 

func (m *ReadTransactionReply) XXX_DiscardUnknown()

func (*ReadTransactionReply) XXX_Marshal 

func (m *ReadTransactionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTransactionReply) XXX_Merge 

func (m *ReadTransactionReply) XXX_Merge(src proto.Message)

func (*ReadTransactionReply) XXX_OneofWrappers 

func (*ReadTransactionReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadTransactionReply) XXX_Size 

func (m *ReadTransactionReply) XXX_Size() int

func (*ReadTransactionReply) XXX_Unmarshal 

func (m *ReadTransactionReply) XXX_Unmarshal(b []byte) error

type ReadTransactionReply_FindByIDReply 

type ReadTransactionReply_FindByIDReply struct {
	FindByIDReply *FindByIDReply `protobuf:"bytes,3,opt,name=findByIDReply,proto3,oneof"`
}

type ReadTransactionReply_FindReply 

type ReadTransactionReply_FindReply struct {
	FindReply *FindReply `protobuf:"bytes,2,opt,name=findReply,proto3,oneof"`
}

type ReadTransactionReply_HasReply 

type ReadTransactionReply_HasReply struct {
	HasReply *HasReply `protobuf:"bytes,1,opt,name=hasReply,proto3,oneof"`
}

type ReadTransactionRequest 

type ReadTransactionRequest struct {
	// Types that are valid to be assigned to Option:
	//	*ReadTransactionRequest_StartTransactionRequest
	//	*ReadTransactionRequest_HasRequest
	//	*ReadTransactionRequest_FindRequest
	//	*ReadTransactionRequest_FindByIDRequest
	Option               isReadTransactionRequest_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ReadTransactionRequest) Descriptor 

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

func (*ReadTransactionRequest) GetFindByIDRequest 

func (m *ReadTransactionRequest) GetFindByIDRequest() *FindByIDRequest

func (*ReadTransactionRequest) GetFindRequest 

func (m *ReadTransactionRequest) GetFindRequest() *FindRequest

func (*ReadTransactionRequest) GetHasRequest 

func (m *ReadTransactionRequest) GetHasRequest() *HasRequest

func (*ReadTransactionRequest) GetOption 

func (m *ReadTransactionRequest) GetOption() isReadTransactionRequest_Option

func (*ReadTransactionRequest) GetStartTransactionRequest 

func (m *ReadTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest

func (*ReadTransactionRequest) ProtoMessage 

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) Reset 

func (m *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) String 

func (m *ReadTransactionRequest) String() string

func (*ReadTransactionRequest) XXX_DiscardUnknown 

func (m *ReadTransactionRequest) XXX_DiscardUnknown()

func (*ReadTransactionRequest) XXX_Marshal 

func (m *ReadTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTransactionRequest) XXX_Merge 

func (m *ReadTransactionRequest) XXX_Merge(src proto.Message)

func (*ReadTransactionRequest) XXX_OneofWrappers 

func (*ReadTransactionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadTransactionRequest) XXX_Size 

func (m *ReadTransactionRequest) XXX_Size() int

func (*ReadTransactionRequest) XXX_Unmarshal 

func (m *ReadTransactionRequest) XXX_Unmarshal(b []byte) error

type ReadTransactionRequest_FindByIDRequest 

type ReadTransactionRequest_FindByIDRequest struct {
	FindByIDRequest *FindByIDRequest `protobuf:"bytes,4,opt,name=findByIDRequest,proto3,oneof"`
}

type ReadTransactionRequest_FindRequest 

type ReadTransactionRequest_FindRequest struct {
	FindRequest *FindRequest `protobuf:"bytes,3,opt,name=findRequest,proto3,oneof"`
}

type ReadTransactionRequest_HasRequest 

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 

type SaveReply struct {
	TransactionError     string   `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SaveReply) Descriptor 

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

func (*SaveReply) GetTransactionError 

func (m *SaveReply) GetTransactionError() string

func (*SaveReply) ProtoMessage 

func (*SaveReply) ProtoMessage()

func (*SaveReply) Reset 

func (m *SaveReply) Reset()

func (*SaveReply) String 

func (m *SaveReply) String() string

func (*SaveReply) XXX_DiscardUnknown 

func (m *SaveReply) XXX_DiscardUnknown()

func (*SaveReply) XXX_Marshal 

func (m *SaveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveReply) XXX_Merge 

func (m *SaveReply) XXX_Merge(src proto.Message)

func (*SaveReply) XXX_Size 

func (m *SaveReply) XXX_Size() int

func (*SaveReply) XXX_Unmarshal 

func (m *SaveReply) XXX_Unmarshal(b []byte) error

type SaveRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SaveRequest) Descriptor 

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

func (*SaveRequest) GetCollectionName 

func (m *SaveRequest) GetCollectionName() string

func (*SaveRequest) GetDbID 

func (m *SaveRequest) GetDbID() []byte

func (*SaveRequest) GetInstances 

func (m *SaveRequest) GetInstances() [][]byte

func (*SaveRequest) ProtoMessage 

func (*SaveRequest) ProtoMessage()

func (*SaveRequest) Reset 

func (m *SaveRequest) Reset()

func (*SaveRequest) String 

func (m *SaveRequest) String() string

func (*SaveRequest) XXX_DiscardUnknown 

func (m *SaveRequest) XXX_DiscardUnknown()

func (*SaveRequest) XXX_Marshal 

func (m *SaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveRequest) XXX_Merge 

func (m *SaveRequest) XXX_Merge(src proto.Message)

func (*SaveRequest) XXX_Size 

func (m *SaveRequest) XXX_Size() int

func (*SaveRequest) XXX_Unmarshal 

func (m *SaveRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartTransactionRequest) Descriptor 

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

func (*StartTransactionRequest) GetCollectionName 

func (m *StartTransactionRequest) GetCollectionName() string

func (*StartTransactionRequest) GetDbID 

func (m *StartTransactionRequest) GetDbID() []byte

func (*StartTransactionRequest) ProtoMessage 

func (*StartTransactionRequest) ProtoMessage()

func (*StartTransactionRequest) Reset 

func (m *StartTransactionRequest) Reset()

func (*StartTransactionRequest) String 

func (m *StartTransactionRequest) String() string

func (*StartTransactionRequest) XXX_DiscardUnknown 

func (m *StartTransactionRequest) XXX_DiscardUnknown()

func (*StartTransactionRequest) XXX_Marshal 

func (m *StartTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTransactionRequest) XXX_Merge 

func (m *StartTransactionRequest) XXX_Merge(src proto.Message)

func (*StartTransactionRequest) XXX_Size 

func (m *StartTransactionRequest) XXX_Size() int

func (*StartTransactionRequest) XXX_Unmarshal 

func (m *StartTransactionRequest) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Create 

func (*UnimplementedAPIServer) Create(ctx context.Context, req *CreateRequest) (*CreateReply, error)

func (*UnimplementedAPIServer) Delete 

func (*UnimplementedAPIServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteReply, error)

func (*UnimplementedAPIServer) DeleteCollection 

func (*UnimplementedAPIServer) DeleteCollection(ctx context.Context, req *DeleteCollectionRequest) (*DeleteCollectionReply, error)

func (*UnimplementedAPIServer) DeleteDB 

func (*UnimplementedAPIServer) DeleteDB(ctx context.Context, req *DeleteDBRequest) (*DeleteDBReply, error)

func (*UnimplementedAPIServer) Find 

func (*UnimplementedAPIServer) Find(ctx context.Context, req *FindRequest) (*FindReply, error)

func (*UnimplementedAPIServer) FindByID 

func (*UnimplementedAPIServer) FindByID(ctx context.Context, req *FindByIDRequest) (*FindByIDReply, error)

func (*UnimplementedAPIServer) GetCollectionIndexes 

func (*UnimplementedAPIServer) GetCollectionIndexes(ctx context.Context, req *GetCollectionIndexesRequest) (*GetCollectionIndexesReply, error)

func (*UnimplementedAPIServer) GetCollectionInfo 

func (*UnimplementedAPIServer) GetCollectionInfo(ctx context.Context, req *GetCollectionInfoRequest) (*GetCollectionInfoReply, error)

func (*UnimplementedAPIServer) GetDBInfo 

func (*UnimplementedAPIServer) GetDBInfo(ctx context.Context, req *GetDBInfoRequest) (*GetDBInfoReply, error)

func (*UnimplementedAPIServer) GetToken 

func (*UnimplementedAPIServer) GetToken(srv API_GetTokenServer) error

func (*UnimplementedAPIServer) Has 

func (*UnimplementedAPIServer) Has(ctx context.Context, req *HasRequest) (*HasReply, error)

func (*UnimplementedAPIServer) ListCollections 

func (*UnimplementedAPIServer) ListCollections(ctx context.Context, req *ListCollectionsRequest) (*ListCollectionsReply, error)

func (*UnimplementedAPIServer) ListDBs 

func (*UnimplementedAPIServer) ListDBs(ctx context.Context, req *ListDBsRequest) (*ListDBsReply, error)

func (*UnimplementedAPIServer) Listen 

func (*UnimplementedAPIServer) Listen(req *ListenRequest, srv API_ListenServer) error

func (*UnimplementedAPIServer) NewCollection 

func (*UnimplementedAPIServer) NewCollection(ctx context.Context, req *NewCollectionRequest) (*NewCollectionReply, error)

func (*UnimplementedAPIServer) NewDB 

func (*UnimplementedAPIServer) NewDB(ctx context.Context, req *NewDBRequest) (*NewDBReply, error)

func (*UnimplementedAPIServer) NewDBFromAddr 

func (*UnimplementedAPIServer) NewDBFromAddr(ctx context.Context, req *NewDBFromAddrRequest) (*NewDBReply, error)

func (*UnimplementedAPIServer) ReadTransaction 

func (*UnimplementedAPIServer) ReadTransaction(srv API_ReadTransactionServer) error

func (*UnimplementedAPIServer) Save 

func (*UnimplementedAPIServer) Save(ctx context.Context, req *SaveRequest) (*SaveReply, error)

func (*UnimplementedAPIServer) UpdateCollection 

func (*UnimplementedAPIServer) UpdateCollection(ctx context.Context, req *UpdateCollectionRequest) (*UpdateCollectionReply, error)

func (*UnimplementedAPIServer) Verify 

func (*UnimplementedAPIServer) Verify(ctx context.Context, req *VerifyRequest) (*VerifyReply, error)

func (*UnimplementedAPIServer) WriteTransaction 

func (*UnimplementedAPIServer) WriteTransaction(srv API_WriteTransactionServer) error

type UpdateCollectionReply 

type UpdateCollectionReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateCollectionReply) Descriptor 

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

func (*UpdateCollectionReply) ProtoMessage 

func (*UpdateCollectionReply) ProtoMessage()

func (*UpdateCollectionReply) Reset 

func (m *UpdateCollectionReply) Reset()

func (*UpdateCollectionReply) String 

func (m *UpdateCollectionReply) String() string

func (*UpdateCollectionReply) XXX_DiscardUnknown 

func (m *UpdateCollectionReply) XXX_DiscardUnknown()

func (*UpdateCollectionReply) XXX_Marshal 

func (m *UpdateCollectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateCollectionReply) XXX_Merge 

func (m *UpdateCollectionReply) XXX_Merge(src proto.Message)

func (*UpdateCollectionReply) XXX_Size 

func (m *UpdateCollectionReply) XXX_Size() int

func (*UpdateCollectionReply) XXX_Unmarshal 

func (m *UpdateCollectionReply) XXX_Unmarshal(b []byte) error

type UpdateCollectionRequest 

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateCollectionRequest) Descriptor 

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

func (*UpdateCollectionRequest) GetConfig 

func (m *UpdateCollectionRequest) GetConfig() *CollectionConfig

func (*UpdateCollectionRequest) GetDbID 

func (m *UpdateCollectionRequest) GetDbID() []byte

func (*UpdateCollectionRequest) ProtoMessage 

func (*UpdateCollectionRequest) ProtoMessage()

func (*UpdateCollectionRequest) Reset 

func (m *UpdateCollectionRequest) Reset()

func (*UpdateCollectionRequest) String 

func (m *UpdateCollectionRequest) String() string

func (*UpdateCollectionRequest) XXX_DiscardUnknown 

func (m *UpdateCollectionRequest) XXX_DiscardUnknown()

func (*UpdateCollectionRequest) XXX_Marshal 

func (m *UpdateCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateCollectionRequest) XXX_Merge 

func (m *UpdateCollectionRequest) XXX_Merge(src proto.Message)

func (*UpdateCollectionRequest) XXX_Size 

func (m *UpdateCollectionRequest) XXX_Size() int

func (*UpdateCollectionRequest) XXX_Unmarshal 

func (m *UpdateCollectionRequest) XXX_Unmarshal(b []byte) error

type VerifyReply 

type VerifyReply struct {
	TransactionError     string   `protobuf:"bytes,1,opt,name=transactionError,proto3" json:"transactionError,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerifyReply) Descriptor 

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

func (*VerifyReply) GetTransactionError 

func (m *VerifyReply) GetTransactionError() string

func (*VerifyReply) ProtoMessage 

func (*VerifyReply) ProtoMessage()

func (*VerifyReply) Reset 

func (m *VerifyReply) Reset()

func (*VerifyReply) String 

func (m *VerifyReply) String() string

func (*VerifyReply) XXX_DiscardUnknown 

func (m *VerifyReply) XXX_DiscardUnknown()

func (*VerifyReply) XXX_Marshal 

func (m *VerifyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyReply) XXX_Merge 

func (m *VerifyReply) XXX_Merge(src proto.Message)

func (*VerifyReply) XXX_Size 

func (m *VerifyReply) XXX_Size() int

func (*VerifyReply) XXX_Unmarshal 

func (m *VerifyReply) XXX_Unmarshal(b []byte) error

type VerifyRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerifyRequest) Descriptor 

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

func (*VerifyRequest) GetCollectionName 

func (m *VerifyRequest) GetCollectionName() string

func (*VerifyRequest) GetDbID 

func (m *VerifyRequest) GetDbID() []byte

func (*VerifyRequest) GetInstances 

func (m *VerifyRequest) GetInstances() [][]byte

func (*VerifyRequest) ProtoMessage 

func (*VerifyRequest) ProtoMessage()

func (*VerifyRequest) Reset 

func (m *VerifyRequest) Reset()

func (*VerifyRequest) String 

func (m *VerifyRequest) String() string

func (*VerifyRequest) XXX_DiscardUnknown 

func (m *VerifyRequest) XXX_DiscardUnknown()

func (*VerifyRequest) XXX_Marshal 

func (m *VerifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyRequest) XXX_Merge 

func (m *VerifyRequest) XXX_Merge(src proto.Message)

func (*VerifyRequest) XXX_Size 

func (m *VerifyRequest) XXX_Size() int

func (*VerifyRequest) XXX_Unmarshal 

func (m *VerifyRequest) XXX_Unmarshal(b []byte) error

type WriteTransactionReply 

type WriteTransactionReply struct {
	// Types that are valid to be assigned to Option:
	//	*WriteTransactionReply_CreateReply
	//	*WriteTransactionReply_VerifyReply
	//	*WriteTransactionReply_SaveReply
	//	*WriteTransactionReply_DeleteReply
	//	*WriteTransactionReply_HasReply
	//	*WriteTransactionReply_FindReply
	//	*WriteTransactionReply_FindByIDReply
	//	*WriteTransactionReply_DiscardReply
	Option               isWriteTransactionReply_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*WriteTransactionReply) Descriptor 

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

func (*WriteTransactionReply) GetCreateReply 

func (m *WriteTransactionReply) GetCreateReply() *CreateReply

func (*WriteTransactionReply) GetDeleteReply 

func (m *WriteTransactionReply) GetDeleteReply() *DeleteReply

func (*WriteTransactionReply) GetDiscardReply 

func (m *WriteTransactionReply) GetDiscardReply() *DiscardReply

func (*WriteTransactionReply) GetFindByIDReply 

func (m *WriteTransactionReply) GetFindByIDReply() *FindByIDReply

func (*WriteTransactionReply) GetFindReply 

func (m *WriteTransactionReply) GetFindReply() *FindReply

func (*WriteTransactionReply) GetHasReply 

func (m *WriteTransactionReply) GetHasReply() *HasReply

func (*WriteTransactionReply) GetOption 

func (m *WriteTransactionReply) GetOption() isWriteTransactionReply_Option

func (*WriteTransactionReply) GetSaveReply 

func (m *WriteTransactionReply) GetSaveReply() *SaveReply

func (*WriteTransactionReply) GetVerifyReply 

func (m *WriteTransactionReply) GetVerifyReply() *VerifyReply

func (*WriteTransactionReply) ProtoMessage 

func (*WriteTransactionReply) ProtoMessage()

func (*WriteTransactionReply) Reset 

func (m *WriteTransactionReply) Reset()

func (*WriteTransactionReply) String 

func (m *WriteTransactionReply) String() string

func (*WriteTransactionReply) XXX_DiscardUnknown 

func (m *WriteTransactionReply) XXX_DiscardUnknown()

func (*WriteTransactionReply) XXX_Marshal 

func (m *WriteTransactionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteTransactionReply) XXX_Merge 

func (m *WriteTransactionReply) XXX_Merge(src proto.Message)

func (*WriteTransactionReply) XXX_OneofWrappers 

func (*WriteTransactionReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteTransactionReply) XXX_Size 

func (m *WriteTransactionReply) XXX_Size() int

func (*WriteTransactionReply) XXX_Unmarshal 

func (m *WriteTransactionReply) XXX_Unmarshal(b []byte) error

type WriteTransactionReply_CreateReply 

type WriteTransactionReply_CreateReply struct {
	CreateReply *CreateReply `protobuf:"bytes,1,opt,name=createReply,proto3,oneof"`
}

type WriteTransactionReply_DeleteReply 

type WriteTransactionReply_DeleteReply struct {
	DeleteReply *DeleteReply `protobuf:"bytes,3,opt,name=deleteReply,proto3,oneof"`
}

type WriteTransactionReply_DiscardReply 

type WriteTransactionReply_DiscardReply struct {
	DiscardReply *DiscardReply `protobuf:"bytes,8,opt,name=discardReply,proto3,oneof"`
}

type WriteTransactionReply_FindByIDReply 

type WriteTransactionReply_FindByIDReply struct {
	FindByIDReply *FindByIDReply `protobuf:"bytes,6,opt,name=findByIDReply,proto3,oneof"`
}

type WriteTransactionReply_FindReply 

type WriteTransactionReply_FindReply struct {
	FindReply *FindReply `protobuf:"bytes,5,opt,name=findReply,proto3,oneof"`
}

type WriteTransactionReply_HasReply 

type WriteTransactionReply_HasReply struct {
	HasReply *HasReply `protobuf:"bytes,4,opt,name=hasReply,proto3,oneof"`
}

type WriteTransactionReply_SaveReply 

type WriteTransactionReply_SaveReply struct {
	SaveReply *SaveReply `protobuf:"bytes,2,opt,name=saveReply,proto3,oneof"`
}

type WriteTransactionReply_VerifyReply 

type WriteTransactionReply_VerifyReply struct {
	VerifyReply *VerifyReply `protobuf:"bytes,7,opt,name=verifyReply,proto3,oneof"`
}

type WriteTransactionRequest 

type WriteTransactionRequest struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*WriteTransactionRequest) Descriptor 

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

func (*WriteTransactionRequest) GetCreateRequest 

func (m *WriteTransactionRequest) GetCreateRequest() *CreateRequest

func (*WriteTransactionRequest) GetDeleteRequest 

func (m *WriteTransactionRequest) GetDeleteRequest() *DeleteRequest

func (*WriteTransactionRequest) GetDiscardRequest 

func (m *WriteTransactionRequest) GetDiscardRequest() *DiscardRequest

func (*WriteTransactionRequest) GetFindByIDRequest 

func (m *WriteTransactionRequest) GetFindByIDRequest() *FindByIDRequest

func (*WriteTransactionRequest) GetFindRequest 

func (m *WriteTransactionRequest) GetFindRequest() *FindRequest

func (*WriteTransactionRequest) GetHasRequest 

func (m *WriteTransactionRequest) GetHasRequest() *HasRequest

func (*WriteTransactionRequest) GetOption 

func (m *WriteTransactionRequest) GetOption() isWriteTransactionRequest_Option

func (*WriteTransactionRequest) GetSaveRequest 

func (m *WriteTransactionRequest) GetSaveRequest() *SaveRequest

func (*WriteTransactionRequest) GetStartTransactionRequest 

func (m *WriteTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest

func (*WriteTransactionRequest) GetVerifyRequest 

func (m *WriteTransactionRequest) GetVerifyRequest() *VerifyRequest

func (*WriteTransactionRequest) ProtoMessage 

func (*WriteTransactionRequest) ProtoMessage()

func (*WriteTransactionRequest) Reset 

func (m *WriteTransactionRequest) Reset()

func (*WriteTransactionRequest) String 

func (m *WriteTransactionRequest) String() string

func (*WriteTransactionRequest) XXX_DiscardUnknown 

func (m *WriteTransactionRequest) XXX_DiscardUnknown()

func (*WriteTransactionRequest) XXX_Marshal 

func (m *WriteTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteTransactionRequest) XXX_Merge 

func (m *WriteTransactionRequest) XXX_Merge(src proto.Message)

func (*WriteTransactionRequest) XXX_OneofWrappers 

func (*WriteTransactionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteTransactionRequest) XXX_Size 

func (m *WriteTransactionRequest) XXX_Size() int

func (*WriteTransactionRequest) XXX_Unmarshal 

func (m *WriteTransactionRequest) XXX_Unmarshal(b []byte) error

type WriteTransactionRequest_CreateRequest 

type WriteTransactionRequest_CreateRequest struct {
	CreateRequest *CreateRequest `protobuf:"bytes,2,opt,name=createRequest,proto3,oneof"`
}

type WriteTransactionRequest_DeleteRequest 

type WriteTransactionRequest_DeleteRequest struct {
	DeleteRequest *DeleteRequest `protobuf:"bytes,4,opt,name=deleteRequest,proto3,oneof"`
}

type WriteTransactionRequest_DiscardRequest 

type WriteTransactionRequest_DiscardRequest struct {
	DiscardRequest *DiscardRequest `protobuf:"bytes,9,opt,name=discardRequest,proto3,oneof"`
}

type WriteTransactionRequest_FindByIDRequest 

type WriteTransactionRequest_FindByIDRequest struct {
	FindByIDRequest *FindByIDRequest `protobuf:"bytes,7,opt,name=findByIDRequest,proto3,oneof"`
}

type WriteTransactionRequest_FindRequest 

type WriteTransactionRequest_FindRequest struct {
	FindRequest *FindRequest `protobuf:"bytes,6,opt,name=findRequest,proto3,oneof"`
}

type WriteTransactionRequest_HasRequest 

type WriteTransactionRequest_HasRequest struct {
	HasRequest *HasRequest `protobuf:"bytes,5,opt,name=hasRequest,proto3,oneof"`
}

type WriteTransactionRequest_SaveRequest 

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 

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.