api_pb

package
v0.1.11-rc2 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 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 {
	NewDB(ctx context.Context, in *NewDBRequest, opts ...grpc.CallOption) (*NewDBReply, error)
	NewCollection(ctx context.Context, in *NewCollectionRequest, opts ...grpc.CallOption) (*NewCollectionReply, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error)
	StartFromAddress(ctx context.Context, in *StartFromAddressRequest, opts ...grpc.CallOption) (*StartFromAddressReply, error)
	GetDBLink(ctx context.Context, in *GetDBLinkRequest, opts ...grpc.CallOption) (*GetDBLinkReply, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, 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 {
	NewDB(context.Context, *NewDBRequest) (*NewDBReply, error)
	NewCollection(context.Context, *NewCollectionRequest) (*NewCollectionReply, error)
	Start(context.Context, *StartRequest) (*StartReply, error)
	StartFromAddress(context.Context, *StartFromAddressRequest) (*StartFromAddressReply, error)
	GetDBLink(context.Context, *GetDBLinkRequest) (*GetDBLinkReply, error)
	Create(context.Context, *CreateRequest) (*CreateReply, 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_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 CreateReply added in v0.1.12 

type CreateReply struct {
	Instances            []string `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,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) GetInstances added in v0.1.12 

func (m *CreateReply) GetInstances() []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                 string   `protobuf:"bytes,1,opt,name=DBID,proto3" json:"DBID,omitempty"`
	CollectionName       string   `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,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 

func (m *CreateRequest) GetDBID() string

func (*CreateRequest) GetValues added in v0.1.12 

func (m *CreateRequest) GetValues() []string

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

type DeleteReply struct {
	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) 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                 string   `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 

func (m *DeleteRequest) GetDBID() string

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

type FindByIDReply struct {
	Instance             string   `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,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() 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                 string   `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 

func (m *FindByIDRequest) GetDBID() string

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"`
	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) 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                 string   `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 

func (m *FindRequest) GetDBID() string

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 GetDBLinkReply 

type GetDBLinkReply struct {
	Addresses            []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	FollowKey            []byte   `protobuf:"bytes,2,opt,name=followKey,proto3" json:"followKey,omitempty"`
	ReadKey              []byte   `protobuf:"bytes,3,opt,name=readKey,proto3" json:"readKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDBLinkReply) Descriptor 

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

func (*GetDBLinkReply) GetAddresses 

func (m *GetDBLinkReply) GetAddresses() []string

func (*GetDBLinkReply) GetFollowKey 

func (m *GetDBLinkReply) GetFollowKey() []byte

func (*GetDBLinkReply) GetReadKey 

func (m *GetDBLinkReply) GetReadKey() []byte

func (*GetDBLinkReply) ProtoMessage 

func (*GetDBLinkReply) ProtoMessage()

func (*GetDBLinkReply) Reset 

func (m *GetDBLinkReply) Reset()

func (*GetDBLinkReply) String 

func (m *GetDBLinkReply) String() string

func (*GetDBLinkReply) XXX_DiscardUnknown 

func (m *GetDBLinkReply) XXX_DiscardUnknown()

func (*GetDBLinkReply) XXX_Marshal 

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

func (*GetDBLinkReply) XXX_Merge 

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

func (*GetDBLinkReply) XXX_Size 

func (m *GetDBLinkReply) XXX_Size() int

func (*GetDBLinkReply) XXX_Unmarshal 

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

type GetDBLinkRequest 

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

func (*GetDBLinkRequest) Descriptor 

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

func (*GetDBLinkRequest) GetDBID 

func (m *GetDBLinkRequest) GetDBID() string

func (*GetDBLinkRequest) ProtoMessage 

func (*GetDBLinkRequest) ProtoMessage()

func (*GetDBLinkRequest) Reset 

func (m *GetDBLinkRequest) Reset()

func (*GetDBLinkRequest) String 

func (m *GetDBLinkRequest) String() string

func (*GetDBLinkRequest) XXX_DiscardUnknown 

func (m *GetDBLinkRequest) XXX_DiscardUnknown()

func (*GetDBLinkRequest) XXX_Marshal 

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

func (*GetDBLinkRequest) XXX_Merge 

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

func (*GetDBLinkRequest) XXX_Size 

func (m *GetDBLinkRequest) XXX_Size() int

func (*GetDBLinkRequest) XXX_Unmarshal 

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

type HasReply added in v0.1.12 

type HasReply struct {
	Exists               bool     `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,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) 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                 string   `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 

func (m *HasRequest) GetDBID() string

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 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=api.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                 string                  `protobuf:"bytes,1,opt,name=DBID,proto3" json:"DBID,omitempty"`
	Filters              []*ListenRequest_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetDBID 

func (m *ListenRequest) GetDBID() string

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=api.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                 string                              `protobuf:"bytes,1,opt,name=DBID,proto3" json:"DBID,omitempty"`
	Name                 string                              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Schema               string                              `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Indexes              []*NewCollectionRequest_IndexConfig `protobuf:"bytes,4,rep,name=indexes,proto3" json:"indexes,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) GetDBID 

func (m *NewCollectionRequest) GetDBID() string

func (*NewCollectionRequest) GetIndexes 

func (m *NewCollectionRequest) GetIndexes() []*NewCollectionRequest_IndexConfig

func (*NewCollectionRequest) GetName 

func (m *NewCollectionRequest) GetName() string

func (*NewCollectionRequest) GetSchema 

func (m *NewCollectionRequest) GetSchema() string

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 NewCollectionRequest_IndexConfig 

type NewCollectionRequest_IndexConfig 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 (*NewCollectionRequest_IndexConfig) Descriptor 

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

func (*NewCollectionRequest_IndexConfig) GetPath 

func (m *NewCollectionRequest_IndexConfig) GetPath() string

func (*NewCollectionRequest_IndexConfig) GetUnique 

func (m *NewCollectionRequest_IndexConfig) GetUnique() bool

func (*NewCollectionRequest_IndexConfig) ProtoMessage 

func (*NewCollectionRequest_IndexConfig) ProtoMessage()

func (*NewCollectionRequest_IndexConfig) Reset 

func (m *NewCollectionRequest_IndexConfig) Reset()

func (*NewCollectionRequest_IndexConfig) String 

func (m *NewCollectionRequest_IndexConfig) String() string

func (*NewCollectionRequest_IndexConfig) XXX_DiscardUnknown 

func (m *NewCollectionRequest_IndexConfig) XXX_DiscardUnknown()

func (*NewCollectionRequest_IndexConfig) XXX_Marshal 

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

func (*NewCollectionRequest_IndexConfig) XXX_Merge 

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

func (*NewCollectionRequest_IndexConfig) XXX_Size 

func (m *NewCollectionRequest_IndexConfig) XXX_Size() int

func (*NewCollectionRequest_IndexConfig) XXX_Unmarshal 

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

type NewDBReply added in v0.1.12 

type NewDBReply struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	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) GetID 

func (m *NewDBReply) GetID() string

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

func (*NewDBRequest) Descriptor added in v0.1.12 

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

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 {
	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) 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                 string   `protobuf:"bytes,1,opt,name=DBID,proto3" json:"DBID,omitempty"`
	CollectionName       string   `protobuf:"bytes,2,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,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 

func (m *SaveRequest) GetDBID() string

func (*SaveRequest) GetValues added in v0.1.12 

func (m *SaveRequest) GetValues() []string

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 StartFromAddressReply 

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

func (*StartFromAddressReply) Descriptor 

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

func (*StartFromAddressReply) ProtoMessage 

func (*StartFromAddressReply) ProtoMessage()

func (*StartFromAddressReply) Reset 

func (m *StartFromAddressReply) Reset()

func (*StartFromAddressReply) String 

func (m *StartFromAddressReply) String() string

func (*StartFromAddressReply) XXX_DiscardUnknown 

func (m *StartFromAddressReply) XXX_DiscardUnknown()

func (*StartFromAddressReply) XXX_Marshal 

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

func (*StartFromAddressReply) XXX_Merge 

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

func (*StartFromAddressReply) XXX_Size 

func (m *StartFromAddressReply) XXX_Size() int

func (*StartFromAddressReply) XXX_Unmarshal 

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

type StartFromAddressRequest 

type StartFromAddressRequest struct {
	DBID                 string   `protobuf:"bytes,1,opt,name=DBID,proto3" json:"DBID,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	FollowKey            []byte   `protobuf:"bytes,3,opt,name=followKey,proto3" json:"followKey,omitempty"`
	ReadKey              []byte   `protobuf:"bytes,4,opt,name=readKey,proto3" json:"readKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartFromAddressRequest) Descriptor 

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

func (*StartFromAddressRequest) GetAddress 

func (m *StartFromAddressRequest) GetAddress() string

func (*StartFromAddressRequest) GetDBID 

func (m *StartFromAddressRequest) GetDBID() string

func (*StartFromAddressRequest) GetFollowKey 

func (m *StartFromAddressRequest) GetFollowKey() []byte

func (*StartFromAddressRequest) GetReadKey 

func (m *StartFromAddressRequest) GetReadKey() []byte

func (*StartFromAddressRequest) ProtoMessage 

func (*StartFromAddressRequest) ProtoMessage()

func (*StartFromAddressRequest) Reset 

func (m *StartFromAddressRequest) Reset()

func (*StartFromAddressRequest) String 

func (m *StartFromAddressRequest) String() string

func (*StartFromAddressRequest) XXX_DiscardUnknown 

func (m *StartFromAddressRequest) XXX_DiscardUnknown()

func (*StartFromAddressRequest) XXX_Marshal 

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

func (*StartFromAddressRequest) XXX_Merge 

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

func (*StartFromAddressRequest) XXX_Size 

func (m *StartFromAddressRequest) XXX_Size() int

func (*StartFromAddressRequest) XXX_Unmarshal 

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

type StartReply 

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

func (*StartReply) Descriptor 

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

func (*StartReply) ProtoMessage 

func (*StartReply) ProtoMessage()

func (*StartReply) Reset 

func (m *StartReply) Reset()

func (*StartReply) String 

func (m *StartReply) String() string

func (*StartReply) XXX_DiscardUnknown 

func (m *StartReply) XXX_DiscardUnknown()

func (*StartReply) XXX_Marshal 

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

func (*StartReply) XXX_Merge 

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

func (*StartReply) XXX_Size 

func (m *StartReply) XXX_Size() int

func (*StartReply) XXX_Unmarshal 

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

type StartRequest 

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

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetDBID 

func (m *StartRequest) GetDBID() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

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

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StartTransactionRequest 

type StartTransactionRequest struct {
	DBID                 string   `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 

func (m *StartTransactionRequest) GetDBID() string

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) 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) GetDBLink(ctx context.Context, req *GetDBLinkRequest) (*GetDBLinkReply, error)

func (*UnimplementedAPIServer) Has added in v0.1.12 

func (*UnimplementedAPIServer) Has(ctx context.Context, req *HasRequest) (*HasReply, 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) 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) Start 

func (*UnimplementedAPIServer) Start(ctx context.Context, req *StartRequest) (*StartReply, error)

func (*UnimplementedAPIServer) StartFromAddress 

func (*UnimplementedAPIServer) StartFromAddress(ctx context.Context, req *StartFromAddressRequest) (*StartFromAddressReply, error)

func (*UnimplementedAPIServer) WriteTransaction 

func (*UnimplementedAPIServer) WriteTransaction(srv API_WriteTransactionServer) error

type WriteTransactionReply 

type WriteTransactionReply struct {
	// Types that are valid to be assigned to Option:
	//	*WriteTransactionReply_CreateReply
	//	*WriteTransactionReply_SaveReply
	//	*WriteTransactionReply_DeleteReply
	//	*WriteTransactionReply_HasReply
	//	*WriteTransactionReply_FindReply
	//	*WriteTransactionReply_FindByIDReply
	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) 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) 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_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 WriteTransactionRequest 

type WriteTransactionRequest struct {
	// Types that are valid to be assigned to Option:
	//	*WriteTransactionRequest_StartTransactionRequest
	//	*WriteTransactionRequest_CreateRequest
	//	*WriteTransactionRequest_SaveRequest
	//	*WriteTransactionRequest_DeleteRequest
	//	*WriteTransactionRequest_HasRequest
	//	*WriteTransactionRequest_FindRequest
	//	*WriteTransactionRequest_FindByIDRequest
	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) 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) 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_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"`
}

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.