rpcpb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpcpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpcpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpcpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Type_name = map[int32]string{
	0:  "TypeResourceHeartbeatReq",
	1:  "TypeResourceHeartbeatRsp",
	2:  "TypeContainerHeartbeatReq",
	3:  "TypeContainerHeartbeatRsp",
	4:  "TypeGetContainerReq",
	5:  "TypeGetContainerRsp",
	6:  "TypeAllocIDReq",
	7:  "TypeAllocIDRsp",
	8:  "TypeAskSplitReq",
	9:  "TypeAskSplitRsp",
	10: "TypeAskBatchSplitReq",
	11: "TypeAskBatchSplitRsp",
	12: "TypeReportSplitReq",
	13: "TypeReportSplitRsp",
	14: "TypeBatchReportSplitReq",
	15: "TypeBatchReportSplitRsp",
	16: "TypeTSOReq",
	17: "TypeTSORsp",
	18: "TypeCreateWatcherReq",
	19: "TypeEventNotify",
	20: "TypeGetDCLocationsReq",
	21: "TypeGetDCLocationsRsp",
}
View Source 
var Type_value = map[string]int32{
	"TypeResourceHeartbeatReq":  0,
	"TypeResourceHeartbeatRsp":  1,
	"TypeContainerHeartbeatReq": 2,
	"TypeContainerHeartbeatRsp": 3,
	"TypeGetContainerReq":       4,
	"TypeGetContainerRsp":       5,
	"TypeAllocIDReq":            6,
	"TypeAllocIDRsp":            7,
	"TypeAskSplitReq":           8,
	"TypeAskSplitRsp":           9,
	"TypeAskBatchSplitReq":      10,
	"TypeAskBatchSplitRsp":      11,
	"TypeReportSplitReq":        12,
	"TypeReportSplitRsp":        13,
	"TypeBatchReportSplitReq":   14,
	"TypeBatchReportSplitRsp":   15,
	"TypeTSOReq":                16,
	"TypeTSORsp":                17,
	"TypeCreateWatcherReq":      18,
	"TypeEventNotify":           19,
	"TypeGetDCLocationsReq":     20,
	"TypeGetDCLocationsRsp":     21,
}

Functions

This section is empty.

Types

type AllocIDReq 

type AllocIDReq struct {
}

AllocIDReq alloc id request

func (*AllocIDReq) Descriptor 

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

func (*AllocIDReq) Marshal 

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

func (*AllocIDReq) MarshalTo 

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

func (*AllocIDReq) MarshalToSizedBuffer 

func (m *AllocIDReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllocIDReq) ProtoMessage 

func (*AllocIDReq) ProtoMessage()

func (*AllocIDReq) Reset 

func (m *AllocIDReq) Reset()

func (*AllocIDReq) Size 

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

func (*AllocIDReq) String 

func (m *AllocIDReq) String() string

func (*AllocIDReq) Unmarshal 

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

func (*AllocIDReq) XXX_DiscardUnknown 

func (m *AllocIDReq) XXX_DiscardUnknown()

func (*AllocIDReq) XXX_Marshal 

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

func (*AllocIDReq) XXX_Merge 

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

func (*AllocIDReq) XXX_Size 

func (m *AllocIDReq) XXX_Size() int

func (*AllocIDReq) XXX_Unmarshal 

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

type AllocIDRsp 

