storagepb

package

v0.0.0-...-13d8ce4 Latest Latest Go to latest Published: Apr 24, 2019 License: Apache-2.0 Imports: 4 Imported by: 12

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flike/kingbus

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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

View Source

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

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

record.pb.go

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