threads_pb

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2020 License: MIT Imports: 7 Imported by: 3

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

func (*CollectionConfig) Descriptor added in v0.1.12 

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

func (*CollectionConfig) GetIndexes added in v0.1.12 

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

func (*CollectionConfig) GetName added in v0.1.12 

func (m *CollectionConfig) GetName() string

func (*CollectionConfig) GetReadFilter added in v1.0.0 

func (m *CollectionConfig) GetReadFilter() string

func (*CollectionConfig) GetSchema added in v0.1.12 

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

func (*CollectionConfig) GetWriteValidator added in v1.0.0 

func (m *CollectionConfig) GetWriteValidator() string

func (*CollectionConfig) ProtoMessage added in v0.1.12 

func (*CollectionConfig) ProtoMessage()

func (*CollectionConfig) Reset added in v0.1.12 

func (m *CollectionConfig) Reset()

func (*CollectionConfig) String added in v0.1.12 

func (m *CollectionConfig) String() string

func (*CollectionConfig) XXX_DiscardUnknown added in v0.1.12 

func (m *CollectionConfig) XXX_DiscardUnknown()

func (*CollectionConfig) XXX_Marshal added in v0.1.12 

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

func (*CollectionConfig) XXX_Merge added in v0.1.12 

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

func (*CollectionConfig) XXX_Size added in v0.1.12 

func (m *CollectionConfig) XXX_Size() int

func (*CollectionConfig) XXX_Unmarshal added in v0.1.12 

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

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

func (*CreateReply) Descriptor added in v0.1.12 

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

func (*CreateReply) GetInstanceIDs added in v0.1.13 

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

func (*CreateReply) GetTransactionError added in v1.0.0 

func (m *CreateReply) GetTransactionError() string

func (*CreateReply) ProtoMessage added in v0.1.12 

func (*CreateReply) ProtoMessage()

func (*CreateReply) Reset added in v0.1.12 

func (m *CreateReply) Reset()

func (*CreateReply) String added in v0.1.12 

func (m *CreateReply) String() string

func (*CreateReply) XXX_DiscardUnknown added in v0.1.12 

func (m *CreateReply) XXX_DiscardUnknown()

func (*CreateReply) XXX_Marshal added in v0.1.12 

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

func (*CreateReply) XXX_Merge added in v0.1.12 

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

func (*CreateReply) XXX_Size added in v0.1.12 

func (m *CreateReply) XXX_Size() int

func (*CreateReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*CreateRequest) Descriptor added in v0.1.12 

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

func (*CreateRequest) GetCollectionName added in v0.1.12 

func (m *CreateRequest) GetCollectionName() string

func (*CreateRequest) GetDbID added in v0.1.12 

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

func (*CreateRequest) GetInstances added in v0.1.13 

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

func (*CreateRequest) ProtoMessage added in v0.1.12 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset added in v0.1.12 

func (m *CreateRequest) Reset()

func (*CreateRequest) String added in v0.1.12 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal added in v0.1.12 

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

func (*CreateRequest) XXX_Merge added in v0.1.12 

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

func (*CreateRequest) XXX_Size added in v0.1.12 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal added in v0.1.12 

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

type DeleteCollectionReply added in v0.1.19 

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

func (*DeleteCollectionReply) Descriptor added in v0.1.19 

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

func (*DeleteCollectionReply) ProtoMessage added in v0.1.19 

func (*DeleteCollectionReply) ProtoMessage()

func (*DeleteCollectionReply) Reset added in v0.1.19 

func (m *DeleteCollectionReply) Reset()

func (*DeleteCollectionReply) String added in v0.1.19 

func (m *DeleteCollectionReply) String() string

func (*DeleteCollectionReply) XXX_DiscardUnknown added in v0.1.19 

func (m *DeleteCollectionReply) XXX_DiscardUnknown()

func (*DeleteCollectionReply) XXX_Marshal added in v0.1.19 

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

func (*DeleteCollectionReply) XXX_Merge added in v0.1.19 

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

func (*DeleteCollectionReply) XXX_Size added in v0.1.19 

func (m *DeleteCollectionReply) XXX_Size() int

func (*DeleteCollectionReply) XXX_Unmarshal added in v0.1.19 

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

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

func (*DeleteCollectionRequest) Descriptor added in v0.1.19 

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

func (*DeleteCollectionRequest) GetDbID added in v0.1.19 

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

func (*DeleteCollectionRequest) GetName added in v0.1.19 

func (m *DeleteCollectionRequest) GetName() string

func (*DeleteCollectionRequest) ProtoMessage added in v0.1.19 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) Reset added in v0.1.19 

