protogo

package module
v0.0.0-...-d22b6c2 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2020 License: GPL-3.0 Imports: 9 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_dbApi_proto protoreflect.FileDescriptor
View Source 
var File_shared_proto protoreflect.FileDescriptor

Functions

func RegisterDbAPIServer 

func RegisterDbAPIServer(s *grpc.Server, srv DbAPIServer)

Types

type BeginReply 

type BeginReply struct {
	DbHandle uint32 `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	// contains filtered or unexported fields
}

BeginReply

func (*BeginReply) Descriptor deprecated 

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

Deprecated: Use BeginReply.ProtoReflect.Descriptor instead.

func (*BeginReply) GetDbHandle 

func (x *BeginReply) GetDbHandle() uint32

func (*BeginReply) ProtoMessage 

func (*BeginReply) ProtoMessage()

func (*BeginReply) ProtoReflect 

func (x *BeginReply) ProtoReflect() protoreflect.Message

func (*BeginReply) Reset 

func (x *BeginReply) Reset()

func (*BeginReply) String 

func (x *BeginReply) String() string

type BeginRequest 

type BeginRequest struct {
	Ctx     *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbName  string       `protobuf:"bytes,2,opt,name=DbName,proto3" json:"DbName,omitempty"`
	TtxName string       `protobuf:"bytes,3,opt,name=TtxName,proto3" json:"TtxName,omitempty"`
	// Options
	Exclusif bool `protobuf:"varint,4,opt,name=Exclusif,proto3" json:"Exclusif,omitempty"`
	// contains filtered or unexported fields
}

////////////////// Begin parameters ////////////////// BeginRequest

func (*BeginRequest) Descriptor deprecated 

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

Deprecated: Use BeginRequest.ProtoReflect.Descriptor instead.

func (*BeginRequest) GetCtx 

func (x *BeginRequest) GetCtx() *ContextData

func (*BeginRequest) GetDbName 

func (x *BeginRequest) GetDbName() string

func (*BeginRequest) GetExclusif 

func (x *BeginRequest) GetExclusif() bool

func (*BeginRequest) GetTtxName 

func (x *BeginRequest) GetTtxName() string

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect 

func (x *BeginRequest) ProtoReflect() protoreflect.Message

func (*BeginRequest) Reset 

func (x *BeginRequest) Reset()

func (*BeginRequest) String 

func (x *BeginRequest) String() string

type CommitReply 

type CommitReply struct {
	// contains filtered or unexported fields
}

CommitReply

func (*CommitReply) Descriptor deprecated 

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

Deprecated: Use CommitReply.ProtoReflect.Descriptor instead.

func (*CommitReply) ProtoMessage 

func (*CommitReply) ProtoMessage()

func (*CommitReply) ProtoReflect 

func (x *CommitReply) ProtoReflect() protoreflect.Message

func (*CommitReply) Reset 

func (x *CommitReply) Reset()

func (*CommitReply) String 

func (x *CommitReply) String() string

type CommitRequest 

type CommitRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	// contains filtered or unexported fields
}

////////////////// Commit parameters ////////////////// CommitRequest

func (*CommitRequest) Descriptor deprecated 

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetCtx 

func (x *CommitRequest) GetCtx() *ContextData

func (*CommitRequest) GetDbHandle 

func (x *CommitRequest) GetDbHandle() uint32

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

func (x *CommitRequest) ProtoReflect() protoreflect.Message

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type ContextData 

type ContextData struct {
	SessionID          uint64 `protobuf:"varint,1,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	UID                uint64 `protobuf:"varint,2,opt,name=UID,proto3" json:"UID,omitempty"`
	Access             uint32 `protobuf:"varint,3,opt,name=Access,proto3" json:"Access,omitempty"`
	DbName             string `protobuf:"bytes,5,opt,name=DbName,proto3" json:"DbName,omitempty"`
	Instance           string `protobuf:"bytes,6,opt,name=Instance,proto3" json:"Instance,omitempty"`
	DbProvider         string `protobuf:"bytes,7,opt,name=DbProvider,proto3" json:"DbProvider,omitempty"`
	CurrentAPI         string `protobuf:"bytes,8,opt,name=CurrentAPI,proto3" json:"CurrentAPI,omitempty"`
	TraceLevel         uint64 `protobuf:"varint,9,opt,name=TraceLevel,proto3" json:"TraceLevel,omitempty"`
	SvcMask            uint32 `protobuf:"varint,10,opt,name=SvcMask,proto3" json:"SvcMask,omitempty"`
	CurrentServiceName string `protobuf:"bytes,11,opt,name=CurrentServiceName,proto3" json:"CurrentServiceName,omitempty"` // updated at service entry
	IsServiceTraced    bool   `protobuf:"varint,12,opt,name=IsServiceTraced,proto3" json:"IsServiceTraced,omitempty"`      // updated at service entry
	DbTtxID            uint64 `protobuf:"varint,14,opt,name=DbTtxID,proto3" json:"DbTtxID,omitempty"`                      // updated at service entry
	// contains filtered or unexported fields
}

ContextData

func (*ContextData) Descriptor deprecated 

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