type AllocIDRsp struct {
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

AllocIDRsp alloc id response

func (*AllocIDRsp) Descriptor 

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

func (*AllocIDRsp) GetID 

func (m *AllocIDRsp) GetID() uint64

func (*AllocIDRsp) Marshal 

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

func (*AllocIDRsp) MarshalTo 

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

func (*AllocIDRsp) MarshalToSizedBuffer 

func (m *AllocIDRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllocIDRsp) ProtoMessage 

func (*AllocIDRsp) ProtoMessage()

func (*AllocIDRsp) Reset 

func (m *AllocIDRsp) Reset()

func (*AllocIDRsp) Size 

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

func (*AllocIDRsp) String 

func (m *AllocIDRsp) String() string

func (*AllocIDRsp) Unmarshal 

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

func (*AllocIDRsp) XXX_DiscardUnknown 

func (m *AllocIDRsp) XXX_DiscardUnknown()

func (*AllocIDRsp) XXX_Marshal 

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

func (*AllocIDRsp) XXX_Merge 

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

func (*AllocIDRsp) XXX_Size 

func (m *AllocIDRsp) XXX_Size() int

func (*AllocIDRsp) XXX_Unmarshal 

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

type AskBatchSplitReq 

type AskBatchSplitReq struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

AskBatchSplitReq ask batch split request

func (*AskBatchSplitReq) Descriptor 

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

func (*AskBatchSplitReq) GetCount 

func (m *AskBatchSplitReq) GetCount() uint32

func (*AskBatchSplitReq) GetData 

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

func (*AskBatchSplitReq) Marshal 

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

func (*AskBatchSplitReq) MarshalTo 

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

func (*AskBatchSplitReq) MarshalToSizedBuffer 

func (m *AskBatchSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskBatchSplitReq) ProtoMessage 

func (*AskBatchSplitReq) ProtoMessage()

func (*AskBatchSplitReq) Reset 

func (m *AskBatchSplitReq) Reset()

func (*AskBatchSplitReq) Size 

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

func (*AskBatchSplitReq) String 

func (m *AskBatchSplitReq) String() string

func (*AskBatchSplitReq) Unmarshal 

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

func (*AskBatchSplitReq) XXX_DiscardUnknown 

func (m *AskBatchSplitReq) XXX_DiscardUnknown()

func (*AskBatchSplitReq) XXX_Marshal 

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

func (*AskBatchSplitReq) XXX_Merge 

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

func (*AskBatchSplitReq) XXX_Size 

func (m *AskBatchSplitReq) XXX_Size() int

func (*AskBatchSplitReq) XXX_Unmarshal 

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

type AskBatchSplitRsp 

type AskBatchSplitRsp struct {
	SplitIDs []SplitID `protobuf:"bytes,1,rep,name=splitIDs,proto3" json:"splitIDs"`
}

AskBatchSplitRsp ask batch split response

func (*AskBatchSplitRsp) Descriptor 

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

func (*AskBatchSplitRsp) GetSplitIDs 

func (m *AskBatchSplitRsp) GetSplitIDs() []SplitID

func (*AskBatchSplitRsp) Marshal 

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

func (*AskBatchSplitRsp) MarshalTo 

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

func (*AskBatchSplitRsp) MarshalToSizedBuffer 

func (m *AskBatchSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskBatchSplitRsp) ProtoMessage 

func (*AskBatchSplitRsp) ProtoMessage()

func (*AskBatchSplitRsp) Reset 

func (m *AskBatchSplitRsp) Reset()

func (*AskBatchSplitRsp) Size 

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

func (*AskBatchSplitRsp) String 

func (m *AskBatchSplitRsp) String() string

func (*AskBatchSplitRsp) Unmarshal 

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

func (*AskBatchSplitRsp) XXX_DiscardUnknown 

func (m *AskBatchSplitRsp) XXX_DiscardUnknown()

func (*AskBatchSplitRsp) XXX_Marshal 

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

func (*AskBatchSplitRsp) XXX_Merge 

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

func (*AskBatchSplitRsp) XXX_Size 

func (m *AskBatchSplitRsp) XXX_Size() int

func (*AskBatchSplitRsp) XXX_Unmarshal 

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

type AskSplitReq 

type AskSplitReq struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

AskSplitReq ask split request

func (*AskSplitReq) Descriptor 

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

func (*AskSplitReq) GetData 

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

func (*AskSplitReq) Marshal 

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

func (*AskSplitReq) MarshalTo 

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

func (*AskSplitReq) MarshalToSizedBuffer 

func (m *AskSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskSplitReq) ProtoMessage 

func (*AskSplitReq) ProtoMessage()

func (*AskSplitReq) Reset 

func (m *AskSplitReq) Reset()

func (*AskSplitReq) Size 

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

func (*AskSplitReq) String 

func (m *AskSplitReq) String() string

func (*AskSplitReq) Unmarshal 

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

func (*AskSplitReq) XXX_DiscardUnknown 

func (m *AskSplitReq) XXX_DiscardUnknown()

func (*AskSplitReq) XXX_Marshal 

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

func (*AskSplitReq) XXX_Merge 

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

func (*AskSplitReq) XXX_Size 

func (m *AskSplitReq) XXX_Size() int

func (*AskSplitReq) XXX_Unmarshal 

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

type AskSplitRsp 

type AskSplitRsp struct {
	SplitID SplitID `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID"`
}

AskSplitRsp ask split response

func (*AskSplitRsp) Descriptor 

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

func (*AskSplitRsp) GetSplitID 

func (m *AskSplitRsp) GetSplitID() SplitID

func (*AskSplitRsp) Marshal 

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

func (*AskSplitRsp) MarshalTo 

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

func (*AskSplitRsp) MarshalToSizedBuffer 

func (m *AskSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskSplitRsp) ProtoMessage 

func (*AskSplitRsp) ProtoMessage()

func (*AskSplitRsp) Reset 

func (m *AskSplitRsp) Reset()

func (*AskSplitRsp) Size 

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

func (*AskSplitRsp) String 

func (m *AskSplitRsp) String() string

func (*AskSplitRsp) Unmarshal 

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

func (*AskSplitRsp) XXX_DiscardUnknown 

func (m *AskSplitRsp) XXX_DiscardUnknown()

func (*AskSplitRsp) XXX_Marshal 

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

func (*AskSplitRsp) XXX_Merge 

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

func (*AskSplitRsp) XXX_Size 

func (m *AskSplitRsp) XXX_Size() int

func (*AskSplitRsp) XXX_Unmarshal 

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

type BatchReportSplitReq 

type BatchReportSplitReq struct {
	Resources [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
}

BatchReportSplitReq report split request

func (*BatchReportSplitReq) Descriptor 

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

func (*BatchReportSplitReq) GetResources 

func (m *BatchReportSplitReq) GetResources() [][]byte

func (*BatchReportSplitReq) Marshal 

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

func (*BatchReportSplitReq) MarshalTo 

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

func (*BatchReportSplitReq) MarshalToSizedBuffer 

func (m *BatchReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchReportSplitReq) ProtoMessage 

func (*BatchReportSplitReq) ProtoMessage()

func (*BatchReportSplitReq) Reset 

func (m *BatchReportSplitReq) Reset()

func (*BatchReportSplitReq) Size 

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

func (*BatchReportSplitReq) String 

func (m *BatchReportSplitReq) String() string

func (*BatchReportSplitReq) Unmarshal 

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

func (*BatchReportSplitReq) XXX_DiscardUnknown 

func (m *BatchReportSplitReq) XXX_DiscardUnknown()

func (*BatchReportSplitReq) XXX_Marshal 

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

func (*BatchReportSplitReq) XXX_Merge 

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

func (*BatchReportSplitReq) XXX_Size 

func (m *BatchReportSplitReq) XXX_Size() int

func (*BatchReportSplitReq) XXX_Unmarshal 

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

type BatchReportSplitRsp 

type BatchReportSplitRsp struct {
}

BatchReportSplitRsp report split response

func (*BatchReportSplitRsp) Descriptor 

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

func (*BatchReportSplitRsp) Marshal 

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

func (*BatchReportSplitRsp) MarshalTo 

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

func (*BatchReportSplitRsp) MarshalToSizedBuffer 

func (m *BatchReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchReportSplitRsp) ProtoMessage 

func (*BatchReportSplitRsp) ProtoMessage()

func (*BatchReportSplitRsp) Reset 

func (m *BatchReportSplitRsp) Reset()

func (*BatchReportSplitRsp) Size 

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

func (*BatchReportSplitRsp) String 

func (m *BatchReportSplitRsp) String() string

func (*BatchReportSplitRsp) Unmarshal 

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

func (*BatchReportSplitRsp) XXX_DiscardUnknown 

func (m *BatchReportSplitRsp) XXX_DiscardUnknown()

func (*BatchReportSplitRsp) XXX_Marshal 

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

func (*BatchReportSplitRsp) XXX_Merge 

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

func (*BatchReportSplitRsp) XXX_Size 

func (m *BatchReportSplitRsp) XXX_Size() int

func (*BatchReportSplitRsp) XXX_Unmarshal 

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

type ChangePeer 

type ChangePeer struct {
	Peer       metapb.Peer           `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
	ChangeType metapb.ChangePeerType `protobuf:"varint,2,opt,name=changeType,proto3,enum=metapb.ChangePeerType" json:"changeType,omitempty"`
}

ChangePeer change peer

func (*ChangePeer) Descriptor 

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

func (*ChangePeer) GetChangeType 

func (m *ChangePeer) GetChangeType() metapb.ChangePeerType

func (*ChangePeer) GetPeer 

func (m *ChangePeer) GetPeer() metapb.Peer

func (*ChangePeer) Marshal 

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

func (*ChangePeer) MarshalTo 

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

func (*ChangePeer) MarshalToSizedBuffer 

func (m *ChangePeer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangePeer) ProtoMessage 

func (*ChangePeer) ProtoMessage()

func (*ChangePeer) Reset 

func (m *ChangePeer) Reset()

func (*ChangePeer) Size 

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

func (*ChangePeer) String 

func (m *ChangePeer) String() string

func (*ChangePeer) Unmarshal 

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

func (*ChangePeer) XXX_DiscardUnknown 

func (m *ChangePeer) XXX_DiscardUnknown()

func (*ChangePeer) XXX_Marshal 

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

func (*ChangePeer) XXX_Merge 

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

func (*ChangePeer) XXX_Size 

func (m *ChangePeer) XXX_Size() int

func (*ChangePeer) XXX_Unmarshal 

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

type ChangePeerV2 

type ChangePeerV2 struct {
	// If changes is empty, it means that to exit joint state.
	Changes []ChangePeer `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes"`
}

ChangePeerV2 change peer v2

func (*ChangePeerV2) Descriptor 

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

func (*ChangePeerV2) GetChanges 

func (m *ChangePeerV2) GetChanges() []ChangePeer

func (*ChangePeerV2) Marshal 

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

func (*ChangePeerV2) MarshalTo 

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

func (*ChangePeerV2) MarshalToSizedBuffer 

func (m *ChangePeerV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangePeerV2) ProtoMessage 

func (*ChangePeerV2) ProtoMessage()

func (*ChangePeerV2) Reset 

func (m *ChangePeerV2) Reset()

func (*ChangePeerV2) Size 

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

func (*ChangePeerV2) String 

func (m *ChangePeerV2) String() string

func (*ChangePeerV2) Unmarshal 

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

func (*ChangePeerV2) XXX_DiscardUnknown 

func (m *ChangePeerV2) XXX_DiscardUnknown()

func (*ChangePeerV2) XXX_Marshal 

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

func (*ChangePeerV2) XXX_Merge 

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

func (*ChangePeerV2) XXX_Size 

func (m *ChangePeerV2) XXX_Size() int

func (*ChangePeerV2) XXX_Unmarshal 

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

type ContainerEventData 

type ContainerEventData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

ContainerEventData container created or updated

func (*ContainerEventData) Descriptor 

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

func (*ContainerEventData) GetData 

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

func (*ContainerEventData) Marshal 

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

func (*ContainerEventData) MarshalTo 

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

func (*ContainerEventData) MarshalToSizedBuffer 

func (m *ContainerEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerEventData) ProtoMessage 

func (*ContainerEventData) ProtoMessage()

func (*ContainerEventData) Reset 

func (m *ContainerEventData) Reset()

func (*ContainerEventData) Size 

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

func (*ContainerEventData) String 

func (m *ContainerEventData) String() string

func (*ContainerEventData) Unmarshal 

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

func (*ContainerEventData) XXX_DiscardUnknown 

func (m *ContainerEventData) XXX_DiscardUnknown()

func (*ContainerEventData) XXX_Marshal 

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

func (*ContainerEventData) XXX_Merge 

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

func (*ContainerEventData) XXX_Size 

func (m *ContainerEventData) XXX_Size() int

func (*ContainerEventData) XXX_Unmarshal 

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

type ContainerHeartbeatReq 

type ContainerHeartbeatReq struct {
	Stats ContainerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats"`
}

ContainerHeartbeatReq container heartbeat request

func (*ContainerHeartbeatReq) Descriptor 

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

func (*ContainerHeartbeatReq) GetStats 

func (m *ContainerHeartbeatReq) GetStats() ContainerStats

func (*ContainerHeartbeatReq) Marshal 

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

func (*ContainerHeartbeatReq) MarshalTo 

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

func (*ContainerHeartbeatReq) MarshalToSizedBuffer 

func (m *ContainerHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerHeartbeatReq) ProtoMessage 

func (*ContainerHeartbeatReq) ProtoMessage()

func (*ContainerHeartbeatReq) Reset 

func (m *ContainerHeartbeatReq) Reset()

func (*ContainerHeartbeatReq) Size 

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

func (*ContainerHeartbeatReq) String 

func (m *ContainerHeartbeatReq) String() string

func (*ContainerHeartbeatReq) Unmarshal 

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

func (*ContainerHeartbeatReq) XXX_DiscardUnknown 

func (m *ContainerHeartbeatReq) XXX_DiscardUnknown()

func (*ContainerHeartbeatReq) XXX_Marshal 

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

func (*ContainerHeartbeatReq) XXX_Merge 

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

func (*ContainerHeartbeatReq) XXX_Size 

func (m *ContainerHeartbeatReq) XXX_Size() int

func (*ContainerHeartbeatReq) XXX_Unmarshal 

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

type ContainerHeartbeatRsp 

type ContainerHeartbeatRsp struct {
}

ContainerHeartbeatRsp container heartbeat response

func (*ContainerHeartbeatRsp) Descriptor 

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

func (*ContainerHeartbeatRsp) Marshal 

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

func (*ContainerHeartbeatRsp) MarshalTo 

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

func (*ContainerHeartbeatRsp) MarshalToSizedBuffer 

func (m *ContainerHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerHeartbeatRsp) ProtoMessage 

func (*ContainerHeartbeatRsp) ProtoMessage()

func (*ContainerHeartbeatRsp) Reset 

func (m *ContainerHeartbeatRsp) Reset()

func (*ContainerHeartbeatRsp) Size 

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

func (*ContainerHeartbeatRsp) String 

func (m *ContainerHeartbeatRsp) String() string

func (*ContainerHeartbeatRsp) Unmarshal 

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

func (*ContainerHeartbeatRsp) XXX_DiscardUnknown 

func (m *ContainerHeartbeatRsp) XXX_DiscardUnknown()

func (*ContainerHeartbeatRsp) XXX_Marshal 

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

func (*ContainerHeartbeatRsp) XXX_Merge 

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

func (*ContainerHeartbeatRsp) XXX_Size 

func (m *ContainerHeartbeatRsp) XXX_Size() int

func (*ContainerHeartbeatRsp) XXX_Unmarshal 

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

type ContainerStats 

type ContainerStats struct {
	// Container id
	ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	// When the container is started (unix timestamp in seconds).
	StartTime uint64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// Actually reported time interval
	Interval *TimeInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Capacity for the container.
	Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available size for the container.
	Available uint64 `protobuf:"varint,5,opt,name=available,proto3" json:"available,omitempty"`
	// Actually used space by db
	UsedSize uint64 `protobuf:"varint,6,opt,name=usedSize,proto3" json:"usedSize,omitempty"`
	// If the container is busy
	IsBusy bool `protobuf:"varint,7,opt,name=isBusy,proto3" json:"isBusy,omitempty"`
	// Total resource count in this container.
	ResourceCount uint64 `protobuf:"varint,8,opt,name=resourceCount,proto3" json:"resourceCount,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint64 `protobuf:"varint,9,opt,name=sendingSnapCount,proto3" json:"sendingSnapCount,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint64 `protobuf:"varint,10,opt,name=receivingSnapCount,proto3" json:"receivingSnapCount,omitempty"`
	// How many resource is applying snapshot.
	ApplyingSnapCount uint64 `protobuf:"varint,11,opt,name=applyingSnapCount,proto3" json:"applyingSnapCount,omitempty"`
	// Bytes written for the container during this period.
	BytesWritten uint64 `protobuf:"varint,12,opt,name=bytesWritten,proto3" json:"bytesWritten,omitempty"`
	// Bytes read for the container during this period.
	BytesRead uint64 `protobuf:"varint,13,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	// Bytes written for the container during this period.
	KeysWritten uint64 `protobuf:"varint,14,opt,name=keysWritten,proto3" json:"keysWritten,omitempty"`
	// Bytes read for the container during this period.
	KeysRead uint64 `protobuf:"varint,15,opt,name=keysRead,proto3" json:"keysRead,omitempty"`
	// Threads' CPU usages in the container
	CpuUsages []RecordPair `protobuf:"bytes,16,rep,name=cpuUsages,proto3" json:"cpuUsages"`
	// Threads' read disk I/O rates in the container
	ReadIORates []RecordPair `protobuf:"bytes,17,rep,name=readIORates,proto3" json:"readIORates"`
	// Threads' write disk I/O rates in the container
	WriteIORates []RecordPair `protobuf:"bytes,18,rep,name=writeIORates,proto3" json:"writeIORates"`
	// Operations' latencies in the container
	OpLatencies []RecordPair `protobuf:"bytes,19,rep,name=opLatencies,proto3" json:"opLatencies"`
}

ContainerStats container stats

func (*ContainerStats) Descriptor 

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

func (*ContainerStats) GetApplyingSnapCount 

func (m *ContainerStats) GetApplyingSnapCount() uint64

func (*ContainerStats) GetAvailable 

func (m *ContainerStats) GetAvailable() uint64

func (*ContainerStats) GetBytesRead 

func (m *ContainerStats) GetBytesRead() uint64

func (*ContainerStats) GetBytesWritten 

func (m *ContainerStats) GetBytesWritten() uint64

func (*ContainerStats) GetCapacity 

func (m *ContainerStats) GetCapacity() uint64

func (*ContainerStats) GetContainerID 

func (m *ContainerStats) GetContainerID() uint64

func (*ContainerStats) GetCpuUsages 

func (m *ContainerStats) GetCpuUsages() []RecordPair

func (*ContainerStats) GetInterval 

func (m *ContainerStats) GetInterval() *TimeInterval

func (*ContainerStats) GetIsBusy 

func (m *ContainerStats) GetIsBusy() bool

func (*ContainerStats) GetKeysRead 

func (m *ContainerStats) GetKeysRead() uint64

func (*ContainerStats) GetKeysWritten 

func (m *ContainerStats) GetKeysWritten() uint64

func (*ContainerStats) GetOpLatencies 

func (m *ContainerStats) GetOpLatencies() []RecordPair

func (*ContainerStats) GetReadIORates 

func (m *ContainerStats) GetReadIORates() []RecordPair

func (*ContainerStats) GetReceivingSnapCount 

func (m *ContainerStats) GetReceivingSnapCount() uint64

func (*ContainerStats) GetResourceCount 

func (m *ContainerStats) GetResourceCount() uint64

func (*ContainerStats) GetSendingSnapCount 

func (m *ContainerStats) GetSendingSnapCount() uint64

func (*ContainerStats) GetStartTime 

func (m *ContainerStats) GetStartTime() uint64

func (*ContainerStats) GetUsedSize 

func (m *ContainerStats) GetUsedSize() uint64

func (*ContainerStats) GetWriteIORates 

func (m *ContainerStats) GetWriteIORates() []RecordPair

func (*ContainerStats) Marshal 

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

func (*ContainerStats) MarshalTo 

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

func (*ContainerStats) MarshalToSizedBuffer 

func (m *ContainerStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerStats) ProtoMessage 

func (*ContainerStats) ProtoMessage()

func (*ContainerStats) Reset 

func (m *ContainerStats) Reset()

func (*ContainerStats) Size 

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

func (*ContainerStats) String 

func (m *ContainerStats) String() string

func (*ContainerStats) Unmarshal 

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

func (*ContainerStats) XXX_DiscardUnknown 

func (m *ContainerStats) XXX_DiscardUnknown()

func (*ContainerStats) XXX_Marshal 

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

func (*ContainerStats) XXX_Merge 

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

func (*ContainerStats) XXX_Size 

func (m *ContainerStats) XXX_Size() int

func (*ContainerStats) XXX_Unmarshal 

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

type CreateWatcherReq 

type CreateWatcherReq struct {
	Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
}

CreateWatcherReq create watcher req

func (*CreateWatcherReq) Descriptor 

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

func (*CreateWatcherReq) GetFlag 

func (m *CreateWatcherReq) GetFlag() uint32

func (*CreateWatcherReq) Marshal 

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

func (*CreateWatcherReq) MarshalTo 

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

func (*CreateWatcherReq) MarshalToSizedBuffer 

func (m *CreateWatcherReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateWatcherReq) ProtoMessage 

func (*CreateWatcherReq) ProtoMessage()

func (*CreateWatcherReq) Reset 

func (m *CreateWatcherReq) Reset()

func (*CreateWatcherReq) Size 

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

func (*CreateWatcherReq) String 

func (m *CreateWatcherReq) String() string

func (*CreateWatcherReq) Unmarshal 

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

func (*CreateWatcherReq) XXX_DiscardUnknown 

func (m *CreateWatcherReq) XXX_DiscardUnknown()

func (*CreateWatcherReq) XXX_Marshal 

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

func (*CreateWatcherReq) XXX_Merge 

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

func (*CreateWatcherReq) XXX_Size 

func (m *CreateWatcherReq) XXX_Size() int

func (*CreateWatcherReq) XXX_Unmarshal 

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

type EventNotify 

type EventNotify struct {
	Seq                uint64                  `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Type               uint32                  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	InitEvent          *InitEventData          `protobuf:"bytes,3,opt,name=initEvent,proto3" json:"initEvent,omitempty"`
	ResourceEvent      *ResourceEventData      `protobuf:"bytes,4,opt,name=resourceEvent,proto3" json:"resourceEvent,omitempty"`
	ContainerEvent     *ContainerEventData     `protobuf:"bytes,5,opt,name=containerEvent,proto3" json:"containerEvent,omitempty"`
	LeaderChangedEvent *LeaderChangedEventData `protobuf:"bytes,6,opt,name=leaderChangedEvent,proto3" json:"leaderChangedEvent,omitempty"`
}

EventNotify event notify

func (*EventNotify) Descriptor 

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

func (*EventNotify) GetContainerEvent 

func (m *EventNotify) GetContainerEvent() *ContainerEventData

func (*EventNotify) GetInitEvent 

func (m *EventNotify) GetInitEvent() *InitEventData

func (*EventNotify) GetLeaderChangedEvent 

func (m *EventNotify) GetLeaderChangedEvent() *LeaderChangedEventData

func (*EventNotify) GetResourceEvent 

func (m *EventNotify) GetResourceEvent() *ResourceEventData

func (*EventNotify) GetSeq 

func (m *EventNotify) GetSeq() uint64

func (*EventNotify) GetType 

func (m *EventNotify) GetType() uint32

func (*EventNotify) Marshal 

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

func (*EventNotify) MarshalTo 

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

func (*EventNotify) MarshalToSizedBuffer 

func (m *EventNotify) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventNotify) ProtoMessage 

func (*EventNotify) ProtoMessage()

func (*EventNotify) Reset 

func (m *EventNotify) Reset()

func (*EventNotify) Size 

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

func (*EventNotify) String 

func (m *EventNotify) String() string

func (*EventNotify) Unmarshal 

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

func (*EventNotify) XXX_DiscardUnknown 

func (m *EventNotify) XXX_DiscardUnknown()

func (*EventNotify) XXX_Marshal 

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

func (*EventNotify) XXX_Merge 

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

func (*EventNotify) XXX_Size 

func (m *EventNotify) XXX_Size() int

func (*EventNotify) XXX_Unmarshal 

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

type GetContainerReq 

type GetContainerReq struct {
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

GetContainerReq get container request

func (*GetContainerReq) Descriptor 

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

func (*GetContainerReq) GetID 

func (m *GetContainerReq) GetID() uint64

func (*GetContainerReq) Marshal 

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

func (*GetContainerReq) MarshalTo 

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

func (*GetContainerReq) MarshalToSizedBuffer 

func (m *GetContainerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetContainerReq) ProtoMessage 

func (*GetContainerReq) ProtoMessage()

func (*GetContainerReq) Reset 

func (m *GetContainerReq) Reset()

func (*GetContainerReq) Size 

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

func (*GetContainerReq) String 

func (m *GetContainerReq) String() string

func (*GetContainerReq) Unmarshal 

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

func (*GetContainerReq) XXX_DiscardUnknown 

func (m *GetContainerReq) XXX_DiscardUnknown()

func (*GetContainerReq) XXX_Marshal 

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

func (*GetContainerReq) XXX_Merge 

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

func (*GetContainerReq) XXX_Size 

func (m *GetContainerReq) XXX_Size() int

func (*GetContainerReq) XXX_Unmarshal 

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

type GetContainerRsp 

type GetContainerRsp struct {
	Data  []byte          `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Stats *ContainerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
}

GetContainerRsp get container response

func (*GetContainerRsp) Descriptor 

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

func (*GetContainerRsp) GetData 

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

func (*GetContainerRsp) GetStats 

func (m *GetContainerRsp) GetStats() *ContainerStats

func (*GetContainerRsp) Marshal 

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

func (*GetContainerRsp) MarshalTo 

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

func (*GetContainerRsp) MarshalToSizedBuffer 

func (m *GetContainerRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetContainerRsp) ProtoMessage 

func (*GetContainerRsp) ProtoMessage()

func (*GetContainerRsp) Reset 

func (m *GetContainerRsp) Reset()

func (*GetContainerRsp) Size 

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

func (*GetContainerRsp) String 

func (m *GetContainerRsp) String() string

func (*GetContainerRsp) Unmarshal 

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

func (*GetContainerRsp) XXX_DiscardUnknown 

func (m *GetContainerRsp) XXX_DiscardUnknown()

func (*GetContainerRsp) XXX_Marshal 

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

func (*GetContainerRsp) XXX_Merge 

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

func (*GetContainerRsp) XXX_Size 

func (m *GetContainerRsp) XXX_Size() int

func (*GetContainerRsp) XXX_Unmarshal 

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

type GetDCLocationsReq 

type GetDCLocationsReq struct {
}

GetDCLocationsReq get dc locations request

func (*GetDCLocationsReq) Descriptor 

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

func (*GetDCLocationsReq) Marshal 

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

func (*GetDCLocationsReq) MarshalTo 

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

func (*GetDCLocationsReq) MarshalToSizedBuffer 

func (m *GetDCLocationsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDCLocationsReq) ProtoMessage 

func (*GetDCLocationsReq) ProtoMessage()

func (*GetDCLocationsReq) Reset 

func (m *GetDCLocationsReq) Reset()

func (*GetDCLocationsReq) Size 

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

func (*GetDCLocationsReq) String 

func (m *GetDCLocationsReq) String() string

func (*GetDCLocationsReq) Unmarshal 

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

func (*GetDCLocationsReq) XXX_DiscardUnknown 

func (m *GetDCLocationsReq) XXX_DiscardUnknown()

func (*GetDCLocationsReq) XXX_Marshal 

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

func (*GetDCLocationsReq) XXX_Merge 

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

func (*GetDCLocationsReq) XXX_Size 

func (m *GetDCLocationsReq) XXX_Size() int

func (*GetDCLocationsReq) XXX_Unmarshal 

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

type GetDCLocationsRsp 

type GetDCLocationsRsp struct {
	DCLocations map[string]int32 `` /* 164-byte string literal not displayed */
}

GetDCLocationsRsp get dc locations response

func (*GetDCLocationsRsp) Descriptor 

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

func (*GetDCLocationsRsp) GetDCLocations 

func (m *GetDCLocationsRsp) GetDCLocations() map[string]int32

func (*GetDCLocationsRsp) Marshal 

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

func (*GetDCLocationsRsp) MarshalTo 

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

func (*GetDCLocationsRsp) MarshalToSizedBuffer 

func (m *GetDCLocationsRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDCLocationsRsp) ProtoMessage 

func (*GetDCLocationsRsp) ProtoMessage()

func (*GetDCLocationsRsp) Reset 

func (m *GetDCLocationsRsp) Reset()

func (*GetDCLocationsRsp) Size 

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

func (*GetDCLocationsRsp) String 

func (m *GetDCLocationsRsp) String() string

func (*GetDCLocationsRsp) Unmarshal 

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

func (*GetDCLocationsRsp) XXX_DiscardUnknown 

func (m *GetDCLocationsRsp) XXX_DiscardUnknown()

func (*GetDCLocationsRsp) XXX_Marshal 

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

func (*GetDCLocationsRsp) XXX_Merge 

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

func (*GetDCLocationsRsp) XXX_Size 

func (m *GetDCLocationsRsp) XXX_Size() int

func (*GetDCLocationsRsp) XXX_Unmarshal 

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

type InitEventData 

type InitEventData struct {
	Resources  [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	Leaders    []uint64 `protobuf:"varint,2,rep,packed,name=leaders,proto3" json:"leaders,omitempty"`
	Containers [][]byte `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
}

InitEventData init event data

func (*InitEventData) Descriptor 

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

func (*InitEventData) GetContainers 

func (m *InitEventData) GetContainers() [][]byte

func (*InitEventData) GetLeaders 

func (m *InitEventData) GetLeaders() []uint64

func (*InitEventData) GetResources 

func (m *InitEventData) GetResources() [][]byte

func (*InitEventData) Marshal 

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

func (*InitEventData) MarshalTo 

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

func (*InitEventData) MarshalToSizedBuffer 

func (m *InitEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InitEventData) ProtoMessage 

func (*InitEventData) ProtoMessage()

func (*InitEventData) Reset 

func (m *InitEventData) Reset()

func (*InitEventData) Size 

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

func (*InitEventData) String 

func (m *InitEventData) String() string

func (*InitEventData) Unmarshal 

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

func (*InitEventData) XXX_DiscardUnknown 

func (m *InitEventData) XXX_DiscardUnknown()

func (*InitEventData) XXX_Marshal 

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

func (*InitEventData) XXX_Merge 

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

func (*InitEventData) XXX_Size 

func (m *InitEventData) XXX_Size() int

func (*InitEventData) XXX_Unmarshal 

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

type LeaderChangedEventData 

type LeaderChangedEventData struct {
	ResourceID uint64 `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"`
	LeaderID   uint64 `protobuf:"varint,2,opt,name=leaderID,proto3" json:"leaderID,omitempty"`
}

LeaderChangedEventData leader changed

func (*LeaderChangedEventData) Descriptor 

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

func (*LeaderChangedEventData) GetLeaderID 

func (m *LeaderChangedEventData) GetLeaderID() uint64

func (*LeaderChangedEventData) GetResourceID 

func (m *LeaderChangedEventData) GetResourceID() uint64

func (*LeaderChangedEventData) Marshal 

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

func (*LeaderChangedEventData) MarshalTo 

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

func (*LeaderChangedEventData) MarshalToSizedBuffer 

func (m *LeaderChangedEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaderChangedEventData) ProtoMessage 

func (*LeaderChangedEventData) ProtoMessage()

func (*LeaderChangedEventData) Reset 

func (m *LeaderChangedEventData) Reset()

func (*LeaderChangedEventData) Size 

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

func (*LeaderChangedEventData) String 

func (m *LeaderChangedEventData) String() string

func (*LeaderChangedEventData) Unmarshal 

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

func (*LeaderChangedEventData) XXX_DiscardUnknown 

func (m *LeaderChangedEventData) XXX_DiscardUnknown()

func (*LeaderChangedEventData) XXX_Marshal 

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

func (*LeaderChangedEventData) XXX_Merge 

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

func (*LeaderChangedEventData) XXX_Size 

func (m *LeaderChangedEventData) XXX_Size() int

func (*LeaderChangedEventData) XXX_Unmarshal 

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

type Merge 

type Merge struct {
	// target resource
	Target []byte `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
}

Merge merge

func (*Merge) Descriptor 

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

func (*Merge) GetTarget 

func (m *Merge) GetTarget() []byte

func (*Merge) Marshal 

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

func (*Merge) MarshalTo 

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

func (*Merge) MarshalToSizedBuffer 

func (m *Merge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Merge) ProtoMessage 

func (*Merge) ProtoMessage()

func (*Merge) Reset 

func (m *Merge) Reset()

func (*Merge) Size 

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

func (*Merge) String 

func (m *Merge) String() string

func (*Merge) Unmarshal 

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

func (*Merge) XXX_DiscardUnknown 

func (m *Merge) XXX_DiscardUnknown()

func (*Merge) XXX_Marshal 

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

func (*Merge) XXX_Merge 

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

func (*Merge) XXX_Size 

func (m *Merge) XXX_Size() int

func (*Merge) XXX_Unmarshal 

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

type RecordPair 

type RecordPair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value uint64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

RecordPair record pair

func (*RecordPair) Descriptor 

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

func (*RecordPair) GetKey 

func (m *RecordPair) GetKey() string

func (*RecordPair) GetValue 

func (m *RecordPair) GetValue() uint64

func (*RecordPair) Marshal 

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

func (*RecordPair) MarshalTo 

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

func (*RecordPair) MarshalToSizedBuffer 

func (m *RecordPair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordPair) ProtoMessage 

func (*RecordPair) ProtoMessage()

func (*RecordPair) Reset 

func (m *RecordPair) Reset()

func (*RecordPair) Size 

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

func (*RecordPair) String 

func (m *RecordPair) String() string

func (*RecordPair) Unmarshal 

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

func (*RecordPair) XXX_DiscardUnknown 

func (m *RecordPair) XXX_DiscardUnknown()

func (*RecordPair) XXX_Marshal 

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

func (*RecordPair) XXX_Merge 

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

func (*RecordPair) XXX_Size 

func (m *RecordPair) XXX_Size() int

func (*RecordPair) XXX_Unmarshal 

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

type ReportSplitReq 

type ReportSplitReq struct {
	Left  []byte `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"`
	Right []byte `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"`
}

ReportSplitReq report split request

func (*ReportSplitReq) Descriptor 

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

func (*ReportSplitReq) GetLeft 

func (m *ReportSplitReq) GetLeft() []byte

func (*ReportSplitReq) GetRight 

func (m *ReportSplitReq) GetRight() []byte

func (*ReportSplitReq) Marshal 

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

func (*ReportSplitReq) MarshalTo 

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

func (*ReportSplitReq) MarshalToSizedBuffer 

func (m *ReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReportSplitReq) ProtoMessage 

func (*ReportSplitReq) ProtoMessage()

func (*ReportSplitReq) Reset 

func (m *ReportSplitReq) Reset()

func (*ReportSplitReq) Size 

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

func (*ReportSplitReq) String 

func (m *ReportSplitReq) String() string

func (*ReportSplitReq) Unmarshal 

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

func (*ReportSplitReq) XXX_DiscardUnknown 

func (m *ReportSplitReq) XXX_DiscardUnknown()

func (*ReportSplitReq) XXX_Marshal 

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

func (*ReportSplitReq) XXX_Merge 

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

func (*ReportSplitReq) XXX_Size 

func (m *ReportSplitReq) XXX_Size() int

func (*ReportSplitReq) XXX_Unmarshal 

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

type ReportSplitRsp 

type ReportSplitRsp struct {
}

ReportSplitRsp report split response

func (*ReportSplitRsp) Descriptor 

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

func (*ReportSplitRsp) Marshal 

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

func (*ReportSplitRsp) MarshalTo 

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

func (*ReportSplitRsp) MarshalToSizedBuffer 

func (m *ReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReportSplitRsp) ProtoMessage 

func (*ReportSplitRsp) ProtoMessage()

func (*ReportSplitRsp) Reset 

func (m *ReportSplitRsp) Reset()

func (*ReportSplitRsp) Size 

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

func (*ReportSplitRsp) String 

func (m *ReportSplitRsp) String() string

func (*ReportSplitRsp) Unmarshal 

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

func (*ReportSplitRsp) XXX_DiscardUnknown 

func (m *ReportSplitRsp) XXX_DiscardUnknown()

func (*ReportSplitRsp) XXX_Marshal 

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

func (*ReportSplitRsp) XXX_Merge 

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

func (*ReportSplitRsp) XXX_Size 

func (m *ReportSplitRsp) XXX_Size() int

func (*ReportSplitRsp) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID                 uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ContainerID        uint64                `protobuf:"varint,2,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Type               Type                  `protobuf:"varint,3,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	ResourceHeartbeat  ResourceHeartbeatReq  `protobuf:"bytes,4,opt,name=ResourceHeartbeat,proto3" json:"ResourceHeartbeat"`
	ContainerHeartbeat ContainerHeartbeatReq `protobuf:"bytes,5,opt,name=ContainerHeartbeat,proto3" json:"ContainerHeartbeat"`
	GetContainer       GetContainerReq       `protobuf:"bytes,6,opt,name=GetContainer,proto3" json:"GetContainer"`
	AllocID            AllocIDReq            `protobuf:"bytes,7,opt,name=AllocID,proto3" json:"AllocID"`
	AskSplit           AskSplitReq           `protobuf:"bytes,8,opt,name=AskSplit,proto3" json:"AskSplit"`
	AskBatchSplit      AskBatchSplitReq      `protobuf:"bytes,9,opt,name=AskBatchSplit,proto3" json:"AskBatchSplit"`
	ReportSplit        ReportSplitReq        `protobuf:"bytes,10,opt,name=ReportSplit,proto3" json:"ReportSplit"`
	BatchReportSplit   BatchReportSplitReq   `protobuf:"bytes,11,opt,name=BatchReportSplit,proto3" json:"BatchReportSplit"`
	TSO                TSOReq                `protobuf:"bytes,12,opt,name=TSO,proto3" json:"TSO"`
	CreateWatcher      CreateWatcherReq      `protobuf:"bytes,13,opt,name=CreateWatcher,proto3" json:"CreateWatcher"`
	GetDCLocations     GetDCLocationsReq     `protobuf:"bytes,14,opt,name=GetDCLocations,proto3" json:"GetDCLocations"`
}

Request the prophet rpc request

func (*Request) Descriptor 

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

func (*Request) GetAllocID 

func (m *Request) GetAllocID() AllocIDReq

func (*Request) GetAskBatchSplit 

func (m *Request) GetAskBatchSplit() AskBatchSplitReq

func (*Request) GetAskSplit 

func (m *Request) GetAskSplit() AskSplitReq

func (*Request) GetBatchReportSplit 

func (m *Request) GetBatchReportSplit() BatchReportSplitReq

func (*Request) GetContainerHeartbeat 

func (m *Request) GetContainerHeartbeat() ContainerHeartbeatReq

func (*Request) GetContainerID 

func (m *Request) GetContainerID() uint64

func (*Request) GetCreateWatcher 

func (m *Request) GetCreateWatcher() CreateWatcherReq

func (*Request) GetGetContainer 

func (m *Request) GetGetContainer() GetContainerReq

func (*Request) GetGetDCLocations 

func (m *Request) GetGetDCLocations() GetDCLocationsReq

func (*Request) GetID 

func (m *Request) GetID() uint64

func (*Request) GetReportSplit 

func (m *Request) GetReportSplit() ReportSplitReq

func (*Request) GetResourceHeartbeat 

func (m *Request) GetResourceHeartbeat() ResourceHeartbeatReq

func (*Request) GetTSO 

func (m *Request) GetTSO() TSOReq

func (*Request) GetType 

func (m *Request) GetType() Type

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type ResourceEventData 

type ResourceEventData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

ResourceEventData resource created or updated

func (*ResourceEventData) Descriptor 

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

func (*ResourceEventData) GetData 

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

func (*ResourceEventData) Marshal 

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

func (*ResourceEventData) MarshalTo 

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

func (*ResourceEventData) MarshalToSizedBuffer 

func (m *ResourceEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceEventData) ProtoMessage 

func (*ResourceEventData) ProtoMessage()

func (*ResourceEventData) Reset 

func (m *ResourceEventData) Reset()

func (*ResourceEventData) Size 

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

func (*ResourceEventData) String 

func (m *ResourceEventData) String() string

func (*ResourceEventData) Unmarshal 

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

func (*ResourceEventData) XXX_DiscardUnknown 

func (m *ResourceEventData) XXX_DiscardUnknown()

func (*ResourceEventData) XXX_Marshal 

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

func (*ResourceEventData) XXX_Merge 

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

func (*ResourceEventData) XXX_Size 

func (m *ResourceEventData) XXX_Size() int

func (*ResourceEventData) XXX_Unmarshal 

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

type ResourceHeartbeatReq 

type ResourceHeartbeatReq struct {
	ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Resource    []byte `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// Term is the term of raft group.
	Term         uint64             `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	Leader       *metapb.Peer       `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	DownPeers    []metapb.PeerStats `protobuf:"bytes,5,rep,name=downPeers,proto3" json:"downPeers"`
	PendingPeers []metapb.Peer      `protobuf:"bytes,6,rep,name=pendingPeers,proto3" json:"pendingPeers"`
	// Bytes read/written during this period.
	BytesWritten uint64 `protobuf:"varint,7,opt,name=bytesWritten,proto3" json:"bytesWritten,omitempty"`
	BytesRead    uint64 `protobuf:"varint,8,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	// Keys read/written during this period.
	KeysWritten uint64 `protobuf:"varint,9,opt,name=keysWritten,proto3" json:"keysWritten,omitempty"`
	KeysRead    uint64 `protobuf:"varint,10,opt,name=keysRead,proto3" json:"keysRead,omitempty"`
	// Approximate  resource size in bytes.
	ApproximateSize uint64 `protobuf:"varint,11,opt,name=approximateSize,proto3" json:"approximateSize,omitempty"`
	// Approximate keys that resource contains.
	ApproximateKeys uint64 `protobuf:"varint,12,opt,name=approximateKeys,proto3" json:"approximateKeys,omitempty"`
	// Actually reported time interval
	Interval *TimeInterval `protobuf:"bytes,13,opt,name=interval,proto3" json:"interval,omitempty"`
}

ResourceHeartbeatReq resource heartbeat request

func (*ResourceHeartbeatReq) Descriptor 

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

func (*ResourceHeartbeatReq) GetApproximateKeys 

func (m *ResourceHeartbeatReq) GetApproximateKeys() uint64

func (*ResourceHeartbeatReq) GetApproximateSize 

func (m *ResourceHeartbeatReq) GetApproximateSize() uint64

func (*ResourceHeartbeatReq) GetBytesRead 

func (m *ResourceHeartbeatReq) GetBytesRead() uint64

func (*ResourceHeartbeatReq) GetBytesWritten 

func (m *ResourceHeartbeatReq) GetBytesWritten() uint64

func (*ResourceHeartbeatReq) GetContainerID 

func (m *ResourceHeartbeatReq) GetContainerID() uint64

func (*ResourceHeartbeatReq) GetDownPeers 

func (m *ResourceHeartbeatReq) GetDownPeers() []metapb.PeerStats

func (*ResourceHeartbeatReq) GetInterval 

func (m *ResourceHeartbeatReq) GetInterval() *TimeInterval

func (*ResourceHeartbeatReq) GetKeysRead 

func (m *ResourceHeartbeatReq) GetKeysRead() uint64

func (*ResourceHeartbeatReq) GetKeysWritten 

func (m *ResourceHeartbeatReq) GetKeysWritten() uint64

func (*ResourceHeartbeatReq) GetLeader 

func (m *ResourceHeartbeatReq) GetLeader() *metapb.Peer

func (*ResourceHeartbeatReq) GetPendingPeers 

func (m *ResourceHeartbeatReq) GetPendingPeers() []metapb.Peer

func (*ResourceHeartbeatReq) GetResource 

func (m *ResourceHeartbeatReq) GetResource() []byte

func (*ResourceHeartbeatReq) GetTerm 

func (m *ResourceHeartbeatReq) GetTerm() uint64

func (*ResourceHeartbeatReq) Marshal 

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

func (*ResourceHeartbeatReq) MarshalTo 

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

func (*ResourceHeartbeatReq) MarshalToSizedBuffer 

func (m *ResourceHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceHeartbeatReq) ProtoMessage 

func (*ResourceHeartbeatReq) ProtoMessage()

func (*ResourceHeartbeatReq) Reset 

func (m *ResourceHeartbeatReq) Reset()

func (*ResourceHeartbeatReq) Size 

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

func (*ResourceHeartbeatReq) String 

func (m *ResourceHeartbeatReq) String() string

func (*ResourceHeartbeatReq) Unmarshal 

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

func (*ResourceHeartbeatReq) XXX_DiscardUnknown 

func (m *ResourceHeartbeatReq) XXX_DiscardUnknown()

func (*ResourceHeartbeatReq) XXX_Marshal 

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

func (*ResourceHeartbeatReq) XXX_Merge 

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

func (*ResourceHeartbeatReq) XXX_Size 

func (m *ResourceHeartbeatReq) XXX_Size() int

func (*ResourceHeartbeatReq) XXX_Unmarshal 

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

type ResourceHeartbeatRsp 

type ResourceHeartbeatRsp struct {
	ResourceID    uint64               `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"`
	ResourceEpoch metapb.ResourceEpoch `protobuf:"bytes,2,opt,name=resourceEpoch,proto3" json:"resourceEpoch"`
	// Leader of the resource at the moment of the corresponding request was made.
	TargetPeer *metapb.Peer `protobuf:"bytes,3,opt,name=targetPeer,proto3" json:"targetPeer,omitempty"`
	// Notice, prophet only allows handling reported epoch >= current prophet's.
	// Leader peer reports resource status with ResourceHeartbeatReq
	// to prophet regularly, prophet will determine whether this resource
	// should do ChangePeer or not.
	// E,g, max peer number is 3, resource A, first only peer 1 in A.
	// 1. prophet resource state -> Peers (1), ConfVer (1).
	// 2. Leader peer 1 reports resource state to prophet, prophet finds the
	// peer number is < 3, so first changes its current resource
	// state -> Peers (1, 2), ConfVer (1), and returns ChangePeer Adding 2.
	// 3. Leader does ChangePeer, then reports Peers (1, 2), ConfVer (2),
	// prophet updates its state -> Peers (1, 2), ConfVer (2).
	// 4. Leader may report old Peers (1), ConfVer (1) to pd before ConfChange
	// finished, pd stills responses ChangePeer Adding 2, of course, we must
	// guarantee the second ChangePeer can't be applied in your application.
	ChangePeer     *ChangePeer     `protobuf:"bytes,4,opt,name=changePeer,proto3" json:"changePeer,omitempty"`
	TransferLeader *TransferLeader `protobuf:"bytes,5,opt,name=transferLeader,proto3" json:"transferLeader,omitempty"`
	Merge          *Merge          `protobuf:"bytes,6,opt,name=merge,proto3" json:"merge,omitempty"`
	SplitResource  *SplitResource  `protobuf:"bytes,7,opt,name=splitResource,proto3" json:"splitResource,omitempty"`
	ChangePeerV2   *ChangePeerV2   `protobuf:"bytes,8,opt,name=changePeerV2,proto3" json:"changePeerV2,omitempty"`
}

ResourceHeartbeatRsp resource heartbeat response.

func (*ResourceHeartbeatRsp) Descriptor 

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

func (*ResourceHeartbeatRsp) GetChangePeer 

func (m *ResourceHeartbeatRsp) GetChangePeer() *ChangePeer

func (*ResourceHeartbeatRsp) GetChangePeerV2 

func (m *ResourceHeartbeatRsp) GetChangePeerV2() *ChangePeerV2

func (*ResourceHeartbeatRsp) GetMerge 

func (m *ResourceHeartbeatRsp) GetMerge() *Merge

func (*ResourceHeartbeatRsp) GetResourceEpoch 

func (m *ResourceHeartbeatRsp) GetResourceEpoch() metapb.ResourceEpoch

func (*ResourceHeartbeatRsp) GetResourceID 

func (m *ResourceHeartbeatRsp) GetResourceID() uint64

func (*ResourceHeartbeatRsp) GetSplitResource 

func (m *ResourceHeartbeatRsp) GetSplitResource() *SplitResource

func (*ResourceHeartbeatRsp) GetTargetPeer 

func (m *ResourceHeartbeatRsp) GetTargetPeer() *metapb.Peer

func (*ResourceHeartbeatRsp) GetTransferLeader 

func (m *ResourceHeartbeatRsp) GetTransferLeader() *TransferLeader

func (*ResourceHeartbeatRsp) Marshal 

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

func (*ResourceHeartbeatRsp) MarshalTo 

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

func (*ResourceHeartbeatRsp) MarshalToSizedBuffer 

func (m *ResourceHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceHeartbeatRsp) ProtoMessage 

func (*ResourceHeartbeatRsp) ProtoMessage()

func (*ResourceHeartbeatRsp) Reset 

func (m *ResourceHeartbeatRsp) Reset()

func (*ResourceHeartbeatRsp) Size 

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

func (*ResourceHeartbeatRsp) String 

func (m *ResourceHeartbeatRsp) String() string

func (*ResourceHeartbeatRsp) Unmarshal 

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

func (*ResourceHeartbeatRsp) XXX_DiscardUnknown 

func (m *ResourceHeartbeatRsp) XXX_DiscardUnknown()

func (*ResourceHeartbeatRsp) XXX_Marshal 

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

func (*ResourceHeartbeatRsp) XXX_Merge 

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

func (*ResourceHeartbeatRsp) XXX_Size 

func (m *ResourceHeartbeatRsp) XXX_Size() int

func (*ResourceHeartbeatRsp) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID                 uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type               Type                  `protobuf:"varint,2,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	Error              string                `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Leader             string                `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	ResourceHeartbeat  ResourceHeartbeatRsp  `protobuf:"bytes,5,opt,name=ResourceHeartbeat,proto3" json:"ResourceHeartbeat"`
	ContainerHeartbeat ContainerHeartbeatRsp `protobuf:"bytes,6,opt,name=ContainerHeartbeat,proto3" json:"ContainerHeartbeat"`
	GetContainer       GetContainerRsp       `protobuf:"bytes,7,opt,name=GetContainer,proto3" json:"GetContainer"`
	AllocID            AllocIDRsp            `protobuf:"bytes,8,opt,name=AllocID,proto3" json:"AllocID"`
	AskSplit           AskSplitRsp           `protobuf:"bytes,9,opt,name=AskSplit,proto3" json:"AskSplit"`
	AskBatchSplit      AskBatchSplitRsp      `protobuf:"bytes,10,opt,name=AskBatchSplit,proto3" json:"AskBatchSplit"`
	ReportSplit        ReportSplitRsp        `protobuf:"bytes,11,opt,name=ReportSplit,proto3" json:"ReportSplit"`
	BatchReportSplit   BatchReportSplitRsp   `protobuf:"bytes,12,opt,name=BatchReportSplit,proto3" json:"BatchReportSplit"`
	TSO                TSORsp                `protobuf:"bytes,13,opt,name=TSO,proto3" json:"TSO"`
	Event              EventNotify           `protobuf:"bytes,14,opt,name=Event,proto3" json:"Event"`
	GetDCLocations     GetDCLocationsRsp     `protobuf:"bytes,15,opt,name=GetDCLocations,proto3" json:"GetDCLocations"`
}

Response the prophet rpc response

func (*Response) Descriptor 

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

func (*Response) GetAllocID 

func (m *Response) GetAllocID() AllocIDRsp

func (*Response) GetAskBatchSplit 

func (m *Response) GetAskBatchSplit() AskBatchSplitRsp

func (*Response) GetAskSplit 

func (m *Response) GetAskSplit() AskSplitRsp

func (*Response) GetBatchReportSplit 

func (m *Response) GetBatchReportSplit() BatchReportSplitRsp

func (*Response) GetContainerHeartbeat 

func (m *Response) GetContainerHeartbeat() ContainerHeartbeatRsp

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetEvent 

func (m *Response) GetEvent() EventNotify

func (*Response) GetGetContainer 

func (m *Response) GetGetContainer() GetContainerRsp

func (*Response) GetGetDCLocations 

func (m *Response) GetGetDCLocations() GetDCLocationsRsp

func (*Response) GetID 

func (m *Response) GetID() uint64

func (*Response) GetLeader 

func (m *Response) GetLeader() string

func (*Response) GetReportSplit 

func (m *Response) GetReportSplit() ReportSplitRsp

func (*Response) GetResourceHeartbeat 

func (m *Response) GetResourceHeartbeat() ResourceHeartbeatRsp

func (*Response) GetTSO 

func (m *Response) GetTSO() TSORsp

func (*Response) GetType 

func (m *Response) GetType() Type

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SplitID 

type SplitID struct {
	NewID      uint64   `protobuf:"varint,1,opt,name=newID,proto3" json:"newID,omitempty"`
	NewPeerIDs []uint64 `protobuf:"varint,2,rep,packed,name=newPeerIDs,proto3" json:"newPeerIDs,omitempty"`
}

SplitID split id

func (*SplitID) Descriptor 

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

func (*SplitID) GetNewID 

func (m *SplitID) GetNewID() uint64

func (*SplitID) GetNewPeerIDs 

func (m *SplitID) GetNewPeerIDs() []uint64

func (*SplitID) Marshal 

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

func (*SplitID) MarshalTo 

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

func (*SplitID) MarshalToSizedBuffer 

func (m *SplitID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SplitID) ProtoMessage 

func (*SplitID) ProtoMessage()

func (*SplitID) Reset 

func (m *SplitID) Reset()

func (*SplitID) Size 

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

func (*SplitID) String 

func (m *SplitID) String() string

func (*SplitID) Unmarshal 

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

func (*SplitID) XXX_DiscardUnknown 

func (m *SplitID) XXX_DiscardUnknown()

func (*SplitID) XXX_Marshal 

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

func (*SplitID) XXX_Merge 

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

func (*SplitID) XXX_Size 

func (m *SplitID) XXX_Size() int

func (*SplitID) XXX_Unmarshal 

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

type SplitResource 

type SplitResource struct {
	Policy metapb.CheckPolicy `protobuf:"varint,1,opt,name=policy,proto3,enum=metapb.CheckPolicy" json:"policy,omitempty"`
	Keys   [][]byte           `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
}