func (m *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String added in v0.1.19 

func (m *DeleteCollectionRequest) String() string

func (*DeleteCollectionRequest) XXX_DiscardUnknown added in v0.1.19 

func (m *DeleteCollectionRequest) XXX_DiscardUnknown()

func (*DeleteCollectionRequest) XXX_Marshal added in v0.1.19 

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

func (*DeleteCollectionRequest) XXX_Merge added in v0.1.19 

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

func (*DeleteCollectionRequest) XXX_Size added in v0.1.19 

func (m *DeleteCollectionRequest) XXX_Size() int

func (*DeleteCollectionRequest) XXX_Unmarshal added in v0.1.19 

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

type DeleteDBReply added in v0.1.15 

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

func (*DeleteDBReply) Descriptor added in v0.1.15 

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

func (*DeleteDBReply) ProtoMessage added in v0.1.15 

func (*DeleteDBReply) ProtoMessage()

func (*DeleteDBReply) Reset added in v0.1.15 

func (m *DeleteDBReply) Reset()

func (*DeleteDBReply) String added in v0.1.15 

func (m *DeleteDBReply) String() string

func (*DeleteDBReply) XXX_DiscardUnknown added in v0.1.15 

func (m *DeleteDBReply) XXX_DiscardUnknown()

func (*DeleteDBReply) XXX_Marshal added in v0.1.15 

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

func (*DeleteDBReply) XXX_Merge added in v0.1.15 

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

func (*DeleteDBReply) XXX_Size added in v0.1.15 

func (m *DeleteDBReply) XXX_Size() int

func (*DeleteDBReply) XXX_Unmarshal added in v0.1.15 

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

type DeleteDBRequest added in v0.1.15 

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 added in v0.1.15 

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

func (*DeleteDBRequest) GetDbID added in v0.1.15 

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

func (*DeleteDBRequest) ProtoMessage added in v0.1.15 

func (*DeleteDBRequest) ProtoMessage()

func (*DeleteDBRequest) Reset added in v0.1.15 

func (m *DeleteDBRequest) Reset()

func (*DeleteDBRequest) String added in v0.1.15 

func (m *DeleteDBRequest) String() string

func (*DeleteDBRequest) XXX_DiscardUnknown added in v0.1.15 

func (m *DeleteDBRequest) XXX_DiscardUnknown()

func (*DeleteDBRequest) XXX_Marshal added in v0.1.15 

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

func (*DeleteDBRequest) XXX_Merge added in v0.1.15 

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

func (*DeleteDBRequest) XXX_Size added in v0.1.15 

func (m *DeleteDBRequest) XXX_Size() int

func (*DeleteDBRequest) XXX_Unmarshal added in v0.1.15 

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

type DeleteReply added in v0.1.12 

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 added in v0.1.12 

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

func (*DeleteReply) GetTransactionError added in v1.0.0 

func (m *DeleteReply) GetTransactionError() string

func (*DeleteReply) ProtoMessage added in v0.1.12 

func (*DeleteReply) ProtoMessage()

func (*DeleteReply) Reset added in v0.1.12 

func (m *DeleteReply) Reset()

func (*DeleteReply) String added in v0.1.12 

func (m *DeleteReply) String() string

func (*DeleteReply) XXX_DiscardUnknown added in v0.1.12 

func (m *DeleteReply) XXX_DiscardUnknown()

func (*DeleteReply) XXX_Marshal added in v0.1.12 

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

func (*DeleteReply) XXX_Merge added in v0.1.12 

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

func (*DeleteReply) XXX_Size added in v0.1.12 

func (m *DeleteReply) XXX_Size() int

func (*DeleteReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*DeleteRequest) Descriptor added in v0.1.12 

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

func (*DeleteRequest) GetCollectionName added in v0.1.12 

func (m *DeleteRequest) GetCollectionName() string

func (*DeleteRequest) GetDbID added in v0.1.12 

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

func (*DeleteRequest) GetInstanceIDs added in v0.1.12 

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

func (*DeleteRequest) ProtoMessage added in v0.1.12 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset added in v0.1.12 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String added in v0.1.12 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal added in v0.1.12 

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

func (*DeleteRequest) XXX_Merge added in v0.1.12 

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

func (*DeleteRequest) XXX_Size added in v0.1.12 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal added in v0.1.12 

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

type DiscardReply added in v1.0.0 

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

func (*DiscardReply) Descriptor added in v1.0.0 

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

func (*DiscardReply) ProtoMessage added in v1.0.0 

func (*DiscardReply) ProtoMessage()

func (*DiscardReply) Reset added in v1.0.0 

func (m *DiscardReply) Reset()

func (*DiscardReply) String added in v1.0.0 

func (m *DiscardReply) String() string

func (*DiscardReply) XXX_DiscardUnknown added in v1.0.0 

func (m *DiscardReply) XXX_DiscardUnknown()

func (*DiscardReply) XXX_Marshal added in v1.0.0 

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

func (*DiscardReply) XXX_Merge added in v1.0.0 

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

func (*DiscardReply) XXX_Size added in v1.0.0 

func (m *DiscardReply) XXX_Size() int

func (*DiscardReply) XXX_Unmarshal added in v1.0.0 

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

type DiscardRequest added in v1.0.0 

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

func (*DiscardRequest) Descriptor added in v1.0.0 

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

func (*DiscardRequest) ProtoMessage added in v1.0.0 

func (*DiscardRequest) ProtoMessage()

func (*DiscardRequest) Reset added in v1.0.0 

func (m *DiscardRequest) Reset()

func (*DiscardRequest) String added in v1.0.0 

func (m *DiscardRequest) String() string

func (*DiscardRequest) XXX_DiscardUnknown added in v1.0.0 

func (m *DiscardRequest) XXX_DiscardUnknown()

func (*DiscardRequest) XXX_Marshal added in v1.0.0 

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

func (*DiscardRequest) XXX_Merge added in v1.0.0 

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

func (*DiscardRequest) XXX_Size added in v1.0.0 

func (m *DiscardRequest) XXX_Size() int

func (*DiscardRequest) XXX_Unmarshal added in v1.0.0 

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

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

func (*FindByIDReply) Descriptor added in v0.1.12 

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

func (*FindByIDReply) GetInstance added in v0.1.12 

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

func (*FindByIDReply) GetTransactionError added in v1.0.0 

func (m *FindByIDReply) GetTransactionError() string

func (*FindByIDReply) ProtoMessage added in v0.1.12 

func (*FindByIDReply) ProtoMessage()

func (*FindByIDReply) Reset added in v0.1.12 

func (m *FindByIDReply) Reset()

func (*FindByIDReply) String added in v0.1.12 

func (m *FindByIDReply) String() string

func (*FindByIDReply) XXX_DiscardUnknown added in v0.1.12 

func (m *FindByIDReply) XXX_DiscardUnknown()

func (*FindByIDReply) XXX_Marshal added in v0.1.12 

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

func (*FindByIDReply) XXX_Merge added in v0.1.12 

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

func (*FindByIDReply) XXX_Size added in v0.1.12 

func (m *FindByIDReply) XXX_Size() int

func (*FindByIDReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*FindByIDRequest) Descriptor added in v0.1.12 

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

func (*FindByIDRequest) GetCollectionName added in v0.1.12 

func (m *FindByIDRequest) GetCollectionName() string

func (*FindByIDRequest) GetDbID added in v0.1.12 

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

func (*FindByIDRequest) GetInstanceID added in v0.1.12 

func (m *FindByIDRequest) GetInstanceID() string

func (*FindByIDRequest) ProtoMessage added in v0.1.12 

func (*FindByIDRequest) ProtoMessage()

func (*FindByIDRequest) Reset added in v0.1.12 

func (m *FindByIDRequest) Reset()

func (*FindByIDRequest) String added in v0.1.12 

func (m *FindByIDRequest) String() string

func (*FindByIDRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *FindByIDRequest) XXX_DiscardUnknown()

func (*FindByIDRequest) XXX_Marshal added in v0.1.12 

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

func (*FindByIDRequest) XXX_Merge added in v0.1.12 

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

func (*FindByIDRequest) XXX_Size added in v0.1.12 

func (m *FindByIDRequest) XXX_Size() int

func (*FindByIDRequest) XXX_Unmarshal added in v0.1.12 

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

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

func (*FindReply) Descriptor added in v0.1.12 

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

func (*FindReply) GetInstances added in v0.1.12 

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

func (*FindReply) GetTransactionError added in v1.0.0 

func (m *FindReply) GetTransactionError() string

func (*FindReply) ProtoMessage added in v0.1.12 

func (*FindReply) ProtoMessage()

func (*FindReply) Reset added in v0.1.12 

func (m *FindReply) Reset()

func (*FindReply) String added in v0.1.12 

func (m *FindReply) String() string

func (*FindReply) XXX_DiscardUnknown added in v0.1.12 

func (m *FindReply) XXX_DiscardUnknown()

func (*FindReply) XXX_Marshal added in v0.1.12 

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

func (*FindReply) XXX_Merge added in v0.1.12 

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

func (*FindReply) XXX_Size added in v0.1.12 

func (m *FindReply) XXX_Size() int

func (*FindReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*FindRequest) Descriptor added in v0.1.12 

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

func (*FindRequest) GetCollectionName added in v0.1.12 

func (m *FindRequest) GetCollectionName() string

func (*FindRequest) GetDbID added in v0.1.12 

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

func (*FindRequest) GetQueryJSON added in v0.1.12 

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

func (*FindRequest) ProtoMessage added in v0.1.12 

func (*FindRequest) ProtoMessage()

func (*FindRequest) Reset added in v0.1.12 

func (m *FindRequest) Reset()

func (*FindRequest) String added in v0.1.12 

func (m *FindRequest) String() string

func (*FindRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *FindRequest) XXX_DiscardUnknown()

func (*FindRequest) XXX_Marshal added in v0.1.12 

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

func (*FindRequest) XXX_Merge added in v0.1.12 

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

func (*FindRequest) XXX_Size added in v0.1.12 

func (m *FindRequest) XXX_Size() int

func (*FindRequest) XXX_Unmarshal added in v0.1.12 

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

type GetCollectionIndexesReply added in v0.1.19 

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 added in v0.1.19 

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

func (*GetCollectionIndexesReply) GetIndexes added in v0.1.19 

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

func (*GetCollectionIndexesReply) ProtoMessage added in v0.1.19 

func (*GetCollectionIndexesReply) ProtoMessage()

func (*GetCollectionIndexesReply) Reset added in v0.1.19 

func (m *GetCollectionIndexesReply) Reset()

func (*GetCollectionIndexesReply) String added in v0.1.19 

func (m *GetCollectionIndexesReply) String() string

func (*GetCollectionIndexesReply) XXX_DiscardUnknown added in v0.1.19 

func (m *GetCollectionIndexesReply) XXX_DiscardUnknown()

func (*GetCollectionIndexesReply) XXX_Marshal added in v0.1.19 

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

func (*GetCollectionIndexesReply) XXX_Merge added in v0.1.19 

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

func (*GetCollectionIndexesReply) XXX_Size added in v0.1.19 

func (m *GetCollectionIndexesReply) XXX_Size() int

func (*GetCollectionIndexesReply) XXX_Unmarshal added in v0.1.19 

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

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

func (*GetCollectionIndexesRequest) Descriptor added in v0.1.19 

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

func (*GetCollectionIndexesRequest) GetDbID added in v0.1.19 

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

func (*GetCollectionIndexesRequest) GetName added in v0.1.19 

func (m *GetCollectionIndexesRequest) GetName() string

func (*GetCollectionIndexesRequest) ProtoMessage added in v0.1.19 

func (*GetCollectionIndexesRequest) ProtoMessage()

func (*GetCollectionIndexesRequest) Reset added in v0.1.19 

func (m *GetCollectionIndexesRequest) Reset()

func (*GetCollectionIndexesRequest) String added in v0.1.19 

func (m *GetCollectionIndexesRequest) String() string

func (*GetCollectionIndexesRequest) XXX_DiscardUnknown added in v0.1.19 

func (m *GetCollectionIndexesRequest) XXX_DiscardUnknown()

func (*GetCollectionIndexesRequest) XXX_Marshal added in v0.1.19 

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

func (*GetCollectionIndexesRequest) XXX_Merge added in v0.1.19 

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

func (*GetCollectionIndexesRequest) XXX_Size added in v0.1.19 

func (m *GetCollectionIndexesRequest) XXX_Size() int

func (*GetCollectionIndexesRequest) XXX_Unmarshal added in v0.1.19 

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

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

func (*GetCollectionInfoReply) Descriptor added in v0.1.22 

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

func (*GetCollectionInfoReply) GetIndexes added in v0.1.22 

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

func (*GetCollectionInfoReply) GetName added in v0.1.22 

func (m *GetCollectionInfoReply) GetName() string

func (*GetCollectionInfoReply) GetReadFilter added in v1.0.0 

func (m *GetCollectionInfoReply) GetReadFilter() string

func (*GetCollectionInfoReply) GetSchema added in v0.1.22 

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

func (*GetCollectionInfoReply) GetWriteValidator added in v1.0.0 

func (m *GetCollectionInfoReply) GetWriteValidator() string

func (*GetCollectionInfoReply) ProtoMessage added in v0.1.22 

func (*GetCollectionInfoReply) ProtoMessage()

func (*GetCollectionInfoReply) Reset added in v0.1.22 

func (m *GetCollectionInfoReply) Reset()

func (*GetCollectionInfoReply) String added in v0.1.22 

func (m *GetCollectionInfoReply) String() string

func (*GetCollectionInfoReply) XXX_DiscardUnknown added in v0.1.22 

func (m *GetCollectionInfoReply) XXX_DiscardUnknown()

func (*GetCollectionInfoReply) XXX_Marshal added in v0.1.22 

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

func (*GetCollectionInfoReply) XXX_Merge added in v0.1.22 

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

func (*GetCollectionInfoReply) XXX_Size added in v0.1.22 

func (m *GetCollectionInfoReply) XXX_Size() int

func (*GetCollectionInfoReply) XXX_Unmarshal added in v0.1.22 

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

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

func (*GetCollectionInfoRequest) Descriptor added in v0.1.22 

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

func (*GetCollectionInfoRequest) GetDbID added in v0.1.22 

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

func (*GetCollectionInfoRequest) GetName added in v0.1.22 

func (m *GetCollectionInfoRequest) GetName() string

func (*GetCollectionInfoRequest) ProtoMessage added in v0.1.22 

func (*GetCollectionInfoRequest) ProtoMessage()

func (*GetCollectionInfoRequest) Reset added in v0.1.22 

func (m *GetCollectionInfoRequest) Reset()

func (*GetCollectionInfoRequest) String added in v0.1.22 

func (m *GetCollectionInfoRequest) String() string

func (*GetCollectionInfoRequest) XXX_DiscardUnknown added in v0.1.22 

func (m *GetCollectionInfoRequest) XXX_DiscardUnknown()

func (*GetCollectionInfoRequest) XXX_Marshal added in v0.1.22 

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

func (*GetCollectionInfoRequest) XXX_Merge added in v0.1.22 

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

func (*GetCollectionInfoRequest) XXX_Size added in v0.1.22 

func (m *GetCollectionInfoRequest) XXX_Size() int

func (*GetCollectionInfoRequest) XXX_Unmarshal added in v0.1.22 

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

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

func (*GetDBInfoReply) Descriptor added in v0.1.12 

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

func (*GetDBInfoReply) GetAddrs added in v0.1.13 

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

func (*GetDBInfoReply) GetKey added in v0.1.13 

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

func (*GetDBInfoReply) GetName added in v0.1.19 

func (m *GetDBInfoReply) GetName() string

func (*GetDBInfoReply) ProtoMessage added in v0.1.12 

func (*GetDBInfoReply) ProtoMessage()

func (*GetDBInfoReply) Reset added in v0.1.12 

func (m *GetDBInfoReply) Reset()

func (*GetDBInfoReply) String added in v0.1.12 

func (m *GetDBInfoReply) String() string

func (*GetDBInfoReply) XXX_DiscardUnknown added in v0.1.12 

func (m *GetDBInfoReply) XXX_DiscardUnknown()

func (*GetDBInfoReply) XXX_Marshal added in v0.1.12 

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

func (*GetDBInfoReply) XXX_Merge added in v0.1.12 

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

func (*GetDBInfoReply) XXX_Size added in v0.1.12 

func (m *GetDBInfoReply) XXX_Size() int

func (*GetDBInfoReply) XXX_Unmarshal added in v0.1.12 

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

type GetDBInfoRequest added in v0.1.12 

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 added in v0.1.12 

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

func (*GetDBInfoRequest) GetDbID added in v0.1.12 

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

func (*GetDBInfoRequest) ProtoMessage added in v0.1.12 

func (*GetDBInfoRequest) ProtoMessage()

func (*GetDBInfoRequest) Reset added in v0.1.12 

func (m *GetDBInfoRequest) Reset()

func (*GetDBInfoRequest) String added in v0.1.12 

func (m *GetDBInfoRequest) String() string

func (*GetDBInfoRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *GetDBInfoRequest) XXX_DiscardUnknown()

func (*GetDBInfoRequest) XXX_Marshal added in v0.1.12 

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

func (*GetDBInfoRequest) XXX_Merge added in v0.1.12 

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

func (*GetDBInfoRequest) XXX_Size added in v0.1.12 

func (m *GetDBInfoRequest) XXX_Size() int

func (*GetDBInfoRequest) XXX_Unmarshal added in v0.1.12 

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

type GetTokenReply added in v0.1.13 

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 added in v0.1.13 

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

func (*GetTokenReply) GetChallenge added in v0.1.13 

func (m *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 (m *GetTokenReply) GetToken() string

func (*GetTokenReply) ProtoMessage added in v0.1.13 

func (*GetTokenReply) ProtoMessage()

func (*GetTokenReply) Reset added in v0.1.13 

func (m *GetTokenReply) Reset()

func (*GetTokenReply) String added in v0.1.13 

func (m *GetTokenReply) String() string

func (*GetTokenReply) XXX_DiscardUnknown added in v0.1.13 

func (m *GetTokenReply) XXX_DiscardUnknown()

func (*GetTokenReply) XXX_Marshal added in v0.1.13 

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

func (*GetTokenReply) XXX_Merge added in v0.1.13 

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

func (*GetTokenReply) XXX_OneofWrappers added in v0.1.13 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenReply) XXX_Size added in v0.1.13 

func (m *GetTokenReply) XXX_Size() int

func (*GetTokenReply) XXX_Unmarshal added in v0.1.13 

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

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 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 added in v0.1.13 

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

func (*GetTokenRequest) GetKey added in v0.1.13 

func (m *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 (m *GetTokenRequest) GetSignature() []byte

func (*GetTokenRequest) ProtoMessage added in v0.1.13 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) Reset added in v0.1.13 

func (m *GetTokenRequest) Reset()

func (*GetTokenRequest) String added in v0.1.13 

func (m *GetTokenRequest) String() string

func (*GetTokenRequest) XXX_DiscardUnknown added in v0.1.13 

func (m *GetTokenRequest) XXX_DiscardUnknown()

func (*GetTokenRequest) XXX_Marshal added in v0.1.13 

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

func (*GetTokenRequest) XXX_Merge added in v0.1.13 

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

func (*GetTokenRequest) XXX_OneofWrappers added in v0.1.13 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenRequest) XXX_Size added in v0.1.13 

func (m *GetTokenRequest) XXX_Size() int

func (*GetTokenRequest) XXX_Unmarshal added in v0.1.13 

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

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

func (*HasReply) Descriptor added in v0.1.12 

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

func (*HasReply) GetExists added in v0.1.12 

func (m *HasReply) GetExists() bool

func (*HasReply) GetTransactionError added in v1.0.0 

func (m *HasReply) GetTransactionError() string

func (*HasReply) ProtoMessage added in v0.1.12 

func (*HasReply) ProtoMessage()

func (*HasReply) Reset added in v0.1.12 

func (m *HasReply) Reset()

func (*HasReply) String added in v0.1.12 

func (m *HasReply) String() string

func (*HasReply) XXX_DiscardUnknown added in v0.1.12 

func (m *HasReply) XXX_DiscardUnknown()

func (*HasReply) XXX_Marshal added in v0.1.12 

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

func (*HasReply) XXX_Merge added in v0.1.12 

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

func (*HasReply) XXX_Size added in v0.1.12 

func (m *HasReply) XXX_Size() int

func (*HasReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*HasRequest) Descriptor added in v0.1.12 

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

func (*HasRequest) GetCollectionName added in v0.1.12 

func (m *HasRequest) GetCollectionName() string

func (*HasRequest) GetDbID added in v0.1.12 

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