Deprecated: Use ContextData.ProtoReflect.Descriptor instead.

func (*ContextData) GetAccess 

func (x *ContextData) GetAccess() uint32

func (*ContextData) GetCurrentAPI 

func (x *ContextData) GetCurrentAPI() string

func (*ContextData) GetCurrentServiceName 

func (x *ContextData) GetCurrentServiceName() string

func (*ContextData) GetDbName 

func (x *ContextData) GetDbName() string

func (*ContextData) GetDbProvider 

func (x *ContextData) GetDbProvider() string

func (*ContextData) GetDbTtxID 

func (x *ContextData) GetDbTtxID() uint64

func (*ContextData) GetInstance 

func (x *ContextData) GetInstance() string

func (*ContextData) GetIsServiceTraced 

func (x *ContextData) GetIsServiceTraced() bool

func (*ContextData) GetSessionID 

func (x *ContextData) GetSessionID() uint64

func (*ContextData) GetSvcMask 

func (x *ContextData) GetSvcMask() uint32

func (*ContextData) GetTraceLevel 

func (x *ContextData) GetTraceLevel() uint64

func (*ContextData) GetUID 

func (x *ContextData) GetUID() uint64

func (*ContextData) ProtoMessage 

func (*ContextData) ProtoMessage()

func (*ContextData) ProtoReflect 

func (x *ContextData) ProtoReflect() protoreflect.Message

func (*ContextData) Reset 

func (x *ContextData) Reset()

func (*ContextData) String 

func (x *ContextData) String() string

type CreateNewDBReply 

type CreateNewDBReply struct {
	// contains filtered or unexported fields
}

CreateNewDBReply

func (*CreateNewDBReply) Descriptor deprecated 

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

Deprecated: Use CreateNewDBReply.ProtoReflect.Descriptor instead.

func (*CreateNewDBReply) ProtoMessage 

func (*CreateNewDBReply) ProtoMessage()

func (*CreateNewDBReply) ProtoReflect 

func (x *CreateNewDBReply) ProtoReflect() protoreflect.Message

func (*CreateNewDBReply) Reset 

func (x *CreateNewDBReply) Reset()

func (*CreateNewDBReply) String 

func (x *CreateNewDBReply) String() string

type CreateNewDBRequest 

type CreateNewDBRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName   string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	Template string       `protobuf:"bytes,3,opt,name=Template,proto3" json:"Template,omitempty"`
	// contains filtered or unexported fields
}

CreateNewDBRequest

func (*CreateNewDBRequest) Descriptor deprecated 

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

Deprecated: Use CreateNewDBRequest.ProtoReflect.Descriptor instead.

func (*CreateNewDBRequest) GetCtx 

func (x *CreateNewDBRequest) GetCtx() *ContextData

func (*CreateNewDBRequest) GetDBName 

func (x *CreateNewDBRequest) GetDBName() string

func (*CreateNewDBRequest) GetTemplate 

func (x *CreateNewDBRequest) GetTemplate() string

func (*CreateNewDBRequest) ProtoMessage 

func (*CreateNewDBRequest) ProtoMessage()

func (*CreateNewDBRequest) ProtoReflect 

func (x *CreateNewDBRequest) ProtoReflect() protoreflect.Message

func (*CreateNewDBRequest) Reset 

func (x *CreateNewDBRequest) Reset()

func (*CreateNewDBRequest) String 

func (x *CreateNewDBRequest) String() string

type DbAPIClient 

type DbAPIClient interface {
	Begin(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginReply, error)
	Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackReply, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitReply, error)
	GetMany(ctx context.Context, in *GetManyRequest, opts ...grpc.CallOption) (*GetManyReply, error)
	Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*ReplaceReply, error)
	UpdateMany(ctx context.Context, in *UpdateManyRequest, opts ...grpc.CallOption) (*UpdateManyReply, error)
	DeleteMany(ctx context.Context, in *DeleteManyRequest, opts ...grpc.CallOption) (*DeleteManyReply, error)
	InsertMany(ctx context.Context, in *InsertManyRequest, opts ...grpc.CallOption) (*InsertManyReply, error)
	PopOne(ctx context.Context, in *PopOneRequest, opts ...grpc.CallOption) (*PopOneReply, error)
	ForceClose(ctx context.Context, in *ForceCloseRequest, opts ...grpc.CallOption) (*ForceCloseReply, error)
	Dump(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*DumpReply, error)
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*RestoreReply, error)
	ListDump(ctx context.Context, in *ListDumpRequest, opts ...grpc.CallOption) (*ListDumpReply, error)
	CreateNewDB(ctx context.Context, in *CreateNewDBRequest, opts ...grpc.CallOption) (*CreateNewDBReply, error)
	DropDB(ctx context.Context, in *DropDBRequest, opts ...grpc.CallOption) (*DropDBReply, error)
	UpgradeDB(ctx context.Context, in *UpgradeDBRequest, opts ...grpc.CallOption) (*UpgradeDBReply, error)
}

DbAPIClient is the client API for DbAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDbAPIClient 

func NewDbAPIClient(cc grpc.ClientConnInterface) DbAPIClient

type DbAPIServer 

type DbAPIServer interface {
	Begin(context.Context, *BeginRequest) (*BeginReply, error)
	Rollback(context.Context, *RollbackRequest) (*RollbackReply, error)
	Commit(context.Context, *CommitRequest) (*CommitReply, error)
	GetMany(context.Context, *GetManyRequest) (*GetManyReply, error)
	Replace(context.Context, *ReplaceRequest) (*ReplaceReply, error)
	UpdateMany(context.Context, *UpdateManyRequest) (*UpdateManyReply, error)
	DeleteMany(context.Context, *DeleteManyRequest) (*DeleteManyReply, error)
	InsertMany(context.Context, *InsertManyRequest) (*InsertManyReply, error)
	PopOne(context.Context, *PopOneRequest) (*PopOneReply, error)
	ForceClose(context.Context, *ForceCloseRequest) (*ForceCloseReply, error)
	Dump(context.Context, *DumpRequest) (*DumpReply, error)
	Restore(context.Context, *RestoreRequest) (*RestoreReply, error)
	ListDump(context.Context, *ListDumpRequest) (*ListDumpReply, error)
	CreateNewDB(context.Context, *CreateNewDBRequest) (*CreateNewDBReply, error)
	DropDB(context.Context, *DropDBRequest) (*DropDBReply, error)
	UpgradeDB(context.Context, *UpgradeDBRequest) (*UpgradeDBReply, error)
}

DbAPIServer is the server API for DbAPI service.

type DbDocumentBytes 

type DbDocumentBytes struct {
	ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	J  []byte `protobuf:"bytes,2,opt,name=J,proto3" json:"J,omitempty"`
	// contains filtered or unexported fields
}

DbDocumentBytes

func (*DbDocumentBytes) Descriptor deprecated 

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

Deprecated: Use DbDocumentBytes.ProtoReflect.Descriptor instead.

func (*DbDocumentBytes) GetID 

func (x *DbDocumentBytes) GetID() uint64

func (*DbDocumentBytes) GetJ 

func (x *DbDocumentBytes) GetJ() []byte

func (*DbDocumentBytes) ProtoMessage 

func (*DbDocumentBytes) ProtoMessage()

func (*DbDocumentBytes) ProtoReflect 

func (x *DbDocumentBytes) ProtoReflect() protoreflect.Message

func (*DbDocumentBytes) Reset 

func (x *DbDocumentBytes) Reset()

func (*DbDocumentBytes) String 

func (x *DbDocumentBytes) String() string

type DeleteManyReply 

type DeleteManyReply struct {
	DeleteID []uint64 `protobuf:"varint,1,rep,packed,name=DeleteID,proto3" json:"DeleteID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteManyReply) Descriptor deprecated 

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

Deprecated: Use DeleteManyReply.ProtoReflect.Descriptor instead.

func (*DeleteManyReply) GetDeleteID 

func (x *DeleteManyReply) GetDeleteID() []uint64

func (*DeleteManyReply) ProtoMessage 

func (*DeleteManyReply) ProtoMessage()

func (*DeleteManyReply) ProtoReflect 

func (x *DeleteManyReply) ProtoReflect() protoreflect.Message

func (*DeleteManyReply) Reset 

func (x *DeleteManyReply) Reset()

func (*DeleteManyReply) String 

func (x *DeleteManyReply) String() string

type DeleteManyRequest 

type DeleteManyRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	ECN      uint64       `protobuf:"varint,3,opt,name=ECN,proto3" json:"ECN,omitempty"`
	// Options
	Options string `protobuf:"bytes,11,opt,name=Options,proto3" json:"Options,omitempty"`
	Limit   uint64 `protobuf:"varint,12,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

DeleteManyRequest

func (*DeleteManyRequest) Descriptor deprecated 

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

Deprecated: Use DeleteManyRequest.ProtoReflect.Descriptor instead.

func (*DeleteManyRequest) GetCtx 

func (x *DeleteManyRequest) GetCtx() *ContextData

func (*DeleteManyRequest) GetDbHandle 

func (x *DeleteManyRequest) GetDbHandle() uint32

func (*DeleteManyRequest) GetECN 

func (x *DeleteManyRequest) GetECN() uint64

func (*DeleteManyRequest) GetLimit 

func (x *DeleteManyRequest) GetLimit() uint64

func (*DeleteManyRequest) GetOptions 

func (x *DeleteManyRequest) GetOptions() string

func (*DeleteManyRequest) ProtoMessage 

func (*DeleteManyRequest) ProtoMessage()

func (*DeleteManyRequest) ProtoReflect 

func (x *DeleteManyRequest) ProtoReflect() protoreflect.Message

func (*DeleteManyRequest) Reset 

func (x *DeleteManyRequest) Reset()

func (*DeleteManyRequest) String 

func (x *DeleteManyRequest) String() string

type DropDBReply 

type DropDBReply struct {
	// contains filtered or unexported fields
}

DropDBReply

func (*DropDBReply) Descriptor deprecated 

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

Deprecated: Use DropDBReply.ProtoReflect.Descriptor instead.

func (*DropDBReply) ProtoMessage 

func (*DropDBReply) ProtoMessage()

func (*DropDBReply) ProtoReflect 

func (x *DropDBReply) ProtoReflect() protoreflect.Message

func (*DropDBReply) Reset 

func (x *DropDBReply) Reset()

func (*DropDBReply) String 

func (x *DropDBReply) String() string

type DropDBRequest 

type DropDBRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName   string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	Template string       `protobuf:"bytes,3,opt,name=Template,proto3" json:"Template,omitempty"`
	// contains filtered or unexported fields
}