SplitResource split resource

func (*SplitResource) Descriptor 

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

func (*SplitResource) GetKeys 

func (m *SplitResource) GetKeys() [][]byte

func (*SplitResource) GetPolicy 

func (m *SplitResource) GetPolicy() metapb.CheckPolicy

func (*SplitResource) Marshal 

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

func (*SplitResource) MarshalTo 

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

func (*SplitResource) MarshalToSizedBuffer 

func (m *SplitResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SplitResource) ProtoMessage 

func (*SplitResource) ProtoMessage()

func (*SplitResource) Reset 

func (m *SplitResource) Reset()

func (*SplitResource) Size 

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

func (*SplitResource) String 

func (m *SplitResource) String() string

func (*SplitResource) Unmarshal 

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

func (*SplitResource) XXX_DiscardUnknown 

func (m *SplitResource) XXX_DiscardUnknown()

func (*SplitResource) XXX_Marshal 

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

func (*SplitResource) XXX_Merge 

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

func (*SplitResource) XXX_Size 

func (m *SplitResource) XXX_Size() int

func (*SplitResource) XXX_Unmarshal 

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

type TSOReq 

type TSOReq struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

TSOReq get tso request

func (*TSOReq) Descriptor 

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

func (*TSOReq) GetCount 

func (m *TSOReq) GetCount() uint32