func (*HasRequest) GetInstanceIDs added in v0.1.12 

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

func (*HasRequest) ProtoMessage added in v0.1.12 

func (*HasRequest) ProtoMessage()

func (*HasRequest) Reset added in v0.1.12 

func (m *HasRequest) Reset()

func (*HasRequest) String added in v0.1.12 

func (m *HasRequest) String() string

func (*HasRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *HasRequest) XXX_DiscardUnknown()

func (*HasRequest) XXX_Marshal added in v0.1.12 

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

func (*HasRequest) XXX_Merge added in v0.1.12 

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

func (*HasRequest) XXX_Size added in v0.1.12 

func (m *HasRequest) XXX_Size() int

func (*HasRequest) XXX_Unmarshal added in v0.1.12 

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

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

func (*Index) Descriptor added in v0.1.19 

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

func (*Index) GetPath added in v0.1.19 

func (m *Index) GetPath() string

func (*Index) GetUnique added in v0.1.19 

func (m *Index) GetUnique() bool

func (*Index) ProtoMessage added in v0.1.19 

func (*Index) ProtoMessage()

func (*Index) Reset added in v0.1.19 

func (m *Index) Reset()

func (*Index) String added in v0.1.19 

func (m *Index) String() string

func (*Index) XXX_DiscardUnknown added in v0.1.19 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal added in v0.1.19 

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

