protobuf

package
v0.0.0-...-b4eea1d Latest Latest
Warning

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

Go to latest
Published: Oct 31, 2018 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Record_RecordKind_name = map[int32]string{
	0: "SET",
	1: "DEL",
	2: "CMT",
}
View Source
var Record_RecordKind_value = map[string]int32{
	"SET": 0,
	"DEL": 1,
	"CMT": 2,
}

Functions

func NewReader

func NewReader(reader io.Reader) stores.Reader

func NewWriter

func NewWriter(writer io.Writer) stores.Writer

Types

type Record

type Record struct {
	Kind                 Record_RecordKind `protobuf:"varint,1,opt,name=kind,proto3,enum=protobuf.Record_RecordKind" json:"kind,omitempty"`
	Key                  string            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                string            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	TransactionId        int64             `protobuf:"varint,4,opt,name=transactionId,proto3" json:"transactionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func RecordToProto

func RecordToProto(r stores.Record) *Record

func (*Record) Descriptor

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

func (*Record) GetKey

func (m *Record) GetKey() string

func (*Record) GetKind

func (m *Record) GetKind() Record_RecordKind

func (*Record) GetTransactionId

func (m *Record) GetTransactionId() int64

func (*Record) GetValue

func (m *Record) GetValue() string

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) String

func (m *Record) String() string

func (Record) ToRecord

func (r Record) ToRecord() *stores.Record

func (*Record) XXX_DiscardUnknown

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal

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

func (*Record) XXX_Merge

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

func (*Record) XXX_Size

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal

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

type Record_RecordKind

type Record_RecordKind int32
const (
	Record_SET Record_RecordKind = 0
	Record_DEL Record_RecordKind = 1
	Record_CMT Record_RecordKind = 2
)

func (Record_RecordKind) EnumDescriptor

func (Record_RecordKind) EnumDescriptor() ([]byte, []int)

func (Record_RecordKind) String

func (x Record_RecordKind) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL