hybsterpb

package
v0.0.0-...-3a733ff Latest Latest
Warning

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

 Go to latest Published: May 24, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthHybster        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHybster          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHybster = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var NormalMessage_Type_name = map[int32]string{
	0: "Prepare",
	1: "Commit",
	3: "ViewChange",
	4: "NewView",
	5: "NewViewAck",
}
View Source 
var NormalMessage_Type_value = map[string]int32{
	"Prepare":    0,
	"Commit":     1,
	"ViewChange": 3,
	"NewView":    4,
	"NewViewAck": 5,
}

Functions

func WrapMessageInner 

func WrapMessageInner(msg proto.Message) isHybsterMessage_Type

WrapMessageInner wraps a union type of Message in a new isMessage_Type.

Types

type HybsterMessage 

type HybsterMessage struct {
	// Types that are valid to be assigned to Type:
	//	*HybsterMessage_Normal
	//	*HybsterMessage_ViewChange
	//	*HybsterMessage_NewView
	//	*HybsterMessage_NewViewAck
	Type isHybsterMessage_Type `protobuf_oneof:"type"`
}

func WrapHybsterMessage 

func WrapHybsterMessage(msg proto.Message) *HybsterMessage

WrapHybsterMessage wraps a union type of Message in a new PBFTMessage without a destination.

func (*HybsterMessage) Descriptor 

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

func (*HybsterMessage) GetNewView 

func (m *HybsterMessage) GetNewView() *NewViewMessage

func (*HybsterMessage) GetNewViewAck 

func (m *HybsterMessage) GetNewViewAck() *NewViewAckMessage

func (*HybsterMessage) GetNormal 

func (m *HybsterMessage) GetNormal() *NormalMessage

func (*HybsterMessage) GetType 

func (m *HybsterMessage) GetType() isHybsterMessage_Type

func (*HybsterMessage) GetViewChange 

func (m *HybsterMessage) GetViewChange() *ViewChangeMessage

func (*HybsterMessage) Marshal 

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

func (*HybsterMessage) MarshalTo 

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

func (*HybsterMessage) MarshalToSizedBuffer 

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

func (*HybsterMessage) ProtoMessage 

func (*HybsterMessage) ProtoMessage()

func (*HybsterMessage) Reset 

func (m *HybsterMessage) Reset()

func (*HybsterMessage) Size 

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

func (*HybsterMessage) String 

func (m *HybsterMessage) String() string

func (*HybsterMessage) Unmarshal 

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

func (*HybsterMessage) XXX_DiscardUnknown 

func (m *HybsterMessage) XXX_DiscardUnknown()

func (*HybsterMessage) XXX_Marshal 

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

func (*HybsterMessage) XXX_Merge 

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

func (*HybsterMessage) XXX_OneofWrappers 

func (*HybsterMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*HybsterMessage) XXX_Size 

func (m *HybsterMessage) XXX_Size() int

func (*HybsterMessage) XXX_Unmarshal 

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

type HybsterMessage_NewView 

type HybsterMessage_NewView struct {
	NewView *NewViewMessage `protobuf:"bytes,3,opt,name=new_view,json=newView,proto3,oneof" json:"new_view,omitempty"`
}

func (*HybsterMessage_NewView) MarshalTo 

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

func (*HybsterMessage_NewView) MarshalToSizedBuffer 

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

func (*HybsterMessage_NewView) Size 

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

type HybsterMessage_NewViewAck 

type HybsterMessage_NewViewAck struct {
	NewViewAck *NewViewAckMessage `protobuf:"bytes,4,opt,name=new_view_ack,json=newViewAck,proto3,oneof" json:"new_view_ack,omitempty"`
}

func (*HybsterMessage_NewViewAck) MarshalTo 

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

func (*HybsterMessage_NewViewAck) MarshalToSizedBuffer 

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

func (*HybsterMessage_NewViewAck) Size 

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

type HybsterMessage_Normal 

type HybsterMessage_Normal struct {
	Normal *NormalMessage `protobuf:"bytes,1,opt,name=normal,proto3,oneof" json:"normal,omitempty"`
}

func (*HybsterMessage_Normal) MarshalTo 

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

func (*HybsterMessage_Normal) MarshalToSizedBuffer 

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

func (*HybsterMessage_Normal) Size 

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

type HybsterMessage_ViewChange 

type HybsterMessage_ViewChange struct {
	ViewChange *ViewChangeMessage `protobuf:"bytes,2,opt,name=view_change,json=viewChange,proto3,oneof" json:"view_change,omitempty"`
}

func (*HybsterMessage_ViewChange) MarshalTo 

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

func (*HybsterMessage_ViewChange) MarshalToSizedBuffer 

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

func (*HybsterMessage_ViewChange) Size 

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

type NewViewAckMessage 