func (*Index) XXX_Merge added in v0.1.19 

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

func (*Index) XXX_Size added in v0.1.19 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal added in v0.1.19 

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

type ListCollectionsReply added in v0.1.22 

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 added in v0.1.22 

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

func (*ListCollectionsReply) GetCollections added in v0.1.22 

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

func (*ListCollectionsReply) ProtoMessage added in v0.1.22 

func (*ListCollectionsReply) ProtoMessage()

func (*ListCollectionsReply) Reset added in v0.1.22 

func (m *ListCollectionsReply) Reset()

func (*ListCollectionsReply) String added in v0.1.22 

func (m *ListCollectionsReply) String() string

func (*ListCollectionsReply) XXX_DiscardUnknown added in v0.1.22 

func (m *ListCollectionsReply) XXX_DiscardUnknown()

func (*ListCollectionsReply) XXX_Marshal added in v0.1.22 

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

func (*ListCollectionsReply) XXX_Merge added in v0.1.22 

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

func (*ListCollectionsReply) XXX_Size added in v0.1.22 

func (m *ListCollectionsReply) XXX_Size() int

func (*ListCollectionsReply) XXX_Unmarshal added in v0.1.22 

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

type ListCollectionsRequest added in v0.1.22 

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 added in v0.1.22 

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

func (*ListCollectionsRequest) GetDbID added in v0.1.22 

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

func (*ListCollectionsRequest) ProtoMessage added in v0.1.22 

func (*ListCollectionsRequest) ProtoMessage()

func (*ListCollectionsRequest) Reset added in v0.1.22 

func (m *ListCollectionsRequest) Reset()

func (*ListCollectionsRequest) String added in v0.1.22 

func (m *ListCollectionsRequest) String() string

func (*ListCollectionsRequest) XXX_DiscardUnknown added in v0.1.22 

func (m *ListCollectionsRequest) XXX_DiscardUnknown()

func (*ListCollectionsRequest) XXX_Marshal added in v0.1.22 

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

func (*ListCollectionsRequest) XXX_Merge added in v0.1.22 

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

func (*ListCollectionsRequest) XXX_Size added in v0.1.22 

func (m *ListCollectionsRequest) XXX_Size() int

func (*ListCollectionsRequest) XXX_Unmarshal added in v0.1.22 

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

type ListDBsReply added in v0.1.19 

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 added in v0.1.19 

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

func (*ListDBsReply) GetDbs added in v0.1.19 

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

func (*ListDBsReply) ProtoMessage added in v0.1.19 

func (*ListDBsReply) ProtoMessage()

func (*ListDBsReply) Reset added in v0.1.19 

func (m *ListDBsReply) Reset()

func (*ListDBsReply) String added in v0.1.19 

func (m *ListDBsReply) String() string

func (*ListDBsReply) XXX_DiscardUnknown added in v0.1.19 

func (m *ListDBsReply) XXX_DiscardUnknown()

func (*ListDBsReply) XXX_Marshal added in v0.1.19 

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

func (*ListDBsReply) XXX_Merge added in v0.1.19 

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

func (*ListDBsReply) XXX_Size added in v0.1.19 

func (m *ListDBsReply) XXX_Size() int

func (*ListDBsReply) XXX_Unmarshal added in v0.1.19 

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

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

func (*ListDBsReply_DB) Descriptor added in v0.1.19 

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

func (*ListDBsReply_DB) GetDbID added in v0.1.19 

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

func (*ListDBsReply_DB) GetInfo added in v0.1.19 

func (m *ListDBsReply_DB) GetInfo() *GetDBInfoReply

func (*ListDBsReply_DB) ProtoMessage added in v0.1.19 

func (*ListDBsReply_DB) ProtoMessage()

func (*ListDBsReply_DB) Reset added in v0.1.19 

func (m *ListDBsReply_DB) Reset()

func (*ListDBsReply_DB) String added in v0.1.19 

func (m *ListDBsReply_DB) String() string

func (*ListDBsReply_DB) XXX_DiscardUnknown added in v0.1.19 

func (m *ListDBsReply_DB) XXX_DiscardUnknown()

func (*ListDBsReply_DB) XXX_Marshal added in v0.1.19 

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

func (*ListDBsReply_DB) XXX_Merge added in v0.1.19 

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

func (*ListDBsReply_DB) XXX_Size added in v0.1.19 

func (m *ListDBsReply_DB) XXX_Size() int

func (*ListDBsReply_DB) XXX_Unmarshal added in v0.1.19 

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

type ListDBsRequest added in v0.1.19 

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

func (*ListDBsRequest) Descriptor added in v0.1.19 

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

func (*ListDBsRequest) ProtoMessage added in v0.1.19 

func (*ListDBsRequest) ProtoMessage()

func (*ListDBsRequest) Reset added in v0.1.19 