DropDBRequest

func (*DropDBRequest) Descriptor deprecated 

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

Deprecated: Use DropDBRequest.ProtoReflect.Descriptor instead.

func (*DropDBRequest) GetCtx 

func (x *DropDBRequest) GetCtx() *ContextData

func (*DropDBRequest) GetDBName 

func (x *DropDBRequest) GetDBName() string

func (*DropDBRequest) GetTemplate 

func (x *DropDBRequest) GetTemplate() string

func (*DropDBRequest) ProtoMessage 

func (*DropDBRequest) ProtoMessage()

func (*DropDBRequest) ProtoReflect 

func (x *DropDBRequest) ProtoReflect() protoreflect.Message

func (*DropDBRequest) Reset 

func (x *DropDBRequest) Reset()

func (*DropDBRequest) String 

func (x *DropDBRequest) String() string

type DumpReply 

type DumpReply struct {
	DumpName string `protobuf:"bytes,1,opt,name=DumpName,proto3" json:"DumpName,omitempty"`
	// contains filtered or unexported fields
}

DumpReply

func (*DumpReply) Descriptor deprecated 

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

Deprecated: Use DumpReply.ProtoReflect.Descriptor instead.

func (*DumpReply) GetDumpName 

func (x *DumpReply) GetDumpName() string

func (*DumpReply) ProtoMessage 

func (*DumpReply) ProtoMessage()

func (*DumpReply) ProtoReflect 

func (x *DumpReply) ProtoReflect() protoreflect.Message

func (*DumpReply) Reset 

func (x *DumpReply) Reset()

func (*DumpReply) String 

func (x *DumpReply) String() string

type DumpRequest 

type DumpRequest struct {
	Ctx    *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	// contains filtered or unexported fields
}

DumpRequest

func (*DumpRequest) Descriptor deprecated 

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

Deprecated: Use DumpRequest.ProtoReflect.Descriptor instead.

func (*DumpRequest) GetCtx 

func (x *DumpRequest) GetCtx() *ContextData

func (*DumpRequest) GetDBName 

func (x *DumpRequest) GetDBName() string

func (*DumpRequest) ProtoMessage 

func (*DumpRequest) ProtoMessage()

func (*DumpRequest) ProtoReflect 

func (x *DumpRequest) ProtoReflect() protoreflect.Message

func (*DumpRequest) Reset 

func (x *DumpRequest) Reset()

func (*DumpRequest) String 

func (x *DumpRequest) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

Empty message

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ForceCloseReply 

type ForceCloseReply struct {
	// contains filtered or unexported fields
}

ForceCloseReply

func (*ForceCloseReply) Descriptor deprecated 

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

Deprecated: Use ForceCloseReply.ProtoReflect.Descriptor instead.

func (*ForceCloseReply) ProtoMessage 

func (*ForceCloseReply) ProtoMessage()

func (*ForceCloseReply) ProtoReflect 

func (x *ForceCloseReply) ProtoReflect() protoreflect.Message

func (*ForceCloseReply) Reset 

func (x *ForceCloseReply) Reset()

func (*ForceCloseReply) String 

func (x *ForceCloseReply) String() string

type ForceCloseRequest 

type ForceCloseRequest struct {
	Ctx    *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	// contains filtered or unexported fields
}

ForceCloseRequest

func (*ForceCloseRequest) Descriptor deprecated 

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

Deprecated: Use ForceCloseRequest.ProtoReflect.Descriptor instead.

func (*ForceCloseRequest) GetCtx 

func (x *ForceCloseRequest) GetCtx() *ContextData

func (*ForceCloseRequest) GetDBName 

func (x *ForceCloseRequest) GetDBName() string

func (*ForceCloseRequest) ProtoMessage 

func (*ForceCloseRequest) ProtoMessage()

func (*ForceCloseRequest) ProtoReflect 

func (x *ForceCloseRequest) ProtoReflect() protoreflect.Message

func (*ForceCloseRequest) Reset 

func (x *ForceCloseRequest) Reset()

func (*ForceCloseRequest) String 

func (x *ForceCloseRequest) String() string

type GetManyReply 

type GetManyReply struct {
	Data []*DbDocumentBytes `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*GetManyReply) Descriptor deprecated 

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

Deprecated: Use GetManyReply.ProtoReflect.Descriptor instead.

func (*GetManyReply) GetData 

func (x *GetManyReply) GetData() []*DbDocumentBytes

func (*GetManyReply) ProtoMessage 

func (*GetManyReply) ProtoMessage()

func (*GetManyReply) ProtoReflect 

func (x *GetManyReply) ProtoReflect() protoreflect.Message

func (*GetManyReply) Reset 

func (x *GetManyReply) Reset()

func (*GetManyReply) String 

func (x *GetManyReply) String() string

type GetManyRequest 

type GetManyRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	ECN      uint64       `protobuf:"varint,3,opt,name=ECN,proto3" json:"ECN,omitempty"`
	Options  string       `protobuf:"bytes,4,opt,name=Options,proto3" json:"Options,omitempty"`
	// contains filtered or unexported fields
}

////////////////// GetMany parameters //////////////////

func (*GetManyRequest) Descriptor deprecated 

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

Deprecated: Use GetManyRequest.ProtoReflect.Descriptor instead.

func (*GetManyRequest) GetCtx 

func (x *GetManyRequest) GetCtx() *ContextData

func (*GetManyRequest) GetDbHandle 

func (x *GetManyRequest) GetDbHandle() uint32

func (*GetManyRequest) GetECN 

func (x *GetManyRequest) GetECN() uint64

func (*GetManyRequest) GetOptions 

func (x *GetManyRequest) GetOptions() string

func (*GetManyRequest) ProtoMessage 

func (*GetManyRequest) ProtoMessage()

func (*GetManyRequest) ProtoReflect 

func (x *GetManyRequest) ProtoReflect() protoreflect.Message

func (*GetManyRequest) Reset 

func (x *GetManyRequest) Reset()

func (*GetManyRequest) String 

func (x *GetManyRequest) String() string

type InsertManyReply 

type InsertManyReply struct {
	Data []*DbDocumentBytes `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertManyReply) Descriptor deprecated 

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

Deprecated: Use InsertManyReply.ProtoReflect.Descriptor instead.

func (*InsertManyReply) GetData 

func (x *InsertManyReply) GetData() []*DbDocumentBytes

func (*InsertManyReply) ProtoMessage 

func (*InsertManyReply) ProtoMessage()

func (*InsertManyReply) ProtoReflect 

func (x *InsertManyReply) ProtoReflect() protoreflect.Message

func (*InsertManyReply) Reset 

func (x *InsertManyReply) Reset()

func (*InsertManyReply) String 

func (x *InsertManyReply) String() string

type InsertManyRequest 

type InsertManyRequest struct {
	Ctx      *ContextData       `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32             `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	ECN      uint64             `protobuf:"varint,3,opt,name=ECN,proto3" json:"ECN,omitempty"`
	Data     []*DbDocumentBytes `protobuf:"bytes,4,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

////////////////////// InsertMany parameters ////////////////////// InsertManyRequest

func (*InsertManyRequest) Descriptor deprecated 

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

Deprecated: Use InsertManyRequest.ProtoReflect.Descriptor instead.

func (*InsertManyRequest) GetCtx 

func (x *InsertManyRequest) GetCtx() *ContextData

func (*InsertManyRequest) GetData 

func (x *InsertManyRequest) GetData() []*DbDocumentBytes

func (*InsertManyRequest) GetDbHandle 

func (x *InsertManyRequest) GetDbHandle() uint32

func (*InsertManyRequest) GetECN 

func (x *InsertManyRequest) GetECN() uint64

func (*InsertManyRequest) ProtoMessage 

func (*InsertManyRequest) ProtoMessage()

func (*InsertManyRequest) ProtoReflect 

func (x *InsertManyRequest) ProtoReflect() protoreflect.Message

func (*InsertManyRequest) Reset 

func (x *InsertManyRequest) Reset()

func (*InsertManyRequest) String 

func (x *InsertManyRequest) String() string

type ListDumpReply 

type ListDumpReply struct {
	// contains filtered or unexported fields
}

ListDumpReply

func (*ListDumpReply) Descriptor deprecated 

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

Deprecated: Use ListDumpReply.ProtoReflect.Descriptor instead.

func (*ListDumpReply) ProtoMessage 

func (*ListDumpReply) ProtoMessage()

func (*ListDumpReply) ProtoReflect 

func (x *ListDumpReply) ProtoReflect() protoreflect.Message

func (*ListDumpReply) Reset 

func (x *ListDumpReply) Reset()

func (*ListDumpReply) String 

func (x *ListDumpReply) String() string

type ListDumpRequest 

type ListDumpRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName   string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	DumpName string       `protobuf:"bytes,3,opt,name=DumpName,proto3" json:"DumpName,omitempty"`
	// contains filtered or unexported fields
}

ListDumpRequest

func (*ListDumpRequest) Descriptor deprecated 

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

Deprecated: Use ListDumpRequest.ProtoReflect.Descriptor instead.

func (*ListDumpRequest) GetCtx 

func (x *ListDumpRequest) GetCtx() *ContextData

func (*ListDumpRequest) GetDBName 

func (x *ListDumpRequest) GetDBName() string

func (*ListDumpRequest) GetDumpName 

func (x *ListDumpRequest) GetDumpName() string

func (*ListDumpRequest) ProtoMessage 

func (*ListDumpRequest) ProtoMessage()

func (*ListDumpRequest) ProtoReflect 

func (x *ListDumpRequest) ProtoReflect() protoreflect.Message

func (*ListDumpRequest) Reset 

func (x *ListDumpRequest) Reset()

func (*ListDumpRequest) String 

func (x *ListDumpRequest) String() string

type PopOneReply 

type PopOneReply struct {
	Data *DbDocumentBytes `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

PopOneReply

func (*PopOneReply) Descriptor deprecated 

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

Deprecated: Use PopOneReply.ProtoReflect.Descriptor instead.

func (*PopOneReply) GetData 

func (x *PopOneReply) GetData() *DbDocumentBytes

func (*PopOneReply) ProtoMessage 

func (*PopOneReply) ProtoMessage()

func (*PopOneReply) ProtoReflect 

func (x *PopOneReply) ProtoReflect() protoreflect.Message

func (*PopOneReply) Reset 

func (x *PopOneReply) Reset()

func (*PopOneReply) String 

func (x *PopOneReply) String() string

type PopOneRequest 

type PopOneRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	// contains filtered or unexported fields
}

PopOneRequest

func (*PopOneRequest) Descriptor deprecated 

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

Deprecated: Use PopOneRequest.ProtoReflect.Descriptor instead.

func (*PopOneRequest) GetCtx 

func (x *PopOneRequest) GetCtx() *ContextData

func (*PopOneRequest) GetDbHandle 

func (x *PopOneRequest) GetDbHandle() uint32

func (*PopOneRequest) ProtoMessage 

func (*PopOneRequest) ProtoMessage()

func (*PopOneRequest) ProtoReflect 

func (x *PopOneRequest) ProtoReflect() protoreflect.Message

func (*PopOneRequest) Reset 

func (x *PopOneRequest) Reset()

func (*PopOneRequest) String 

func (x *PopOneRequest) String() string

type ReplaceReply 

type ReplaceReply struct {
	Data []*DbDocumentBytes `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

ReplaceReply

func (*ReplaceReply) Descriptor deprecated 

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

Deprecated: Use ReplaceReply.ProtoReflect.Descriptor instead.

func (*ReplaceReply) GetData 

func (x *ReplaceReply) GetData() []*DbDocumentBytes

func (*ReplaceReply) ProtoMessage 

func (*ReplaceReply) ProtoMessage()

func (*ReplaceReply) ProtoReflect 

func (x *ReplaceReply) ProtoReflect() protoreflect.Message

func (*ReplaceReply) Reset 

func (x *ReplaceReply) Reset()

func (*ReplaceReply) String 

func (x *ReplaceReply) String() string

type ReplaceRequest 

type ReplaceRequest struct {
	Ctx      *ContextData       `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32             `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	Ecn      int64              `protobuf:"varint,3,opt,name=Ecn,proto3" json:"Ecn,omitempty"`
	Data     []*DbDocumentBytes `protobuf:"bytes,4,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

////////////////// Replace parameters ////////////////// ReplaceRequest

func (*ReplaceRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetCtx 

func (x *ReplaceRequest) GetCtx() *ContextData

func (*ReplaceRequest) GetData 

func (x *ReplaceRequest) GetData() []*DbDocumentBytes

func (*ReplaceRequest) GetDbHandle 

func (x *ReplaceRequest) GetDbHandle() uint32

func (*ReplaceRequest) GetEcn 

func (x *ReplaceRequest) GetEcn() int64

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect 

func (x *ReplaceRequest) ProtoReflect() protoreflect.Message

func (*ReplaceRequest) Reset 

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String 

func (x *ReplaceRequest) String() string

type RestoreReply 

type RestoreReply struct {
	// contains filtered or unexported fields
}

RestoreReply

func (*RestoreReply) Descriptor deprecated 

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

Deprecated: Use RestoreReply.ProtoReflect.Descriptor instead.

func (*RestoreReply) ProtoMessage 

func (*RestoreReply) ProtoMessage()

func (*RestoreReply) ProtoReflect 

func (x *RestoreReply) ProtoReflect() protoreflect.Message

func (*RestoreReply) Reset 

func (x *RestoreReply) Reset()

func (*RestoreReply) String 

func (x *RestoreReply) String() string

type RestoreRequest 

type RestoreRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName   string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	DumpName string       `protobuf:"bytes,3,opt,name=DumpName,proto3" json:"DumpName,omitempty"`
	// contains filtered or unexported fields
}

RestoreRequest

func (*RestoreRequest) Descriptor deprecated 

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

Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.

func (*RestoreRequest) GetCtx 

func (x *RestoreRequest) GetCtx() *ContextData

func (*RestoreRequest) GetDBName 

func (x *RestoreRequest) GetDBName() string

func (*RestoreRequest) GetDumpName 

func (x *RestoreRequest) GetDumpName() string

func (*RestoreRequest) ProtoMessage 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) ProtoReflect 

func (x *RestoreRequest) ProtoReflect() protoreflect.Message

func (*RestoreRequest) Reset 

func (x *RestoreRequest) Reset()

func (*RestoreRequest) String 