func (*TSOReq) Marshal 

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

func (*TSOReq) MarshalTo 

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

func (*TSOReq) MarshalToSizedBuffer 

func (m *TSOReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TSOReq) ProtoMessage 

func (*TSOReq) ProtoMessage()

func (*TSOReq) Reset 

func (m *TSOReq) Reset()

func (*TSOReq) Size 

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

func (*TSOReq) String 

func (m *TSOReq) String() string

func (*TSOReq) Unmarshal 

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

func (*TSOReq) XXX_DiscardUnknown 

func (m *TSOReq) XXX_DiscardUnknown()

func (*TSOReq) XXX_Marshal 

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

func (*TSOReq) XXX_Merge 

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

func (*TSOReq) XXX_Size 

func (m *TSOReq) XXX_Size() int

func (*TSOReq) XXX_Unmarshal 

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

type TSORsp 

type TSORsp struct {
	Count     uint32            `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Timestamp *metapb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

TSORsp get tso response

func (*TSORsp) Descriptor 

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

func (*TSORsp) GetCount 

func (m *TSORsp) GetCount() uint32

func (*TSORsp) GetTimestamp 

func (m *TSORsp) GetTimestamp() *metapb.Timestamp

func (*TSORsp) Marshal 

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

func (*TSORsp) MarshalTo 

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

func (*TSORsp) MarshalToSizedBuffer 

func (m *TSORsp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TSORsp) ProtoMessage 

func (*TSORsp) ProtoMessage()

func (*TSORsp) Reset 

func (m *TSORsp) Reset()

func (*TSORsp) Size 

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

func (*TSORsp) String 

func (m *TSORsp) String() string

func (*TSORsp) Unmarshal 

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

func (*TSORsp) XXX_DiscardUnknown 

func (m *TSORsp) XXX_DiscardUnknown()

func (*TSORsp) XXX_Marshal 

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

func (*TSORsp) XXX_Merge 

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

func (*TSORsp) XXX_Size 

func (m *TSORsp) XXX_Size() int

func (*TSORsp) XXX_Unmarshal 

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

type TimeInterval 

type TimeInterval struct {
	// The unix timestamp in seconds of the start of this period.
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// The unix timestamp in seconds of the end of this period.
	End uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
}

TimeInterval time interval

func (*TimeInterval) Descriptor 

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

func (*TimeInterval) GetEnd 

func (m *TimeInterval) GetEnd() uint64

func (*TimeInterval) GetStart 

func (m *TimeInterval) GetStart() uint64

func (*TimeInterval) Marshal 

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

func (*TimeInterval) MarshalTo 

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

func (*TimeInterval) MarshalToSizedBuffer 

func (m *TimeInterval) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeInterval) ProtoMessage 

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) Reset 

func (m *TimeInterval) Reset()

func (*TimeInterval) Size 

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

func (*TimeInterval) String 

func (m *TimeInterval) String() string

func (*TimeInterval) Unmarshal 

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

func (*TimeInterval) XXX_DiscardUnknown 

func (m *TimeInterval) XXX_DiscardUnknown()

func (*TimeInterval) XXX_Marshal 

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

func (*TimeInterval) XXX_Merge 

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

func (*TimeInterval) XXX_Size 

func (m *TimeInterval) XXX_Size() int

func (*TimeInterval) XXX_Unmarshal 

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

type TransferLeader 

type TransferLeader struct {
	Peer metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
}

TransferLeader transfer leader

func (*TransferLeader) Descriptor 

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

func (*TransferLeader) GetPeer 

func (m *TransferLeader) GetPeer() metapb.Peer

func (*TransferLeader) Marshal 

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

func (*TransferLeader) MarshalTo 

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

func (*TransferLeader) MarshalToSizedBuffer 

func (m *TransferLeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransferLeader) ProtoMessage 

func (*TransferLeader) ProtoMessage()

func (*TransferLeader) Reset 

func (m *TransferLeader) Reset()

func (*TransferLeader) Size 

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

func (*TransferLeader) String 

func (m *TransferLeader) String() string

func (*TransferLeader) Unmarshal 

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

func (*TransferLeader) XXX_DiscardUnknown 

func (m *TransferLeader) XXX_DiscardUnknown()

func (*TransferLeader) XXX_Marshal 

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

func (*TransferLeader) XXX_Merge 

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

func (*TransferLeader) XXX_Size 

func (m *TransferLeader) XXX_Size() int

func (*TransferLeader) XXX_Unmarshal 

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

type Type 

type Type int32

Type rpc type 

const (
	TypeResourceHeartbeatReq  Type = 0
	TypeResourceHeartbeatRsp  Type = 1
	TypeContainerHeartbeatReq Type = 2
	TypeContainerHeartbeatRsp Type = 3
	TypeGetContainerReq       Type = 4
	TypeGetContainerRsp       Type = 5
	TypeAllocIDReq            Type = 6
	TypeAllocIDRsp            Type = 7
	TypeAskSplitReq           Type = 8
	TypeAskSplitRsp           Type = 9
	TypeAskBatchSplitReq      Type = 10
	TypeAskBatchSplitRsp      Type = 11
	TypeReportSplitReq        Type = 12
	TypeReportSplitRsp        Type = 13
	TypeBatchReportSplitReq   Type = 14
	TypeBatchReportSplitRsp   Type = 15
	TypeTSOReq                Type = 16
	TypeTSORsp                Type = 17
	TypeCreateWatcherReq      Type = 18
	TypeEventNotify           Type = 19
	TypeGetDCLocationsReq     Type = 20
	TypeGetDCLocationsRsp     Type = 21
)

func (Type) EnumDescriptor 

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

func (Type) String 

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