func (m *ListDBsRequest) Reset()

func (*ListDBsRequest) String added in v0.1.19 

func (m *ListDBsRequest) String() string

func (*ListDBsRequest) XXX_DiscardUnknown added in v0.1.19 

func (m *ListDBsRequest) XXX_DiscardUnknown()

func (*ListDBsRequest) XXX_Marshal added in v0.1.19 

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

func (*ListDBsRequest) XXX_Merge added in v0.1.19 

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

func (*ListDBsRequest) XXX_Size added in v0.1.19 

func (m *ListDBsRequest) XXX_Size() int

func (*ListDBsRequest) XXX_Unmarshal added in v0.1.19 

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 added in v0.1.12 

func (m *ListenReply) GetCollectionName() string

func (*ListenReply) GetInstance added in v0.1.12 

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

func (*ListenReply) GetInstanceID added in v0.1.12 

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 added in v0.1.12 

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 added in v0.1.12 

func (m *ListenRequest_Filter) GetCollectionName() string

func (*ListenRequest_Filter) GetInstanceID added in v0.1.12 

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 added in v0.1.12 

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

func (*NewCollectionReply) Descriptor added in v0.1.12 

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

func (*NewCollectionReply) ProtoMessage added in v0.1.12 

func (*NewCollectionReply) ProtoMessage()

func (*NewCollectionReply) Reset added in v0.1.12 

func (m *NewCollectionReply) Reset()

func (*NewCollectionReply) String added in v0.1.12 

func (m *NewCollectionReply) String() string

func (*NewCollectionReply) XXX_DiscardUnknown added in v0.1.12 

func (m *NewCollectionReply) XXX_DiscardUnknown()

func (*NewCollectionReply) XXX_Marshal added in v0.1.12 

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

func (*NewCollectionReply) XXX_Merge added in v0.1.12 

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

func (*NewCollectionReply) XXX_Size added in v0.1.12 

func (m *NewCollectionReply) XXX_Size() int

func (*NewCollectionReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*NewCollectionRequest) Descriptor added in v0.1.12 

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

func (*NewCollectionRequest) GetConfig added in v0.1.12 

func (m *NewCollectionRequest) GetConfig() *CollectionConfig

func (*NewCollectionRequest) GetDbID added in v0.1.12 

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

func (*NewCollectionRequest) ProtoMessage added in v0.1.12 

func (*NewCollectionRequest) ProtoMessage()

func (*NewCollectionRequest) Reset added in v0.1.12 

func (m *NewCollectionRequest) Reset()

func (*NewCollectionRequest) String added in v0.1.12 

func (m *NewCollectionRequest) String() string

func (*NewCollectionRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *NewCollectionRequest) XXX_DiscardUnknown()

func (*NewCollectionRequest) XXX_Marshal added in v0.1.12 

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

func (*NewCollectionRequest) XXX_Merge added in v0.1.12 

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

func (*NewCollectionRequest) XXX_Size added in v0.1.12 

func (m *NewCollectionRequest) XXX_Size() int

func (*NewCollectionRequest) XXX_Unmarshal added in v0.1.12 

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

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"`
	ThreadKey            []byte              `protobuf:"bytes,6,opt,name=threadKey,proto3" json:"threadKey,omitempty"` // Deprecated: Do not use.
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

@todo: Clean up tag numbers with next major release

func (*NewDBFromAddrRequest) Descriptor added in v0.1.12 

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

func (*NewDBFromAddrRequest) GetAddr added in v0.1.13 

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

func (*NewDBFromAddrRequest) GetBlock added in v0.1.22 

func (m *NewDBFromAddrRequest) GetBlock() bool

func (*NewDBFromAddrRequest) GetCollections added in v0.1.12 

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

func (*NewDBFromAddrRequest) GetKey added in v0.1.13 

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

func (*NewDBFromAddrRequest) GetLogKey added in v1.0.1 

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

func (*NewDBFromAddrRequest) GetName added in v0.1.19 

func (m *NewDBFromAddrRequest) GetName() string

func (*NewDBFromAddrRequest) GetThreadKey deprecated added in v1.0.1 

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

Deprecated: Do not use.

func (*NewDBFromAddrRequest) ProtoMessage added in v0.1.12 

func (*NewDBFromAddrRequest) ProtoMessage()

func (*NewDBFromAddrRequest) Reset added in v0.1.12 

func (m *NewDBFromAddrRequest) Reset()

func (*NewDBFromAddrRequest) String added in v0.1.12 

func (m *NewDBFromAddrRequest) String() string

func (*NewDBFromAddrRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *NewDBFromAddrRequest) XXX_DiscardUnknown()

func (*NewDBFromAddrRequest) XXX_Marshal added in v0.1.12 

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

func (*NewDBFromAddrRequest) XXX_Merge added in v0.1.12 

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

func (*NewDBFromAddrRequest) XXX_Size added in v0.1.12 

func (m *NewDBFromAddrRequest) XXX_Size() int

func (*NewDBFromAddrRequest) XXX_Unmarshal added in v0.1.12 

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

type NewDBReply added in v0.1.12 

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

func (*NewDBReply) Descriptor added in v0.1.12 

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

func (*NewDBReply) ProtoMessage added in v0.1.12 

func (*NewDBReply) ProtoMessage()

func (*NewDBReply) Reset added in v0.1.12 

func (m *NewDBReply) Reset()

func (*NewDBReply) String added in v0.1.12 

func (m *NewDBReply) String() string

func (*NewDBReply) XXX_DiscardUnknown added in v0.1.12 

func (m *NewDBReply) XXX_DiscardUnknown()

func (*NewDBReply) XXX_Marshal added in v0.1.12 

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

func (*NewDBReply) XXX_Merge added in v0.1.12 

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

func (*NewDBReply) XXX_Size added in v0.1.12 

func (m *NewDBReply) XXX_Size() int

func (*NewDBReply) XXX_Unmarshal added in v0.1.12 

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

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"`
	Block                bool                `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"` // Deprecated: Do not use.
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

@todo: Clean up tag numbers with next major release

func (*NewDBRequest) Descriptor added in v0.1.12 

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

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

func (m *NewDBRequest) GetBlock() bool

Deprecated: Do not use.

func (*NewDBRequest) GetCollections added in v0.1.13 

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

func (*NewDBRequest) GetDbID added in v0.1.12 

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