type NewViewAckMessage struct {
	View    View      `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	Order   Order     `protobuf:"varint,2,opt,name=order,proto3,casttype=Order" json:"order,omitempty"`
	History []Support `protobuf:"bytes,3,rep,name=history,proto3" json:"history"`
}

func (*NewViewAckMessage) Descriptor 

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

func (*NewViewAckMessage) GetHistory 

func (m *NewViewAckMessage) GetHistory() []Support

func (*NewViewAckMessage) GetOrder 

func (m *NewViewAckMessage) GetOrder() Order

func (*NewViewAckMessage) GetView 

func (m *NewViewAckMessage) GetView() View

func (*NewViewAckMessage) Marshal 

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

func (*NewViewAckMessage) MarshalTo 

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

func (*NewViewAckMessage) MarshalToSizedBuffer 

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

func (*NewViewAckMessage) ProtoMessage 

func (*NewViewAckMessage) ProtoMessage()

func (*NewViewAckMessage) Reset 

func (m *NewViewAckMessage) Reset()

func (*NewViewAckMessage) Size 

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

func (*NewViewAckMessage) String 

func (m *NewViewAckMessage) String() string

func (*NewViewAckMessage) Unmarshal 

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

func (*NewViewAckMessage) XXX_DiscardUnknown 

func (m *NewViewAckMessage) XXX_DiscardUnknown()

func (*NewViewAckMessage) XXX_Marshal 

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

func (*NewViewAckMessage) XXX_Merge 

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

func (*NewViewAckMessage) XXX_Size 

func (m *NewViewAckMessage) XXX_Size() int

func (*NewViewAckMessage) XXX_Unmarshal 

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

type NewViewMessage 

type NewViewMessage struct {
	FromView View      `protobuf:"varint,1,opt,name=from_view,json=fromView,proto3,casttype=View" json:"from_view,omitempty"`
	ToView   View      `protobuf:"varint,2,opt,name=to_view,json=toView,proto3,casttype=View" json:"to_view,omitempty"`
	Order    Order     `protobuf:"varint,3,opt,name=order,proto3,casttype=Order" json:"order,omitempty"`
	History  []Support `protobuf:"bytes,4,rep,name=history,proto3" json:"history"`
	Proof    []Support `protobuf:"bytes,5,rep,name=proof,proto3" json:"proof"`
}

func (*NewViewMessage) Descriptor 

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

func (*NewViewMessage) GetFromView 

func (m *NewViewMessage) GetFromView() View

func (*NewViewMessage) GetHistory 

func (m *NewViewMessage) GetHistory() []Support

func (*NewViewMessage) GetOrder 

func (m *NewViewMessage) GetOrder() Order

func (*NewViewMessage) GetProof 

func (m *NewViewMessage) GetProof() []Support

func (*NewViewMessage) GetToView 

func (m *NewViewMessage) GetToView() View

func (*NewViewMessage) Marshal 

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

func (*NewViewMessage) MarshalTo 

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

func (*NewViewMessage) MarshalToSizedBuffer 

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

func (*NewViewMessage) ProtoMessage 

func (*NewViewMessage) ProtoMessage()

func (*NewViewMessage) Reset 

func (m *NewViewMessage) Reset()

func (*NewViewMessage) Size 

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

func (*NewViewMessage) String 

func (m *NewViewMessage) String() string

func (*NewViewMessage) Unmarshal 

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

func (*NewViewMessage) XXX_DiscardUnknown 

func (m *NewViewMessage) XXX_DiscardUnknown()

func (*NewViewMessage) XXX_Marshal 

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

func (*NewViewMessage) XXX_Merge 

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

func (*NewViewMessage) XXX_Size 

func (m *NewViewMessage) XXX_Size() int

func (*NewViewMessage) XXX_Unmarshal 

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

type NormalMessage 

type NormalMessage struct {
	Type        NormalMessage_Type `protobuf:"varint,1,opt,name=type,proto3,enum=hybsterpb.NormalMessage_Type" json:"type,omitempty"`
	View        View               `protobuf:"varint,2,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	Order       Order              `protobuf:"varint,3,opt,name=order,proto3,casttype=Order" json:"order,omitempty"`
	Command     *commandpb.Command `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
	CommandHash []byte             `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"`
}

func (*NormalMessage) Descriptor 

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

func (*NormalMessage) Equals 

func (m *NormalMessage) Equals(other *NormalMessage) bool

func (*NormalMessage) GetCommand 

func (m *NormalMessage) GetCommand() *commandpb.Command

func (*NormalMessage) GetCommandHash 

func (m *NormalMessage) GetCommandHash() []byte

func (*NormalMessage) GetOrder 

func (m *NormalMessage) GetOrder() Order

func (*NormalMessage) GetType 

func (m *NormalMessage) GetType() NormalMessage_Type

func (*NormalMessage) GetView 

func (m *NormalMessage) GetView() View

func (*NormalMessage) Marshal 

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

func (*NormalMessage) MarshalTo 

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

func (*NormalMessage) MarshalToSizedBuffer 

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

func (*NormalMessage) ProtoMessage 

