api_pb

package
v0.1.14 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 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)
	GetDBInfo(ctx context.Context, in *GetDBInfoRequest, opts ...grpc.CallOption) (*GetDBInfoReply, error)
	NewCollection(ctx context.Context, in *NewCollectionRequest, opts ...grpc.CallOption) (*NewCollectionReply, 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 {
	GetToken(API_GetTokenServer) error
	NewDB(context.Context, *NewDBRequest) (*NewDBReply, error)
	NewDBFromAddr(context.Context, *NewDBFromAddrRequest) (*NewDBReply, error)
	GetDBInfo(context.Context, *GetDBInfoRequest) (*GetDBInfoReply, error)
	NewCollection(context.Context, *NewCollectionRequest) (*NewCollectionReply, 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_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              []*CollectionConfig_IndexConfig `protobuf:"bytes,3,rep,name=indexes,proto3" json:"indexes,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() []*CollectionConfig_IndexConfig

func (*CollectionConfig) GetName added in v0.1.12 

func (m *CollectionConfig) GetName() string

func (*CollectionConfig) GetSchema added in v0.1.12 

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

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

type CollectionConfig_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 (*CollectionConfig_IndexConfig) Descriptor added in v0.1.12 

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

func (*CollectionConfig_IndexConfig) GetPath added in v0.1.12 

func (m *CollectionConfig_IndexConfig) GetPath() string

func (*CollectionConfig_IndexConfig) GetUnique added in v0.1.12 

func (m *CollectionConfig_IndexConfig) GetUnique() bool

func (*CollectionConfig_IndexConfig) ProtoMessage added in v0.1.12 

func (*CollectionConfig_IndexConfig) ProtoMessage()

func (*CollectionConfig_IndexConfig) Reset added in v0.1.12 

func (m *CollectionConfig_IndexConfig) Reset()

func (*CollectionConfig_IndexConfig) String added in v0.1.12 

func (m *CollectionConfig_IndexConfig) String() string

func (*CollectionConfig_IndexConfig) XXX_DiscardUnknown added in v0.1.12 

func (m *CollectionConfig_IndexConfig) XXX_DiscardUnknown()

func (*CollectionConfig_IndexConfig) XXX_Marshal added in v0.1.12 

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

func (*CollectionConfig_IndexConfig) XXX_Merge added in v0.1.12 

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

func (*CollectionConfig_IndexConfig) XXX_Size added in v0.1.12 

func (m *CollectionConfig_IndexConfig) XXX_Size() int

func (*CollectionConfig_IndexConfig) XXX_Unmarshal added in v0.1.12 

func (m *CollectionConfig_IndexConfig) 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"`
	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) 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 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                 []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 FindByIDReply added in v0.1.12 

type FindByIDReply struct {
	Instance             []byte   `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() []byte

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"`
	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                 []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 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"`
	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) 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"`
	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                 []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 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                 []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=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                 []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"`
	Collections          []*CollectionConfig `protobuf:"bytes,3,rep,name=collections,proto3" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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) 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) 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"`
	Collections          []*CollectionConfig `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	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) 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) 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                 []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) 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) 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) 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) 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.