storagepb

Documentation

Overview

Package storagepb is a generated protocol buffer package.

It is generated from these files:

record.proto

It has these top-level messages:

Record
BinlogEvent

Index

• Variables
• type BinlogEvent
  • func (*BinlogEvent) Descriptor() ([]byte, []int)
  • func (m *BinlogEvent) GetData() []byte
  • func (m *BinlogEvent) GetDividedCount() uint32
  • func (m *BinlogEvent) GetDividedSeqNum() uint32
  • func (m *BinlogEvent) GetFlavor() FlavorType
  • func (m *BinlogEvent) GetType() uint32
  • func (m *BinlogEvent) Marshal() (dAtA []byte, err error)
  • func (m *BinlogEvent) MarshalTo(dAtA []byte) (int, error)
  • func (*BinlogEvent) ProtoMessage()
  • func (m *BinlogEvent) Reset()
  • func (m *BinlogEvent) Size() (n int)
  • func (m *BinlogEvent) String() string
  • func (m *BinlogEvent) Unmarshal(dAtA []byte) error
• type FlavorType
  • func (x FlavorType) Enum() *FlavorType
  • func (FlavorType) EnumDescriptor() ([]byte, []int)
  • func (x FlavorType) String() string
  • func (x *FlavorType) UnmarshalJSON(data []byte) error
• type Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (m *Record) GetCrc() uint32
  • func (m *Record) GetData() []byte
  • func (m *Record) Marshal() (dAtA []byte, err error)
  • func (m *Record) MarshalTo(dAtA []byte) (int, error)
  • func (*Record) ProtoMessage()
  • func (m *Record) Reset()
  • func (m *Record) Size() (n int)
  • func (m *Record) String() string
  • func (m *Record) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthRecord = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRecord   = fmt.Errorf("proto: integer overflow")
)

var FlavorType_name = map[int32]string{
	0: "MySQL",
	1: "Maria",
}

var FlavorType_value = map[string]int32{
	"MySQL": 0,
	"Maria": 1,
}

Types

type BinlogEvent

type BinlogEvent struct {
	Type             uint32     `protobuf:"varint,1,opt,name=type" json:"type"`
	Flavor           FlavorType `protobuf:"varint,2,opt,name=flavor,enum=storagepb.FlavorType" json:"flavor"`
	DividedCount     uint32     `protobuf:"varint,3,opt,name=divided_count,json=dividedCount" json:"divided_count"`
	DividedSeqNum    uint32     `protobuf:"varint,4,opt,name=divided_seq_num,json=dividedSeqNum" json:"divided_seq_num"`
	Data             []byte     `protobuf:"bytes,5,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*BinlogEvent) Descriptor

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

func (*BinlogEvent) GetData

func (m *BinlogEvent) GetData() []byte

func (*BinlogEvent) GetDividedCount

func (m *BinlogEvent) GetDividedCount() uint32

func (*BinlogEvent) GetDividedSeqNum

func (m *BinlogEvent) GetDividedSeqNum() uint32

func (*BinlogEvent) GetFlavor

func (m *BinlogEvent) GetFlavor() FlavorType

func (*BinlogEvent) GetType

func (m *BinlogEvent) GetType() uint32

func (*BinlogEvent) Marshal

func (m *BinlogEvent) Marshal() (dAtA []byte, err error)

func (*BinlogEvent) MarshalTo

func (m *BinlogEvent) MarshalTo(dAtA []byte) (int, error)

func (*BinlogEvent) ProtoMessage

func (*BinlogEvent) ProtoMessage()

func (*BinlogEvent) Reset

func (m *BinlogEvent) Reset()

func (*BinlogEvent) Size

func (m *BinlogEvent) Size() (n int)

func (*BinlogEvent) String

func (m *BinlogEvent) String() string

func (*BinlogEvent) Unmarshal

func (m *BinlogEvent) Unmarshal(dAtA []byte) error

type FlavorType

type FlavorType int32

const (
	FlavorType_MySQL FlavorType = 0
	FlavorType_Maria FlavorType = 1
)

func (FlavorType) Enum

func (x FlavorType) Enum() *FlavorType

func (FlavorType) EnumDescriptor

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

func (FlavorType) String

func (x FlavorType) String() string

func (*FlavorType) UnmarshalJSON

func (x *FlavorType) UnmarshalJSON(data []byte) error

type Record

type Record struct {
	Crc              uint32 `protobuf:"varint,1,opt,name=crc" json:"crc"`
	Data             []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Record) Descriptor

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

func (*Record) GetCrc

func (m *Record) GetCrc() uint32

func (*Record) GetData

func (m *Record) GetData() []byte

func (*Record) Marshal

func (m *Record) Marshal() (dAtA []byte, err error)

func (*Record) MarshalTo

func (m *Record) MarshalTo(dAtA []byte) (int, error)

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) Size

func (m *Record) Size() (n int)

func (*Record) String

func (m *Record) String() string

func (*Record) Unmarshal

func (m *Record) Unmarshal(dAtA []byte) error