remote

package
v0.0.0-...-0adc8af Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2022 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterKeydbServer 

func RegisterKeydbServer(s *grpc.Server, srv KeydbServer)

Types

type BeginReply 

type BeginReply struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BeginReply) Descriptor 

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

func (*BeginReply) GetError 

func (m *BeginReply) GetError() string

func (*BeginReply) GetTxid 

func (m *BeginReply) GetTxid() uint64

func (*BeginReply) ProtoMessage 

func (*BeginReply) ProtoMessage()

func (*BeginReply) Reset 

func (m *BeginReply) Reset()

func (*BeginReply) String 

func (m *BeginReply) String() string

func (*BeginReply) XXX_DiscardUnknown 

func (m *BeginReply) XXX_DiscardUnknown()

func (*BeginReply) XXX_Marshal 

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

func (*BeginReply) XXX_Merge 

func (dst *BeginReply) XXX_Merge(src proto.Message)

func (*BeginReply) XXX_Size 

func (m *BeginReply) XXX_Size() int

func (*BeginReply) XXX_Unmarshal 

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

type BeginRequest 

type BeginRequest struct {
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BeginRequest) Descriptor 

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

func (*BeginRequest) GetTable 

func (m *BeginRequest) GetTable() string

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) Reset 

func (m *BeginRequest) Reset()

func (*BeginRequest) String 

func (m *BeginRequest) String() string

func (*BeginRequest) XXX_DiscardUnknown 

func (m *BeginRequest) XXX_DiscardUnknown()

func (*BeginRequest) XXX_Marshal 

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

func (*BeginRequest) XXX_Merge 

func (dst *BeginRequest) XXX_Merge(src proto.Message)

func (*BeginRequest) XXX_Size 

func (m *BeginRequest) XXX_Size() int

func (*BeginRequest) XXX_Unmarshal 

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

type CloseReply 

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

func (*CloseReply) Descriptor 

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

func (*CloseReply) GetError 

func (m *CloseReply) GetError() string

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

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

func (*CloseReply) XXX_Merge 

func (dst *CloseReply) XXX_Merge(src proto.Message)

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

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

type CloseRequest 

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

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

func (dst *CloseRequest) XXX_Merge(src proto.Message)

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type CommitReply 

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

func (*CommitReply) Descriptor 

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

func (*CommitReply) GetError 

func (m *CommitReply) GetError() string

func (*CommitReply) ProtoMessage 

func (*CommitReply) ProtoMessage()

func (*CommitReply) Reset 

func (m *CommitReply) Reset()

func (*CommitReply) String 

func (m *CommitReply) String() string

func (*CommitReply) XXX_DiscardUnknown 

func (m *CommitReply) XXX_DiscardUnknown()

func (*CommitReply) XXX_Marshal 

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

func (*CommitReply) XXX_Merge 

func (dst *CommitReply) XXX_Merge(src proto.Message)

func (*CommitReply) XXX_Size 

func (m *CommitReply) XXX_Size() int

func (*CommitReply) XXX_Unmarshal 

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

type CommitRequest 

type CommitRequest struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,omitempty"`
	Sync                 bool     `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetSync 

func (m *CommitRequest) GetSync() bool

func (*CommitRequest) GetTxid 

func (m *CommitRequest) GetTxid() uint64

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) String 

func (m *CommitRequest) String() string

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

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

func (*CommitRequest) XXX_Merge 

func (dst *CommitRequest) XXX_Merge(src proto.Message)

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

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

type GetReply 

type GetReply struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetReply) Descriptor 

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

func (*GetReply) GetError 

func (m *GetReply) GetError() string

func (*GetReply) GetValue 

func (m *GetReply) GetValue() []byte

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset 

func (m *GetReply) Reset()

func (*GetReply) String 

func (m *GetReply) String() string

func (*GetReply) XXX_DiscardUnknown 

func (m *GetReply) XXX_DiscardUnknown()

func (*GetReply) XXX_Marshal 

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

func (*GetReply) XXX_Merge 

func (dst *GetReply) XXX_Merge(src proto.Message)

func (*GetReply) XXX_Size 

func (m *GetReply) XXX_Size() int

func (*GetReply) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,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 (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

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

func (*GetRequest) GetTxid 

func (m *GetRequest) GetTxid() uint64

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

func (dst *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type InMessage 

type InMessage struct {
	// Types that are valid to be assigned to Request:
	//	*InMessage_Open
	//	*InMessage_Close
	//	*InMessage_Get
	//	*InMessage_Put
	//	*InMessage_Begin
	//	*InMessage_Commit
	//	*InMessage_Rollback
	//	*InMessage_Lookup
	//	*InMessage_Next
	Request              isInMessage_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*InMessage) Descriptor 

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

func (*InMessage) GetBegin 

func (m *InMessage) GetBegin() *BeginRequest

func (*InMessage) GetClose 

func (m *InMessage) GetClose() *CloseRequest

func (*InMessage) GetCommit 

func (m *InMessage) GetCommit() *CommitRequest

func (*InMessage) GetGet 

func (m *InMessage) GetGet() *GetRequest

func (*InMessage) GetLookup 

func (m *InMessage) GetLookup() *LookupRequest

func (*InMessage) GetNext 

func (m *InMessage) GetNext() *LookupNextRequest

func (*InMessage) GetOpen 

func (m *InMessage) GetOpen() *OpenRequest

func (*InMessage) GetPut 

func (m *InMessage) GetPut() *PutRequest

func (*InMessage) GetRequest 

func (m *InMessage) GetRequest() isInMessage_Request

func (*InMessage) GetRollback 

func (m *InMessage) GetRollback() *RollbackRequest

func (*InMessage) ProtoMessage 

func (*InMessage) ProtoMessage()

func (*InMessage) Reset 

func (m *InMessage) Reset()

func (*InMessage) String 

func (m *InMessage) String() string

func (*InMessage) XXX_DiscardUnknown 

func (m *InMessage) XXX_DiscardUnknown()

func (*InMessage) XXX_Marshal 

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

func (*InMessage) XXX_Merge 

func (dst *InMessage) XXX_Merge(src proto.Message)

func (*InMessage) XXX_OneofFuncs 

func (*InMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*InMessage) XXX_Size 

func (m *InMessage) XXX_Size() int

func (*InMessage) XXX_Unmarshal 

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

type InMessage_Begin 

type InMessage_Begin struct {
	Begin *BeginRequest `protobuf:"bytes,6,opt,name=begin,proto3,oneof"`
}

type InMessage_Close 

type InMessage_Close struct {
	Close *CloseRequest `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type InMessage_Commit 

type InMessage_Commit struct {
	Commit *CommitRequest `protobuf:"bytes,7,opt,name=commit,proto3,oneof"`
}

type InMessage_Get 

type InMessage_Get struct {
	Get *GetRequest `protobuf:"bytes,4,opt,name=get,proto3,oneof"`
}

type InMessage_Lookup 

type InMessage_Lookup struct {
	Lookup *LookupRequest `protobuf:"bytes,9,opt,name=lookup,proto3,oneof"`
}

type InMessage_Next 

type InMessage_Next struct {
	Next *LookupNextRequest `protobuf:"bytes,10,opt,name=next,proto3,oneof"`
}

type InMessage_Open 

type InMessage_Open struct {
	Open *OpenRequest `protobuf:"bytes,1,opt,name=open,proto3,oneof"`
}

type InMessage_Put 

type InMessage_Put struct {
	Put *PutRequest `protobuf:"bytes,5,opt,name=put,proto3,oneof"`
}

type InMessage_Rollback 

type InMessage_Rollback struct {
	Rollback *RollbackRequest `protobuf:"bytes,8,opt,name=rollback,proto3,oneof"`
}

type KeyValue 

type KeyValue struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

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

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

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

func (*KeyValue) XXX_Merge 

