eventpb

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package eventpb is a generated protocol buffer package.

It is generated from these files: 

eventpb.proto

It has these top-level messages: 

EventRangeSplitAck
EventRangeSplitKey
EventRangeDeleteAck
EventRaftErr
EventStoreErr
EventNodeBuildAck
EventEventStatistics
Event

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEventpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEventpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var EventType_name = map[int32]string{
	0: "RangeSplitAck",
	1: "RaftErr",
	2: "NodeBuildAck",
	3: "RangeDeleteAck",
	4: "EventStatistics",
	5: "RangeSplitKey",
	6: "StoreErr",
}
View Source 
var EventType_value = map[string]int32{
	"RangeSplitAck":   0,
	"RaftErr":         1,
	"NodeBuildAck":    2,
	"RangeDeleteAck":  3,
	"EventStatistics": 4,
	"RangeSplitKey":   5,
	"StoreErr":        6,
}
View Source 
var StatisticsType_name = map[int32]string{
	0: "RaftSplit",
	1: "ApplySnapshot",
	2: "LeaderLose",
	3: "PeerAdd",
	4: "PeerRemove",
	5: "LeaderReign",
}
View Source 
var StatisticsType_value = map[string]int32{
	"RaftSplit":     0,
	"ApplySnapshot": 1,
	"LeaderLose":    2,
	"PeerAdd":       3,
	"PeerRemove":    4,
	"LeaderReign":   5,
}

Functions

This section is empty.

Types

type Event 

type Event struct {
	Type                 EventType             `protobuf:"varint,1,opt,name=type,proto3,enum=eventpb.EventType" json:"type,omitempty"`
	EventRangeSplitAck   *EventRangeSplitAck   `protobuf:"bytes,2,opt,name=event_range_split_ack,json=eventRangeSplitAck" json:"event_range_split_ack,omitempty"`
	EventRaftErr         *EventRaftErr         `protobuf:"bytes,3,opt,name=event_raft_err,json=eventRaftErr" json:"event_raft_err,omitempty"`
	EventNodeBuildAck    *EventNodeBuildAck    `protobuf:"bytes,4,opt,name=event_node_build_ack,json=eventNodeBuildAck" json:"event_node_build_ack,omitempty"`
	EventRangeDeleteAck  *EventRangeDeleteAck  `protobuf:"bytes,5,opt,name=event_range_delete_ack,json=eventRangeDeleteAck" json:"event_range_delete_ack,omitempty"`
	EventEventStatistics *EventEventStatistics `protobuf:"bytes,6,opt,name=event_event_statistics,json=eventEventStatistics" json:"event_event_statistics,omitempty"`
	EventRangeSplitKey   *EventRangeSplitKey   `protobuf:"bytes,7,opt,name=event_range_split_key,json=eventRangeSplitKey" json:"event_range_split_key,omitempty"`
	EventStoreErr        *EventStoreErr        `protobuf:"bytes,8,opt,name=event_store_err,json=eventStoreErr" json:"event_store_err,omitempty"`
}

func (*Event) Descriptor 

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

func (*Event) GetEventEventStatistics 

func (m *Event) GetEventEventStatistics() *EventEventStatistics

func (*Event) GetEventNodeBuildAck 

func (m *Event) GetEventNodeBuildAck() *EventNodeBuildAck

func (*Event) GetEventRaftErr 

func (m *Event) GetEventRaftErr() *EventRaftErr

func (*Event) GetEventRangeDeleteAck 

func (m *Event) GetEventRangeDeleteAck() *EventRangeDeleteAck

func (*Event) GetEventRangeSplitAck 

func (m *Event) GetEventRangeSplitAck() *EventRangeSplitAck

func (*Event) GetEventRangeSplitKey 

func (m *Event) GetEventRangeSplitKey() *EventRangeSplitKey

func (*Event) GetEventStoreErr 

func (m *Event) GetEventStoreErr() *EventStoreErr

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

type EventEventStatistics 

type EventEventStatistics struct {
	DbName         string         `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName      string         `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	RangeId        uint64         `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	NodeId         uint64         `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	StartTime      int64          `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime        int64          `protobuf:"varint,6,opt,name=endTime,proto3" json:"endTime,omitempty"`
	StatisticsType StatisticsType `protobuf:"varint,7,opt,name=statisticsType,proto3,enum=eventpb.StatisticsType" json:"statisticsType,omitempty"`
}

func (*EventEventStatistics) Descriptor 

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

func (*EventEventStatistics) GetDbName 

func (m *EventEventStatistics) GetDbName() string

func (*EventEventStatistics) GetEndTime 

func (m *EventEventStatistics) GetEndTime() int64

func (*EventEventStatistics) GetNodeId 

func (m *EventEventStatistics) GetNodeId() uint64

func (*EventEventStatistics) GetRangeId 

func (m *EventEventStatistics) GetRangeId() uint64

func (*EventEventStatistics) GetStartTime 

func (m *EventEventStatistics) GetStartTime() int64

func (*EventEventStatistics) GetStatisticsType 

func (m *EventEventStatistics) GetStatisticsType() StatisticsType

func (*EventEventStatistics) GetTableName 

func (m *EventEventStatistics) GetTableName() string

func (*EventEventStatistics) Marshal 

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

func (*EventEventStatistics) MarshalTo 

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

func (*EventEventStatistics) ProtoMessage 

func (*EventEventStatistics) ProtoMessage()

func (*EventEventStatistics) Reset 

func (m *EventEventStatistics) Reset()

func (*EventEventStatistics) Size 

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

func (*EventEventStatistics) String 

func (m *EventEventStatistics) String() string

func (*EventEventStatistics) Unmarshal 

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

type EventNodeBuildAck 

type EventNodeBuildAck struct {
	Ip  string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Err string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
}

func (*EventNodeBuildAck) Descriptor 

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

func (*EventNodeBuildAck) GetErr 

func (m *EventNodeBuildAck) GetErr() string

func (*EventNodeBuildAck) GetIp 

func (m *EventNodeBuildAck) GetIp() string

func (*EventNodeBuildAck) GetKey 

func (m *EventNodeBuildAck) GetKey() string

func (*EventNodeBuildAck) Marshal 

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

func (*EventNodeBuildAck) MarshalTo 

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

func (*EventNodeBuildAck) ProtoMessage 

func (*EventNodeBuildAck) ProtoMessage()

func (*EventNodeBuildAck) Reset 

func (m *EventNodeBuildAck) Reset()

func (*EventNodeBuildAck) Size 

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

func (*EventNodeBuildAck) String 

func (m *EventNodeBuildAck) String() string

func (*EventNodeBuildAck) Unmarshal 

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

type EventRaftErr 

type EventRaftErr struct {
	NodeId  uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RangeId uint64 `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Error   string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*EventRaftErr) Descriptor 

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

func (*EventRaftErr) GetError 

func (m *EventRaftErr) GetError() string

func (*EventRaftErr) GetNodeId 

func (m *EventRaftErr) GetNodeId() uint64

func (*EventRaftErr) GetRangeId 

func (m *EventRaftErr) GetRangeId() uint64

func (*EventRaftErr) Marshal 

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

func (*EventRaftErr) MarshalTo 

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

func (*EventRaftErr) ProtoMessage 

func (*EventRaftErr) ProtoMessage()

func (*EventRaftErr) Reset 

func (m *EventRaftErr) Reset()

func (*EventRaftErr) Size 

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

func (*EventRaftErr) String 

func (m *EventRaftErr) String() string

func (*EventRaftErr) Unmarshal 

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

type EventRangeDeleteAck 

type EventRangeDeleteAck struct {
	TaskId uint64        `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Range  *metapb.Range `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
}

func (*EventRangeDeleteAck) Descriptor 

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

func (*EventRangeDeleteAck) GetRange 

func (m *EventRangeDeleteAck) GetRange() *metapb.Range

func (*EventRangeDeleteAck) GetTaskId 

func (m *EventRangeDeleteAck) GetTaskId() uint64

func (*EventRangeDeleteAck) Marshal 

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

func (*EventRangeDeleteAck) MarshalTo 

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

func (*EventRangeDeleteAck) ProtoMessage 

func (*EventRangeDeleteAck) ProtoMessage()

func (*EventRangeDeleteAck) Reset 

func (m *EventRangeDeleteAck) Reset()

func (*EventRangeDeleteAck) Size 

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

func (*EventRangeDeleteAck) String 

func (m *EventRangeDeleteAck) String() string

func (*EventRangeDeleteAck) Unmarshal 

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

type EventRangeSplitAck 