func (*NewDBRequest) GetKey added in v1.0.2 

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

func (*NewDBRequest) GetLogKey added in v1.0.1 

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

func (*NewDBRequest) GetName added in v0.1.19 

func (m *NewDBRequest) GetName() string

func (*NewDBRequest) ProtoMessage added in v0.1.12 

func (*NewDBRequest) ProtoMessage()

func (*NewDBRequest) Reset added in v0.1.12 

func (m *NewDBRequest) Reset()

func (*NewDBRequest) String added in v0.1.12 

func (m *NewDBRequest) String() string

func (*NewDBRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *NewDBRequest) XXX_DiscardUnknown()

func (*NewDBRequest) XXX_Marshal added in v0.1.12 

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

func (*NewDBRequest) XXX_Merge added in v0.1.12 

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

func (*NewDBRequest) XXX_Size added in v0.1.12 

func (m *NewDBRequest) XXX_Size() int

func (*NewDBRequest) XXX_Unmarshal added in v0.1.12 

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 added in v0.1.12 

func (m *ReadTransactionReply) GetFindByIDReply() *FindByIDReply

func (*ReadTransactionReply) GetFindReply added in v0.1.12 

func (m *ReadTransactionReply) GetFindReply() *FindReply

func (*ReadTransactionReply) GetHasReply added in v0.1.12 

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 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 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 added in v0.1.12 

func (m *ReadTransactionRequest) GetFindByIDRequest() *FindByIDRequest

func (*ReadTransactionRequest) GetFindRequest added in v0.1.12 

func (m *ReadTransactionRequest) GetFindRequest() *FindRequest

func (*ReadTransactionRequest) GetHasRequest added in v0.1.12 

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

func (*SaveReply) Descriptor added in v0.1.12 

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

func (*SaveReply) GetTransactionError added in v1.0.0 

func (m *SaveReply) GetTransactionError() string

func (*SaveReply) ProtoMessage added in v0.1.12 

func (*SaveReply) ProtoMessage()

func (*SaveReply) Reset added in v0.1.12 

func (m *SaveReply) Reset()

func (*SaveReply) String added in v0.1.12 

func (m *SaveReply) String() string

func (*SaveReply) XXX_DiscardUnknown added in v0.1.12 

func (m *SaveReply) XXX_DiscardUnknown()

func (*SaveReply) XXX_Marshal added in v0.1.12 

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

func (*SaveReply) XXX_Merge added in v0.1.12 

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

func (*SaveReply) XXX_Size added in v0.1.12 

func (m *SaveReply) XXX_Size() int

func (*SaveReply) XXX_Unmarshal added in v0.1.12 

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

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

func (*SaveRequest) Descriptor added in v0.1.12 

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

func (*SaveRequest) GetCollectionName added in v0.1.12 

func (m *SaveRequest) GetCollectionName() string

func (*SaveRequest) GetDbID added in v0.1.12 

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

func (*SaveRequest) GetInstances added in v0.1.13 

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

func (*SaveRequest) ProtoMessage added in v0.1.12 

func (*SaveRequest) ProtoMessage()

func (*SaveRequest) Reset added in v0.1.12 

func (m *SaveRequest) Reset()

func (*SaveRequest) String added in v0.1.12 

func (m *SaveRequest) String() string

func (*SaveRequest) XXX_DiscardUnknown added in v0.1.12 

func (m *SaveRequest) XXX_DiscardUnknown()

func (*SaveRequest) XXX_Marshal added in v0.1.12 

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

func (*SaveRequest) XXX_Merge added in v0.1.12 

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

func (*SaveRequest) XXX_Size added in v0.1.12 

func (m *SaveRequest) XXX_Size() int

func (*SaveRequest) XXX_Unmarshal added in v0.1.12 

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 added in v0.1.12 

func (m *StartTransactionRequest) GetCollectionName() string

func (*StartTransactionRequest) GetDbID added in v0.1.12 

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 added in v0.1.12 

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

func (*UnimplementedAPIServer) Delete added in v0.1.12 

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

func (*UnimplementedAPIServer) DeleteCollection added in v0.1.19 

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

func (*UnimplementedAPIServer) DeleteDB added in v0.1.15 

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

func (*UnimplementedAPIServer) Find added in v0.1.12 

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

func (*UnimplementedAPIServer) FindByID added in v0.1.12 

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

func (*UnimplementedAPIServer) GetCollectionIndexes added in v0.1.19 

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

func (*UnimplementedAPIServer) GetCollectionInfo added in v0.1.22 

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

func (*UnimplementedAPIServer) GetDBInfo added in v0.1.12 

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

func (*UnimplementedAPIServer) GetToken added in v0.1.13 

func (*UnimplementedAPIServer) GetToken(srv API_GetTokenServer) error

func (*UnimplementedAPIServer) Has added in v0.1.12 

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

func (*UnimplementedAPIServer) ListCollections added in v0.1.22 

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

func (*UnimplementedAPIServer) ListDBs added in v0.1.19 

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 added in v0.1.12 

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

func (*UnimplementedAPIServer) NewDB added in v0.1.12 

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

func (*UnimplementedAPIServer) NewDBFromAddr added in v0.1.12 

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

func (*UnimplementedAPIServer) ReadTransaction 

func (*UnimplementedAPIServer) ReadTransaction(srv API_ReadTransactionServer) error

func (*UnimplementedAPIServer) Save added in v0.1.12 

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

func (*UnimplementedAPIServer) UpdateCollection added in v0.1.19 

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

func (*UnimplementedAPIServer) Verify added in v1.0.0 

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

func (*UnimplementedAPIServer) WriteTransaction 

func (*UnimplementedAPIServer) WriteTransaction(srv API_WriteTransactionServer) error

type UpdateCollectionReply added in v0.1.19 

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

func (*UpdateCollectionReply) Descriptor added in v0.1.19 

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

func (*UpdateCollectionReply) ProtoMessage added in v0.1.19 

func (*UpdateCollectionReply) ProtoMessage()

func (*UpdateCollectionReply) Reset added in v0.1.19 

func (m *UpdateCollectionReply) Reset()

func (*UpdateCollectionReply) String added in v0.1.19 

func (m *UpdateCollectionReply) String() string

func (*UpdateCollectionReply) XXX_DiscardUnknown added in v0.1.19 

func (m *UpdateCollectionReply) XXX_DiscardUnknown()

func (*UpdateCollectionReply) XXX_Marshal added in v0.1.19 

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

func (*UpdateCollectionReply) XXX_Merge added in v0.1.19 

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

func (*UpdateCollectionReply) XXX_Size added in v0.1.19 

func (m *UpdateCollectionReply) XXX_Size() int

func (*UpdateCollectionReply) XXX_Unmarshal added in v0.1.19 

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

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

func (*UpdateCollectionRequest) Descriptor added in v0.1.19 

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

func (*UpdateCollectionRequest) GetConfig added in v0.1.19 

func (m *UpdateCollectionRequest) GetConfig() *CollectionConfig

func (*UpdateCollectionRequest) GetDbID added in v0.1.19 

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

func (*UpdateCollectionRequest) ProtoMessage added in v0.1.19 

func (*UpdateCollectionRequest) ProtoMessage()

func (*UpdateCollectionRequest) Reset added in v0.1.19 

func (m *UpdateCollectionRequest) Reset()

func (*UpdateCollectionRequest) String added in v0.1.19 

func (m *UpdateCollectionRequest) String() string

func (*UpdateCollectionRequest) XXX_DiscardUnknown added in v0.1.19 

func (m *UpdateCollectionRequest) XXX_DiscardUnknown()

func (*UpdateCollectionRequest) XXX_Marshal added in v0.1.19 

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

func (*UpdateCollectionRequest) XXX_Merge added in v0.1.19 

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

func (*UpdateCollectionRequest) XXX_Size added in v0.1.19 

func (m *UpdateCollectionRequest) XXX_Size() int

func (*UpdateCollectionRequest) XXX_Unmarshal added in v0.1.19 

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

type VerifyReply added in v1.0.0 

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

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

func (*VerifyReply) GetTransactionError added in v1.0.0 

func (m *VerifyReply) GetTransactionError() string

func (*VerifyReply) ProtoMessage added in v1.0.0 

func (*VerifyReply) ProtoMessage()

func (*VerifyReply) Reset added in v1.0.0 

func (m *VerifyReply) Reset()

func (*VerifyReply) String added in v1.0.0 

func (m *VerifyReply) String() string

func (*VerifyReply) XXX_DiscardUnknown added in v1.0.0 

func (m *VerifyReply) XXX_DiscardUnknown()

func (*VerifyReply) XXX_Marshal added in v1.0.0 

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

func (*VerifyReply) XXX_Merge added in v1.0.0 

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

func (*VerifyReply) XXX_Size added in v1.0.0 

func (m *VerifyReply) XXX_Size() int

func (*VerifyReply) XXX_Unmarshal added in v1.0.0 

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

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

func (*VerifyRequest) Descriptor added in v1.0.0 

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

func (*VerifyRequest) GetCollectionName added in v1.0.0 

func (m *VerifyRequest) GetCollectionName() string

func (*VerifyRequest) GetDbID added in v1.0.0 

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

func (*VerifyRequest) GetInstances added in v1.0.0 

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

func (*VerifyRequest) ProtoMessage added in v1.0.0 

func (*VerifyRequest) ProtoMessage()

func (*VerifyRequest) Reset added in v1.0.0 

func (m *VerifyRequest) Reset()

func (*VerifyRequest) String added in v1.0.0 

func (m *VerifyRequest) String() string

func (*VerifyRequest) XXX_DiscardUnknown added in v1.0.0 

func (m *VerifyRequest) XXX_DiscardUnknown()

func (*VerifyRequest) XXX_Marshal added in v1.0.0 

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

func (*VerifyRequest) XXX_Merge added in v1.0.0 

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

func (*VerifyRequest) XXX_Size added in v1.0.0 

func (m *VerifyRequest) XXX_Size() int

func (*VerifyRequest) XXX_Unmarshal added in v1.0.0 

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 added in v0.1.12 

func (m *WriteTransactionReply) GetCreateReply() *CreateReply

func (*WriteTransactionReply) GetDeleteReply added in v0.1.12 

func (m *WriteTransactionReply) GetDeleteReply() *DeleteReply

func (*WriteTransactionReply) GetDiscardReply added in v1.0.0 

func (m *WriteTransactionReply) GetDiscardReply() *DiscardReply

func (*WriteTransactionReply) GetFindByIDReply added in v0.1.12 

func (m *WriteTransactionReply) GetFindByIDReply() *FindByIDReply

func (*WriteTransactionReply) GetFindReply added in v0.1.12 

func (m *WriteTransactionReply) GetFindReply() *FindReply

func (*WriteTransactionReply) GetHasReply added in v0.1.12 

func (m *WriteTransactionReply) GetHasReply() *HasReply

func (*WriteTransactionReply) GetOption 

func (m *WriteTransactionReply) GetOption() isWriteTransactionReply_Option

func (*WriteTransactionReply) GetSaveReply added in v0.1.12 

func (m *WriteTransactionReply) GetSaveReply() *SaveReply

func (*WriteTransactionReply) GetVerifyReply added in v1.0.0 

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 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 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 added in v0.1.12 

func (m *WriteTransactionRequest) GetCreateRequest() *CreateRequest

func (*WriteTransactionRequest) GetDeleteRequest added in v0.1.12 

func (m *WriteTransactionRequest) GetDeleteRequest() *DeleteRequest

func (*WriteTransactionRequest) GetDiscardRequest added in v1.0.0 

func (m *WriteTransactionRequest) GetDiscardRequest() *DiscardRequest

func (*WriteTransactionRequest) GetFindByIDRequest added in v0.1.12 

func (m *WriteTransactionRequest) GetFindByIDRequest() *FindByIDRequest

func (*WriteTransactionRequest) GetFindRequest added in v0.1.12 

func (m *WriteTransactionRequest) GetFindRequest() *FindRequest

func (*WriteTransactionRequest) GetHasRequest added in v0.1.12 

func (m *WriteTransactionRequest) GetHasRequest() *HasRequest

func (*WriteTransactionRequest) GetOption 

func (m *WriteTransactionRequest) GetOption() isWriteTransactionRequest_Option

func (*WriteTransactionRequest) GetSaveRequest added in v0.1.12 

func (m *WriteTransactionRequest) GetSaveRequest() *SaveRequest

func (*WriteTransactionRequest) GetStartTransactionRequest 

func (m *WriteTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest

func (*WriteTransactionRequest) GetVerifyRequest added in v1.0.0 

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