func (*NormalMessage) ProtoMessage()

func (*NormalMessage) Reset 

func (m *NormalMessage) Reset()

func (*NormalMessage) Size 

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

func (*NormalMessage) String 

func (m *NormalMessage) String() string

func (*NormalMessage) Unmarshal 

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

func (*NormalMessage) XXX_DiscardUnknown 

func (m *NormalMessage) XXX_DiscardUnknown()

func (*NormalMessage) XXX_Marshal 

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

func (*NormalMessage) XXX_Merge 

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

func (*NormalMessage) XXX_Size 

func (m *NormalMessage) XXX_Size() int

func (*NormalMessage) XXX_Unmarshal 

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

type NormalMessage_Type 

type NormalMessage_Type int32
const (
	NormalMessage_Prepare    NormalMessage_Type = 0
	NormalMessage_Commit     NormalMessage_Type = 1
	NormalMessage_ViewChange NormalMessage_Type = 3
	NormalMessage_NewView    NormalMessage_Type = 4
	NormalMessage_NewViewAck NormalMessage_Type = 5
)

func (NormalMessage_Type) EnumDescriptor 

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

func (NormalMessage_Type) String 

func (x NormalMessage_Type) String() string

type Order 

type Order uint64

Index is the number of an instance slot in a replica's command array.

type Support 

type Support struct {
	RawMsg []byte                                                 `protobuf:"bytes,1,opt,name=raw_msg,json=rawMsg,proto3" json:"raw_msg,omitempty"`
	Cert   []byte                                                 `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
	From   github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 126-byte string literal not displayed */
}

func (*Support) Descriptor 

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

func (*Support) GetCert 

func (m *Support) GetCert() []byte

func (*Support) GetFrom 

func (m *Support) GetFrom() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID

func (*Support) GetRawMsg 

func (m *Support) GetRawMsg() []byte

func (*Support) Marshal 

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

func (*Support) MarshalTo 

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

func (*Support) MarshalToSizedBuffer 

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

func (*Support) ProtoMessage 

func (*Support) ProtoMessage()

func (*Support) Reset 

func (m *Support) Reset()

func (*Support) Size 

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

func (*Support) String 

func (m *Support) String() string

func (*Support) Unmarshal 

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

func (*Support) XXX_DiscardUnknown 

func (m *Support) XXX_DiscardUnknown()

func (*Support) XXX_Marshal 

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

func (*Support) XXX_Merge 

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

func (*Support) XXX_Size 

func (m *Support) XXX_Size() int

func (*Support) XXX_Unmarshal 

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

type View 

type View uint64

View is a view

type ViewChangeMessage 

type ViewChangeMessage struct {
	FromView View      `protobuf:"varint,1,opt,name=from_view,json=fromView,proto3,casttype=View" json:"from_view,omitempty"`
	ToView   View      `protobuf:"varint,2,opt,name=to_view,json=toView,proto3,casttype=View" json:"to_view,omitempty"`
	Order    Order     `protobuf:"varint,3,opt,name=order,proto3,casttype=Order" json:"order,omitempty"`
	History  []Support `protobuf:"bytes,4,rep,name=history,proto3" json:"history"`
	LastCtr  uint64    `protobuf:"varint,5,opt,name=last_ctr,json=lastCtr,proto3" json:"last_ctr,omitempty"`
}

func (*ViewChangeMessage) Descriptor 

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

func (*ViewChangeMessage) GetFromView 

func (m *ViewChangeMessage) GetFromView() View

func (*ViewChangeMessage) GetHistory 

func (m *ViewChangeMessage) GetHistory() []Support

func (*ViewChangeMessage) GetLastCtr 

func (m *ViewChangeMessage) GetLastCtr() uint64

func (*ViewChangeMessage) GetOrder 

func (m *ViewChangeMessage) GetOrder() Order

func (*ViewChangeMessage) GetToView 

func (m *ViewChangeMessage) GetToView() View

func (*ViewChangeMessage) Marshal 

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

func (*ViewChangeMessage) MarshalTo 

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

func (*ViewChangeMessage) MarshalToSizedBuffer 

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

func (*ViewChangeMessage) ProtoMessage 

func (*ViewChangeMessage) ProtoMessage()

func (*ViewChangeMessage) Reset 

func (m *ViewChangeMessage) Reset()

func (*ViewChangeMessage) Size 

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

func (*ViewChangeMessage) String 

func (m *ViewChangeMessage) String() string

func (*ViewChangeMessage) Unmarshal 

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

func (*ViewChangeMessage) XXX_DiscardUnknown 

func (m *ViewChangeMessage) XXX_DiscardUnknown()

func (*ViewChangeMessage) XXX_Marshal 

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

func (*ViewChangeMessage) XXX_Merge 

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

func (*ViewChangeMessage) XXX_Size 

func (m *ViewChangeMessage) XXX_Size() int

func (*ViewChangeMessage) XXX_Unmarshal 

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

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.