type EventRangeSplitAck struct {
	TaskId     uint64        `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Range      *metapb.Range `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	LeftRange  *metapb.Range `protobuf:"bytes,3,opt,name=left_range,json=leftRange" json:"left_range,omitempty"`
	RightRange *metapb.Range `protobuf:"bytes,4,opt,name=right_range,json=rightRange" json:"right_range,omitempty"`
}

func (*EventRangeSplitAck) Descriptor 

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

func (*EventRangeSplitAck) GetLeftRange 

func (m *EventRangeSplitAck) GetLeftRange() *metapb.Range

func (*EventRangeSplitAck) GetRange 

func (m *EventRangeSplitAck) GetRange() *metapb.Range

func (*EventRangeSplitAck) GetRightRange 

func (m *EventRangeSplitAck) GetRightRange() *metapb.Range

func (*EventRangeSplitAck) GetTaskId 

func (m *EventRangeSplitAck) GetTaskId() uint64

func (*EventRangeSplitAck) Marshal 

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

func (*EventRangeSplitAck) MarshalTo 

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

func (*EventRangeSplitAck) ProtoMessage 

func (*EventRangeSplitAck) ProtoMessage()

func (*EventRangeSplitAck) Reset 

func (m *EventRangeSplitAck) Reset()

func (*EventRangeSplitAck) Size 

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

func (*EventRangeSplitAck) String 

func (m *EventRangeSplitAck) String() string

func (*EventRangeSplitAck) Unmarshal 

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

type EventRangeSplitKey 

type EventRangeSplitKey struct {
	TaskId   uint64        `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Range    *metapb.Range `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	SplitKey []byte        `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
}

func (*EventRangeSplitKey) Descriptor 

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

func (*EventRangeSplitKey) GetRange 

func (m *EventRangeSplitKey) GetRange() *metapb.Range

func (*EventRangeSplitKey) GetSplitKey 

func (m *EventRangeSplitKey) GetSplitKey() []byte

func (*EventRangeSplitKey) GetTaskId 

func (m *EventRangeSplitKey) GetTaskId() uint64

func (*EventRangeSplitKey) Marshal 

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

func (*EventRangeSplitKey) MarshalTo 

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

func (*EventRangeSplitKey) ProtoMessage 

func (*EventRangeSplitKey) ProtoMessage()

func (*EventRangeSplitKey) Reset 

func (m *EventRangeSplitKey) Reset()

func (*EventRangeSplitKey) Size 

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

func (*EventRangeSplitKey) String 

func (m *EventRangeSplitKey) String() string

func (*EventRangeSplitKey) Unmarshal 

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

type EventStoreErr 

type EventStoreErr struct {
	NodeId  uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RangeId uint64 `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Error   string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*EventStoreErr) Descriptor 

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

func (*EventStoreErr) GetError 

func (m *EventStoreErr) GetError() string

func (*EventStoreErr) GetNodeId 

func (m *EventStoreErr) GetNodeId() uint64

func (*EventStoreErr) GetRangeId 

func (m *EventStoreErr) GetRangeId() uint64

func (*EventStoreErr) Marshal 

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

func (*EventStoreErr) MarshalTo 

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

func (*EventStoreErr) ProtoMessage 

func (*EventStoreErr) ProtoMessage()

func (*EventStoreErr) Reset 

func (m *EventStoreErr) Reset()

func (*EventStoreErr) Size 

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

func (*EventStoreErr) String 

func (m *EventStoreErr) String() string

func (*EventStoreErr) Unmarshal 

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

type EventType 

type EventType int32
const (
	EventType_RangeSplitAck   EventType = 0
	EventType_RaftErr         EventType = 1
	EventType_NodeBuildAck    EventType = 2
	EventType_RangeDeleteAck  EventType = 3
	EventType_EventStatistics EventType = 4
	EventType_RangeSplitKey   EventType = 5
	EventType_StoreErr        EventType = 6
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type StatisticsType 

type StatisticsType int32
const (
	StatisticsType_RaftSplit     StatisticsType = 0
	StatisticsType_ApplySnapshot StatisticsType = 1
	StatisticsType_LeaderLose    StatisticsType = 2
	StatisticsType_PeerAdd       StatisticsType = 3
	StatisticsType_PeerRemove    StatisticsType = 4
	StatisticsType_LeaderReign   StatisticsType = 5
)

func (StatisticsType) EnumDescriptor 

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

func (StatisticsType) String 

func (x StatisticsType) 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.