func (dst *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

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

type KeydbClient 

type KeydbClient interface {
	Connection(ctx context.Context, opts ...grpc.CallOption) (Keydb_ConnectionClient, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error)
}

KeydbClient is the client API for Keydb service.

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

func NewKeydbClient 

func NewKeydbClient(cc *grpc.ClientConn) KeydbClient

type KeydbServer 

type KeydbServer interface {
	Connection(Keydb_ConnectionServer) error
	Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
}

KeydbServer is the server API for Keydb service.

type Keydb_ConnectionClient 

type Keydb_ConnectionClient interface {
	Send(*InMessage) error
	Recv() (*OutMessage, error)
	grpc.ClientStream
}

type Keydb_ConnectionServer 

type Keydb_ConnectionServer interface {
	Send(*OutMessage) error
	Recv() (*InMessage, error)
	grpc.ServerStream
}

type LookupNextReply 

type LookupNextReply struct {
	Entries              []*KeyValue `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Error                string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*LookupNextReply) Descriptor 

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

func (*LookupNextReply) GetEntries 

func (m *LookupNextReply) GetEntries() []*KeyValue

func (*LookupNextReply) GetError 

func (m *LookupNextReply) GetError() string

func (*LookupNextReply) ProtoMessage 

func (*LookupNextReply) ProtoMessage()

func (*LookupNextReply) Reset 

func (m *LookupNextReply) Reset()

func (*LookupNextReply) String 

func (m *LookupNextReply) String() string

func (*LookupNextReply) XXX_DiscardUnknown 

func (m *LookupNextReply) XXX_DiscardUnknown()

func (*LookupNextReply) XXX_Marshal 

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

func (*LookupNextReply) XXX_Merge 

func (dst *LookupNextReply) XXX_Merge(src proto.Message)

func (*LookupNextReply) XXX_Size 

func (m *LookupNextReply) XXX_Size() int

func (*LookupNextReply) XXX_Unmarshal 

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

type LookupNextRequest 

type LookupNextRequest struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupNextRequest) Descriptor 

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

func (*LookupNextRequest) GetId 

func (m *LookupNextRequest) GetId() uint64

func (*LookupNextRequest) ProtoMessage 

func (*LookupNextRequest) ProtoMessage()

func (*LookupNextRequest) Reset 

func (m *LookupNextRequest) Reset()

func (*LookupNextRequest) String 

func (m *LookupNextRequest) String() string

func (*LookupNextRequest) XXX_DiscardUnknown 

func (m *LookupNextRequest) XXX_DiscardUnknown()

func (*LookupNextRequest) XXX_Marshal 

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

func (*LookupNextRequest) XXX_Merge 

func (dst *LookupNextRequest) XXX_Merge(src proto.Message)

func (*LookupNextRequest) XXX_Size 

func (m *LookupNextRequest) XXX_Size() int

func (*LookupNextRequest) XXX_Unmarshal 

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

type LookupReply 

type LookupReply struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupReply) Descriptor 

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

func (*LookupReply) GetError 

func (m *LookupReply) GetError() string

func (*LookupReply) GetId 

func (m *LookupReply) GetId() uint64

func (*LookupReply) ProtoMessage 

func (*LookupReply) ProtoMessage()

func (*LookupReply) Reset 

func (m *LookupReply) Reset()

func (*LookupReply) String 

func (m *LookupReply) String() string

func (*LookupReply) XXX_DiscardUnknown 

func (m *LookupReply) XXX_DiscardUnknown()

func (*LookupReply) XXX_Marshal 

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

func (*LookupReply) XXX_Merge 

func (dst *LookupReply) XXX_Merge(src proto.Message)

func (*LookupReply) XXX_Size 

func (m *LookupReply) XXX_Size() int

func (*LookupReply) XXX_Unmarshal 

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

type LookupRequest 

type LookupRequest struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,omitempty"`
	Lower                []byte   `protobuf:"bytes,2,opt,name=lower,proto3" json:"lower,omitempty"`
	Upper                []byte   `protobuf:"bytes,3,opt,name=upper,proto3" json:"upper,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupRequest) Descriptor 

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

func (*LookupRequest) GetLower 

func (m *LookupRequest) GetLower() []byte

func (*LookupRequest) GetTxid 

func (m *LookupRequest) GetTxid() uint64

func (*LookupRequest) GetUpper 

func (m *LookupRequest) GetUpper() []byte

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset 

func (m *LookupRequest) Reset()

func (*LookupRequest) String 

func (m *LookupRequest) String() string

func (*LookupRequest) XXX_DiscardUnknown 

func (m *LookupRequest) XXX_DiscardUnknown()

func (*LookupRequest) XXX_Marshal 

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

func (*LookupRequest) XXX_Merge 

func (dst *LookupRequest) XXX_Merge(src proto.Message)

func (*LookupRequest) XXX_Size 

func (m *LookupRequest) XXX_Size() int

func (*LookupRequest) XXX_Unmarshal 

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

type OpenReply 

type OpenReply struct {
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpenReply) Descriptor 

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

func (*OpenReply) GetError 

func (m *OpenReply) GetError() string

func (*OpenReply) ProtoMessage 

func (*OpenReply) ProtoMessage()

func (*OpenReply) Reset 

func (m *OpenReply) Reset()

func (*OpenReply) String 

func (m *OpenReply) String() string

func (*OpenReply) XXX_DiscardUnknown 

func (m *OpenReply) XXX_DiscardUnknown()

func (*OpenReply) XXX_Marshal 

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

func (*OpenReply) XXX_Merge 

func (dst *OpenReply) XXX_Merge(src proto.Message)

func (*OpenReply) XXX_Size 

func (m *OpenReply) XXX_Size() int

func (*OpenReply) XXX_Unmarshal 

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

type OpenRequest 

type OpenRequest struct {
	Dbname               string   `protobuf:"bytes,1,opt,name=dbname,proto3" json:"dbname,omitempty"`
	Create               bool     `protobuf:"varint,2,opt,name=create,proto3" json:"create,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpenRequest) Descriptor 

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

func (*OpenRequest) GetCreate 

func (m *OpenRequest) GetCreate() bool

func (*OpenRequest) GetDbname 

func (m *OpenRequest) GetDbname() string

func (*OpenRequest) ProtoMessage 

func (*OpenRequest) ProtoMessage()

func (*OpenRequest) Reset 

func (m *OpenRequest) Reset()

func (*OpenRequest) String 

func (m *OpenRequest) String() string

func (*OpenRequest) XXX_DiscardUnknown 

func (m *OpenRequest) XXX_DiscardUnknown()

func (*OpenRequest) XXX_Marshal 

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

func (*OpenRequest) XXX_Merge 

func (dst *OpenRequest) XXX_Merge(src proto.Message)

func (*OpenRequest) XXX_Size 

func (m *OpenRequest) XXX_Size() int

func (*OpenRequest) XXX_Unmarshal 

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

type OutMessage 

type OutMessage struct {
	// Types that are valid to be assigned to Reply:
	//	*OutMessage_Open
	//	*OutMessage_Close
	//	*OutMessage_Get
	//	*OutMessage_Put
	//	*OutMessage_Begin
	//	*OutMessage_Commit
	//	*OutMessage_Rollback
	//	*OutMessage_Lookup
	//	*OutMessage_Next
	Reply                isOutMessage_Reply `protobuf_oneof:"reply"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*OutMessage) Descriptor 

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

func (*OutMessage) GetBegin 

func (m *OutMessage) GetBegin() *BeginReply

func (*OutMessage) GetClose 

func (m *OutMessage) GetClose() *CloseReply

func (*OutMessage) GetCommit 

func (m *OutMessage) GetCommit() *CommitReply

func (*OutMessage) GetGet 

func (m *OutMessage) GetGet() *GetReply

func (*OutMessage) GetLookup 

func (m *OutMessage) GetLookup() *LookupReply

func (*OutMessage) GetNext 

func (m *OutMessage) GetNext() *LookupNextReply

func (*OutMessage) GetOpen 

func (m *OutMessage) GetOpen() *OpenReply

func (*OutMessage) GetPut 

func (m *OutMessage) GetPut() *PutReply

func (*OutMessage) GetReply 

func (m *OutMessage) GetReply() isOutMessage_Reply

func (*OutMessage) GetRollback 

func (m *OutMessage) GetRollback() *RollbackReply

func (*OutMessage) ProtoMessage 

func (*OutMessage) ProtoMessage()

func (*OutMessage) Reset 

func (m *OutMessage) Reset()

func (*OutMessage) String 

func (m *OutMessage) String() string

func (*OutMessage) XXX_DiscardUnknown 

func (m *OutMessage) XXX_DiscardUnknown()

func (*OutMessage) XXX_Marshal 

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

func (*OutMessage) XXX_Merge 

func (dst *OutMessage) XXX_Merge(src proto.Message)

func (*OutMessage) XXX_OneofFuncs 

func (*OutMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*OutMessage) XXX_Size 

func (m *OutMessage) XXX_Size() int

func (*OutMessage) XXX_Unmarshal 

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

type OutMessage_Begin 

type OutMessage_Begin struct {
	Begin *BeginReply `protobuf:"bytes,6,opt,name=begin,proto3,oneof"`
}

type OutMessage_Close 

type OutMessage_Close struct {
	Close *CloseReply `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type OutMessage_Commit 

type OutMessage_Commit struct {
	Commit *CommitReply `protobuf:"bytes,7,opt,name=commit,proto3,oneof"`
}

type OutMessage_Get 

type OutMessage_Get struct {
	Get *GetReply `protobuf:"bytes,4,opt,name=get,proto3,oneof"`
}

type OutMessage_Lookup 

type OutMessage_Lookup struct {
	Lookup *LookupReply `protobuf:"bytes,9,opt,name=lookup,proto3,oneof"`
}

type OutMessage_Next 

type OutMessage_Next struct {
	Next *LookupNextReply `protobuf:"bytes,10,opt,name=next,proto3,oneof"`
}

type OutMessage_Open 

type OutMessage_Open struct {
	Open *OpenReply `protobuf:"bytes,1,opt,name=open,proto3,oneof"`
}

type OutMessage_Put 

type OutMessage_Put struct {
	Put *PutReply `protobuf:"bytes,5,opt,name=put,proto3,oneof"`
}

type OutMessage_Rollback 

type OutMessage_Rollback struct {
	Rollback *RollbackReply `protobuf:"bytes,8,opt,name=rollback,proto3,oneof"`
}

type PutReply 

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

func (*PutReply) Descriptor 

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

func (*PutReply) GetError 

func (m *PutReply) GetError() string

func (*PutReply) ProtoMessage 

func (*PutReply) ProtoMessage()

func (*PutReply) Reset 

func (m *PutReply) Reset()

func (*PutReply) String 

func (m *PutReply) String() string

func (*PutReply) XXX_DiscardUnknown 

func (m *PutReply) XXX_DiscardUnknown()

func (*PutReply) XXX_Marshal 

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

func (*PutReply) XXX_Merge 

func (dst *PutReply) XXX_Merge(src proto.Message)

func (*PutReply) XXX_Size 

func (m *PutReply) XXX_Size() int

func (*PutReply) XXX_Unmarshal 

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

type PutRequest 

type PutRequest struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Sync                 bool     `protobuf:"varint,4,opt,name=sync,proto3" json:"sync,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetKey 

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

func (*PutRequest) GetSync 

func (m *PutRequest) GetSync() bool

func (*PutRequest) GetTxid 

func (m *PutRequest) GetTxid() uint64

func (*PutRequest) GetValue 

func (m *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

func (dst *PutRequest) XXX_Merge(src proto.Message)

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type RemoveReply 

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

func (*RemoveReply) Descriptor 

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

func (*RemoveReply) GetError 

func (m *RemoveReply) GetError() string

func (*RemoveReply) ProtoMessage 

func (*RemoveReply) ProtoMessage()

func (*RemoveReply) Reset 

func (m *RemoveReply) Reset()

func (*RemoveReply) String 

func (m *RemoveReply) String() string

func (*RemoveReply) XXX_DiscardUnknown 

func (m *RemoveReply) XXX_DiscardUnknown()

func (*RemoveReply) XXX_Marshal 

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

func (*RemoveReply) XXX_Merge 

func (dst *RemoveReply) XXX_Merge(src proto.Message)

func (*RemoveReply) XXX_Size 

func (m *RemoveReply) XXX_Size() int

func (*RemoveReply) XXX_Unmarshal 

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

type RemoveRequest 

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

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetDbname 

func (m *RemoveRequest) GetDbname() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

func (dst *RemoveRequest) XXX_Merge(src proto.Message)

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RollbackReply 

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

func (*RollbackReply) Descriptor 

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

func (*RollbackReply) GetError 

func (m *RollbackReply) GetError() string

func (*RollbackReply) ProtoMessage 

func (*RollbackReply) ProtoMessage()

func (*RollbackReply) Reset 

func (m *RollbackReply) Reset()

func (*RollbackReply) String 

func (m *RollbackReply) String() string

func (*RollbackReply) XXX_DiscardUnknown 

func (m *RollbackReply) XXX_DiscardUnknown()

func (*RollbackReply) XXX_Marshal 

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

func (*RollbackReply) XXX_Merge 

func (dst *RollbackReply) XXX_Merge(src proto.Message)

func (*RollbackReply) XXX_Size 

func (m *RollbackReply) XXX_Size() int

func (*RollbackReply) XXX_Unmarshal 

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

type RollbackRequest 

type RollbackRequest struct {
	Txid                 uint64   `protobuf:"varint,1,opt,name=txid,proto3" json:"txid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RollbackRequest) Descriptor 

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

func (*RollbackRequest) GetTxid 

func (m *RollbackRequest) GetTxid() uint64

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset 

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (m *RollbackRequest) String() string

func (*RollbackRequest) XXX_DiscardUnknown 

func (m *RollbackRequest) XXX_DiscardUnknown()

func (*RollbackRequest) XXX_Marshal 

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

func (*RollbackRequest) XXX_Merge 

func (dst *RollbackRequest) XXX_Merge(src proto.Message)

func (*RollbackRequest) XXX_Size 

func (m *RollbackRequest) XXX_Size() int

func (*RollbackRequest) XXX_Unmarshal 

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

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.