mirbftpb

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 (
	ErrInvalidLengthMirbft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMirbft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMirbft = fmt.Errorf("proto: unexpected end of group")
)
View Source
var AgreementMessage_Type_name = map[int32]string{
	0: "PrePrepare",
	1: "Prepare",
	2: "Commit",
}
View Source
var AgreementMessage_Type_value = map[string]int32{
	"PrePrepare": 0,
	"Prepare":    1,
	"Commit":     2,
}
View Source
var InstanceState_Status_name = map[int32]string{
	0: "None",
	1: "PrePrepared",
	2: "Prepared",
	3: "Committed",
	4: "Executed",
}
View Source
var InstanceState_Status_value = map[string]int32{
	"None":        0,
	"PrePrepared": 1,
	"Prepared":    2,
	"Committed":   3,
	"Executed":    4,
}

Functions

func WrapMessageInner

func WrapMessageInner(msg proto.Message) isMirBFTMessage_Type

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

Types

type AgreementMessage

type AgreementMessage struct {
	Epoch       Epoch                 `protobuf:"varint,1,opt,name=epoch,proto3,casttype=Epoch" json:"epoch,omitempty"`
	Index       Index                 `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"`
	Type        AgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=mirbftpb.AgreementMessage_Type" json:"type,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 (*AgreementMessage) Descriptor

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

func (*AgreementMessage) Equals

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

func (*AgreementMessage) GetCommand

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

func (*AgreementMessage) GetCommandHash

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

func (*AgreementMessage) GetEpoch

func (m *AgreementMessage) GetEpoch() Epoch

func (*AgreementMessage) GetIndex

func (m *AgreementMessage) GetIndex() Index

func (*AgreementMessage) GetType

func (*AgreementMessage) Marshal

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

func (*AgreementMessage) MarshalTo

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

func (*AgreementMessage) MarshalToSizedBuffer

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

func (*AgreementMessage) ProtoMessage

func (*AgreementMessage) ProtoMessage()

func (*AgreementMessage) Reset

func (m *AgreementMessage) Reset()

func (*AgreementMessage) Size

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

func (*AgreementMessage) String

func (m *AgreementMessage) String() string

func (*AgreementMessage) Unmarshal

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

func (*AgreementMessage) XXX_DiscardUnknown

func (m *AgreementMessage) XXX_DiscardUnknown()

func (*AgreementMessage) XXX_Marshal

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

func (*AgreementMessage) XXX_Merge

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

func (*AgreementMessage) XXX_Size

func (m *AgreementMessage) XXX_Size() int

func (*AgreementMessage) XXX_Unmarshal

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

type AgreementMessage_Type

type AgreementMessage_Type int32
const (
	AgreementMessage_PrePrepare AgreementMessage_Type = 0
	AgreementMessage_Prepare    AgreementMessage_Type = 1
	AgreementMessage_Commit     AgreementMessage_Type = 2
)

func (AgreementMessage_Type) EnumDescriptor

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

func (AgreementMessage_Type) String

func (x AgreementMessage_Type) String() string

type Epoch

type Epoch uint64

type EpochChangeAckMessage

type EpochChangeAckMessage struct {
	NewEpoch Epoch                                                  `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"`
	AckFor   github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-byte string literal not displayed */
	Digest   []byte                                                 `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"`
}

func (*EpochChangeAckMessage) Descriptor

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

func (*EpochChangeAckMessage) GetAckFor

func (*EpochChangeAckMessage) GetDigest

func (m *EpochChangeAckMessage) GetDigest() []byte

func (*EpochChangeAckMessage) GetNewEpoch

func (m *EpochChangeAckMessage) GetNewEpoch() Epoch

func (*EpochChangeAckMessage) Marshal

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

func (*EpochChangeAckMessage) MarshalTo

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

func (*EpochChangeAckMessage) MarshalToSizedBuffer

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

func (*EpochChangeAckMessage) ProtoMessage

func (*EpochChangeAckMessage) ProtoMessage()

func (*EpochChangeAckMessage) Reset

func (m *EpochChangeAckMessage) Reset()

func (*EpochChangeAckMessage) Size

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

func (*EpochChangeAckMessage) String

func (m *EpochChangeAckMessage) String() string

func (*EpochChangeAckMessage) Unmarshal

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

func (*EpochChangeAckMessage) XXX_DiscardUnknown

func (m *EpochChangeAckMessage) XXX_DiscardUnknown()

func (*EpochChangeAckMessage) XXX_Marshal

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

func (*EpochChangeAckMessage) XXX_Merge

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

func (*EpochChangeAckMessage) XXX_Size

func (m *EpochChangeAckMessage) XXX_Size() int

func (*EpochChangeAckMessage) XXX_Unmarshal

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

type EpochChangeMessage

type EpochChangeMessage struct {
	NewEpoch  Epoch           `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"`
	LowIndex  Index           `protobuf:"varint,2,opt,name=low_index,json=lowIndex,proto3,casttype=Index" json:"low_index,omitempty"`
	HighIndex Index           `protobuf:"varint,3,opt,name=high_index,json=highIndex,proto3,casttype=Index" json:"high_index,omitempty"`
	PSet      []InstanceState `protobuf:"bytes,4,rep,name=p_set,json=pSet,proto3" json:"p_set"`
	QSet      []InstanceState `protobuf:"bytes,5,rep,name=q_set,json=qSet,proto3" json:"q_set"`
}

func (*EpochChangeMessage) Descriptor

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

func (*EpochChangeMessage) GetHighIndex

func (m *EpochChangeMessage) GetHighIndex() Index

func (*EpochChangeMessage) GetLowIndex

func (m *EpochChangeMessage) GetLowIndex() Index

func (*EpochChangeMessage) GetNewEpoch

func (m *EpochChangeMessage) GetNewEpoch() Epoch

func (*EpochChangeMessage) GetPSet

func (m *EpochChangeMessage) GetPSet() []InstanceState

func (*EpochChangeMessage) GetQSet

func (m *EpochChangeMessage) GetQSet() []InstanceState

func (*EpochChangeMessage) Marshal

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

func (*EpochChangeMessage) MarshalTo

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

func (*EpochChangeMessage) MarshalToSizedBuffer

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

func (*EpochChangeMessage) ProtoMessage

func (*EpochChangeMessage) ProtoMessage()

func (*EpochChangeMessage) Reset

func (m *EpochChangeMessage) Reset()

func (*EpochChangeMessage) Size

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

func (*EpochChangeMessage) String

func (m *EpochChangeMessage) String() string

func (*EpochChangeMessage) Unmarshal

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

func (*EpochChangeMessage) XXX_DiscardUnknown

func (m *EpochChangeMessage) XXX_DiscardUnknown()

func (*EpochChangeMessage) XXX_Marshal

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

func (*EpochChangeMessage) XXX_Merge

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

func (*EpochChangeMessage) XXX_Size

func (m *EpochChangeMessage) XXX_Size() int

func (*EpochChangeMessage) XXX_Unmarshal

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

type Index

type Index uint64

type InstanceState

type InstanceState struct {
	Epoch       Epoch                `protobuf:"varint,1,opt,name=epoch,proto3,casttype=Epoch" json:"epoch,omitempty"`
	Index       Index                `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"`
	Status      InstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=mirbftpb.InstanceState_Status" json:"status,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 (*InstanceState) Descriptor

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

func (*InstanceState) GetCommand

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

func (*InstanceState) GetCommandHash

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

func (*InstanceState) GetEpoch

func (m *InstanceState) GetEpoch() Epoch

func (*InstanceState) GetIndex

func (m *InstanceState) GetIndex() Index

func (*InstanceState) GetStatus

func (m *InstanceState) GetStatus() InstanceState_Status

func (*InstanceState) IsAtleastPrePrepared

func (m *InstanceState) IsAtleastPrePrepared() bool

func (*InstanceState) IsAtleastPrepared

func (m *InstanceState) IsAtleastPrepared() bool

func (*InstanceState) IsCommitted

func (m *InstanceState) IsCommitted() bool

func (*InstanceState) IsPrePrepared

func (m *InstanceState) IsPrePrepared() bool

func (*InstanceState) IsPrepared

func (m *InstanceState) IsPrepared() bool

func (*InstanceState) Marshal

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

func (*InstanceState) MarshalTo

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

func (*InstanceState) MarshalToSizedBuffer

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

func (*InstanceState) ProtoMessage

func (*InstanceState) ProtoMessage()

func (*InstanceState) Reset

func (m *InstanceState) Reset()

func (*InstanceState) Size

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

func (*InstanceState) String

func (m *InstanceState) String() string

func (*InstanceState) Unmarshal

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

func (*InstanceState) XXX_DiscardUnknown

func (m *InstanceState) XXX_DiscardUnknown()

func (*InstanceState) XXX_Marshal

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

func (*InstanceState) XXX_Merge

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

func (*InstanceState) XXX_Size

func (m *InstanceState) XXX_Size() int

func (*InstanceState) XXX_Unmarshal

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

type InstanceState_Status

type InstanceState_Status int32
const (
	InstanceState_None        InstanceState_Status = 0
	InstanceState_PrePrepared InstanceState_Status = 1
	InstanceState_Prepared    InstanceState_Status = 2
	InstanceState_Committed   InstanceState_Status = 3
	InstanceState_Executed    InstanceState_Status = 4
)

func (InstanceState_Status) EnumDescriptor

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

func (InstanceState_Status) String

func (x InstanceState_Status) String() string

type MirBFTMessage

type MirBFTMessage struct {
	// Types that are valid to be assigned to Type:
	//	*MirBFTMessage_Agreement
	//	*MirBFTMessage_EpochChange
	//	*MirBFTMessage_EpochChangeAck
	//	*MirBFTMessage_NewEpoch
	Type isMirBFTMessage_Type `protobuf_oneof:"type"`
}

func WrapMirBFTMessage

func WrapMirBFTMessage(msg proto.Message) *MirBFTMessage

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

func (*MirBFTMessage) Descriptor

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

func (*MirBFTMessage) GetAgreement

func (m *MirBFTMessage) GetAgreement() *AgreementMessage

func (*MirBFTMessage) GetEpochChange

func (m *MirBFTMessage) GetEpochChange() *EpochChangeMessage

func (*MirBFTMessage) GetEpochChangeAck

func (m *MirBFTMessage) GetEpochChangeAck() *EpochChangeAckMessage

func (*MirBFTMessage) GetNewEpoch

func (m *MirBFTMessage) GetNewEpoch() *NewEpochMessage

func (*MirBFTMessage) GetType

func (m *MirBFTMessage) GetType() isMirBFTMessage_Type

func (*MirBFTMessage) Marshal

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

func (*MirBFTMessage) MarshalTo

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

func (*MirBFTMessage) MarshalToSizedBuffer

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

func (*MirBFTMessage) ProtoMessage

func (*MirBFTMessage) ProtoMessage()

func (*MirBFTMessage) Reset

func (m *MirBFTMessage) Reset()

func (*MirBFTMessage) Size

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

func (*MirBFTMessage) String

func (m *MirBFTMessage) String() string

func (*MirBFTMessage) Unmarshal

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

func (*MirBFTMessage) XXX_DiscardUnknown

func (m *MirBFTMessage) XXX_DiscardUnknown()

func (*MirBFTMessage) XXX_Marshal

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

func (*MirBFTMessage) XXX_Merge

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

func (*MirBFTMessage) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MirBFTMessage) XXX_Size

func (m *MirBFTMessage) XXX_Size() int

func (*MirBFTMessage) XXX_Unmarshal

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

type MirBFTMessage_Agreement

type MirBFTMessage_Agreement struct {
	Agreement *AgreementMessage `protobuf:"bytes,1,opt,name=agreement,proto3,oneof" json:"agreement,omitempty"`
}

func (*MirBFTMessage_Agreement) MarshalTo

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

func (*MirBFTMessage_Agreement) MarshalToSizedBuffer

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

func (*MirBFTMessage_Agreement) Size

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

type MirBFTMessage_EpochChange

type MirBFTMessage_EpochChange struct {
	EpochChange *EpochChangeMessage `protobuf:"bytes,2,opt,name=epoch_change,json=epochChange,proto3,oneof" json:"epoch_change,omitempty"`
}

func (*MirBFTMessage_EpochChange) MarshalTo

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

func (*MirBFTMessage_EpochChange) MarshalToSizedBuffer

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

func (*MirBFTMessage_EpochChange) Size

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

type MirBFTMessage_EpochChangeAck

type MirBFTMessage_EpochChangeAck struct {
	EpochChangeAck *EpochChangeAckMessage `protobuf:"bytes,3,opt,name=epoch_change_ack,json=epochChangeAck,proto3,oneof" json:"epoch_change_ack,omitempty"`
}

func (*MirBFTMessage_EpochChangeAck) MarshalTo

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

func (*MirBFTMessage_EpochChangeAck) MarshalToSizedBuffer

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

func (*MirBFTMessage_EpochChangeAck) Size

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

type MirBFTMessage_NewEpoch

type MirBFTMessage_NewEpoch struct {
	NewEpoch *NewEpochMessage `protobuf:"bytes,4,opt,name=new_epoch,json=newEpoch,proto3,oneof" json:"new_epoch,omitempty"`
}

func (*MirBFTMessage_NewEpoch) MarshalTo

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

func (*MirBFTMessage_NewEpoch) MarshalToSizedBuffer

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

func (*MirBFTMessage_NewEpoch) Size

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

type NewEpochMessage

type NewEpochMessage struct {
	NewEpoch  Epoch                   `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"`
	NvProof   []NewEpochProof         `protobuf:"bytes,2,rep,name=nv_proof,json=nvProof,proto3" json:"nv_proof"`
	Instances map[Index]InstanceState `` /* 164-byte string literal not displayed */
}

func (*NewEpochMessage) Descriptor

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

func (*NewEpochMessage) GetInstances

func (m *NewEpochMessage) GetInstances() map[Index]InstanceState

func (*NewEpochMessage) GetNewEpoch

func (m *NewEpochMessage) GetNewEpoch() Epoch

func (*NewEpochMessage) GetNvProof

func (m *NewEpochMessage) GetNvProof() []NewEpochProof

func (*NewEpochMessage) Marshal

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

func (*NewEpochMessage) MarshalTo

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

func (*NewEpochMessage) MarshalToSizedBuffer

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

func (*NewEpochMessage) ProtoMessage

func (*NewEpochMessage) ProtoMessage()

func (*NewEpochMessage) Reset

func (m *NewEpochMessage) Reset()

func (*NewEpochMessage) Size

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

func (*NewEpochMessage) String

func (m *NewEpochMessage) String() string

func (*NewEpochMessage) Unmarshal

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

func (*NewEpochMessage) XXX_DiscardUnknown

func (m *NewEpochMessage) XXX_DiscardUnknown()

func (*NewEpochMessage) XXX_Marshal

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

func (*NewEpochMessage) XXX_Merge

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

func (*NewEpochMessage) XXX_Size

func (m *NewEpochMessage) XXX_Size() int

func (*NewEpochMessage) XXX_Unmarshal

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

type NewEpochProof

type NewEpochProof struct {
	AckFor github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-byte string literal not displayed */
	Digest []byte                                                 `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"`
}

func (*NewEpochProof) Descriptor

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

func (*NewEpochProof) GetDigest

func (m *NewEpochProof) GetDigest() []byte

func (*NewEpochProof) Marshal

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

func (*NewEpochProof) MarshalTo

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

func (*NewEpochProof) MarshalToSizedBuffer

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

func (*NewEpochProof) ProtoMessage

func (*NewEpochProof) ProtoMessage()

func (*NewEpochProof) Reset

func (m *NewEpochProof) Reset()

func (*NewEpochProof) Size

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

func (*NewEpochProof) String

func (m *NewEpochProof) String() string

func (*NewEpochProof) Unmarshal

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

func (*NewEpochProof) XXX_DiscardUnknown

func (m *NewEpochProof) XXX_DiscardUnknown()

func (*NewEpochProof) XXX_Marshal

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

func (*NewEpochProof) XXX_Merge

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

func (*NewEpochProof) XXX_Size

func (m *NewEpochProof) XXX_Size() int

func (*NewEpochProof) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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