func (x *RestoreRequest) String() string

type RollbackReply 

type RollbackReply struct {
	// contains filtered or unexported fields
}

RollbackReply

func (*RollbackReply) Descriptor deprecated 

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

Deprecated: Use RollbackReply.ProtoReflect.Descriptor instead.

func (*RollbackReply) ProtoMessage 

func (*RollbackReply) ProtoMessage()

func (*RollbackReply) ProtoReflect 

func (x *RollbackReply) ProtoReflect() protoreflect.Message

func (*RollbackReply) Reset 

func (x *RollbackReply) Reset()

func (*RollbackReply) String 

func (x *RollbackReply) String() string

type RollbackRequest 

type RollbackRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	Reason   string       `protobuf:"bytes,3,opt,name=Reason,proto3" json:"Reason,omitempty"`
	// contains filtered or unexported fields
}

////////////////// Rollback parameters ////////////////// RollbackRequest

func (*RollbackRequest) Descriptor deprecated 

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

Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead.

func (*RollbackRequest) GetCtx 

func (x *RollbackRequest) GetCtx() *ContextData

func (*RollbackRequest) GetDbHandle 

func (x *RollbackRequest) GetDbHandle() uint32

func (*RollbackRequest) GetReason 

func (x *RollbackRequest) GetReason() string

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) ProtoReflect 

func (x *RollbackRequest) ProtoReflect() protoreflect.Message

func (*RollbackRequest) Reset 

func (x *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (x *RollbackRequest) String() string

type UnimplementedDbAPIServer 

type UnimplementedDbAPIServer struct {
}

UnimplementedDbAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedDbAPIServer) Begin 

func (*UnimplementedDbAPIServer) Begin(context.Context, *BeginRequest) (*BeginReply, error)

func (*UnimplementedDbAPIServer) Commit 

func (*UnimplementedDbAPIServer) Commit(context.Context, *CommitRequest) (*CommitReply, error)

func (*UnimplementedDbAPIServer) CreateNewDB 

func (*UnimplementedDbAPIServer) CreateNewDB(context.Context, *CreateNewDBRequest) (*CreateNewDBReply, error)

func (*UnimplementedDbAPIServer) DeleteMany 

func (*UnimplementedDbAPIServer) DeleteMany(context.Context, *DeleteManyRequest) (*DeleteManyReply, error)

func (*UnimplementedDbAPIServer) DropDB 

func (*UnimplementedDbAPIServer) DropDB(context.Context, *DropDBRequest) (*DropDBReply, error)

func (*UnimplementedDbAPIServer) Dump 

func (*UnimplementedDbAPIServer) Dump(context.Context, *DumpRequest) (*DumpReply, error)

func (*UnimplementedDbAPIServer) ForceClose 

func (*UnimplementedDbAPIServer) ForceClose(context.Context, *ForceCloseRequest) (*ForceCloseReply, error)

func (*UnimplementedDbAPIServer) GetMany 

func (*UnimplementedDbAPIServer) GetMany(context.Context, *GetManyRequest) (*GetManyReply, error)

func (*UnimplementedDbAPIServer) InsertMany 

func (*UnimplementedDbAPIServer) InsertMany(context.Context, *InsertManyRequest) (*InsertManyReply, error)

func (*UnimplementedDbAPIServer) ListDump 

func (*UnimplementedDbAPIServer) ListDump(context.Context, *ListDumpRequest) (*ListDumpReply, error)

func (*UnimplementedDbAPIServer) PopOne 

func (*UnimplementedDbAPIServer) PopOne(context.Context, *PopOneRequest) (*PopOneReply, error)

func (*UnimplementedDbAPIServer) Replace 

func (*UnimplementedDbAPIServer) Replace(context.Context, *ReplaceRequest) (*ReplaceReply, error)

func (*UnimplementedDbAPIServer) Restore 

func (*UnimplementedDbAPIServer) Restore(context.Context, *RestoreRequest) (*RestoreReply, error)

func (*UnimplementedDbAPIServer) Rollback 

func (*UnimplementedDbAPIServer) Rollback(context.Context, *RollbackRequest) (*RollbackReply, error)

func (*UnimplementedDbAPIServer) UpdateMany 

func (*UnimplementedDbAPIServer) UpdateMany(context.Context, *UpdateManyRequest) (*UpdateManyReply, error)

func (*UnimplementedDbAPIServer) UpgradeDB 

func (*UnimplementedDbAPIServer) UpgradeDB(context.Context, *UpgradeDBRequest) (*UpgradeDBReply, error)

type UpdateManyItem 

type UpdateManyItem struct {
	FieldPath string `protobuf:"bytes,1,opt,name=FieldPath,proto3" json:"FieldPath,omitempty"`
	Value     string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

UpdateManyItem

func (*UpdateManyItem) Descriptor deprecated 

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

Deprecated: Use UpdateManyItem.ProtoReflect.Descriptor instead.

func (*UpdateManyItem) GetFieldPath 

func (x *UpdateManyItem) GetFieldPath() string

func (*UpdateManyItem) GetValue 

func (x *UpdateManyItem) GetValue() string

func (*UpdateManyItem) ProtoMessage 

func (*UpdateManyItem) ProtoMessage()

func (*UpdateManyItem) ProtoReflect 

func (x *UpdateManyItem) ProtoReflect() protoreflect.Message

func (*UpdateManyItem) Reset 

func (x *UpdateManyItem) Reset()

func (*UpdateManyItem) String 

func (x *UpdateManyItem) String() string

type UpdateManyReply 

type UpdateManyReply struct {
	Data []*DbDocumentBytes `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

UpdateManyReply

func (*UpdateManyReply) Descriptor deprecated 

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

Deprecated: Use UpdateManyReply.ProtoReflect.Descriptor instead.

func (*UpdateManyReply) GetData 

func (x *UpdateManyReply) GetData() []*DbDocumentBytes

func (*UpdateManyReply) ProtoMessage 

func (*UpdateManyReply) ProtoMessage()

func (*UpdateManyReply) ProtoReflect 

func (x *UpdateManyReply) ProtoReflect() protoreflect.Message

func (*UpdateManyReply) Reset 

func (x *UpdateManyReply) Reset()

func (*UpdateManyReply) String 

func (x *UpdateManyReply) String() string

type UpdateManyRequest 

type UpdateManyRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DbHandle uint32       `protobuf:"varint,2,opt,name=DbHandle,proto3" json:"DbHandle,omitempty"`
	ECN      uint64       `protobuf:"varint,3,opt,name=ECN,proto3" json:"ECN,omitempty"`
	// Options
	Set     []*UpdateManyItem `protobuf:"bytes,11,rep,name=Set,proto3" json:"Set,omitempty"`
	Options string            `protobuf:"bytes,12,opt,name=Options,proto3" json:"Options,omitempty"`
	// contains filtered or unexported fields
}

UpdateManyRequest

func (*UpdateManyRequest) Descriptor deprecated 

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

Deprecated: Use UpdateManyRequest.ProtoReflect.Descriptor instead.

func (*UpdateManyRequest) GetCtx 

func (x *UpdateManyRequest) GetCtx() *ContextData

func (*UpdateManyRequest) GetDbHandle 

func (x *UpdateManyRequest) GetDbHandle() uint32

func (*UpdateManyRequest) GetECN 

func (x *UpdateManyRequest) GetECN() uint64

func (*UpdateManyRequest) GetOptions 

func (x *UpdateManyRequest) GetOptions() string

func (*UpdateManyRequest) GetSet 

func (x *UpdateManyRequest) GetSet() []*UpdateManyItem

func (*UpdateManyRequest) ProtoMessage 

func (*UpdateManyRequest) ProtoMessage()

func (*UpdateManyRequest) ProtoReflect 

func (x *UpdateManyRequest) ProtoReflect() protoreflect.Message

func (*UpdateManyRequest) Reset 

func (x *UpdateManyRequest) Reset()

func (*UpdateManyRequest) String 

func (x *UpdateManyRequest) String() string

type UpgradeDBReply 

type UpgradeDBReply struct {
	// contains filtered or unexported fields
}

UpgradeDBReply

func (*UpgradeDBReply) Descriptor deprecated 

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

Deprecated: Use UpgradeDBReply.ProtoReflect.Descriptor instead.

func (*UpgradeDBReply) ProtoMessage 

func (*UpgradeDBReply) ProtoMessage()

func (*UpgradeDBReply) ProtoReflect 

func (x *UpgradeDBReply) ProtoReflect() protoreflect.Message

func (*UpgradeDBReply) Reset 

func (x *UpgradeDBReply) Reset()

func (*UpgradeDBReply) String 

func (x *UpgradeDBReply) String() string

type UpgradeDBRequest 

type UpgradeDBRequest struct {
	Ctx      *ContextData `protobuf:"bytes,1,opt,name=Ctx,proto3" json:"Ctx,omitempty"`
	DBName   string       `protobuf:"bytes,2,opt,name=DBName,proto3" json:"DBName,omitempty"`
	Template string       `protobuf:"bytes,3,opt,name=Template,proto3" json:"Template,omitempty"`
	// contains filtered or unexported fields
}

UpgradeDBRequest

func (*UpgradeDBRequest) Descriptor deprecated 

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

Deprecated: Use UpgradeDBRequest.ProtoReflect.Descriptor instead.

func (*UpgradeDBRequest) GetCtx 

func (x *UpgradeDBRequest) GetCtx() *ContextData

func (*UpgradeDBRequest) GetDBName 

func (x *UpgradeDBRequest) GetDBName() string

func (*UpgradeDBRequest) GetTemplate 

func (x *UpgradeDBRequest) GetTemplate() string

func (*UpgradeDBRequest) ProtoMessage 

func (*UpgradeDBRequest) ProtoMessage()

func (*UpgradeDBRequest) ProtoReflect 

func (x *UpgradeDBRequest) ProtoReflect() protoreflect.Message

func (*UpgradeDBRequest) Reset 

func (x *UpgradeDBRequest) Reset()

func (*UpgradeDBRequest) String 

func (x *UpgradeDBRequest) String() string

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.