dqpbftpb

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 (
	ErrInvalidLengthDqpbft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDqpbft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDqpbft = 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,
}
View Source 
var OAgreementMessage_Type_name = map[int32]string{
	0: "OPrePrepare",
	1: "OPrepare",
	2: "OCommit",
}
View Source 
var OAgreementMessage_Type_value = map[string]int32{
	"OPrePrepare": 0,
	"OPrepare":    1,
	"OCommit":     2,
}
View Source 
var OInstanceState_Status_name = map[int32]string{
	0: "None",
	1: "OPrePrepared",
	2: "OPrepared",
	3: "OCommitted",
	4: "OExecuted",
}
View Source 
var OInstanceState_Status_value = map[string]int32{
	"None":         0,
	"OPrePrepared": 1,
	"OPrepared":    2,
	"OCommitted":   3,
	"OExecuted":    4,
}

Functions

func InstancesEquals 

func InstancesEquals(a, b []InstanceID) bool

func ReplicaIDEquals 

func ReplicaIDEquals(a, b []peerpb.PeerID) bool

func WrapMessageInner 

func WrapMessageInner(msg proto.Message) isDQPBFTMessage_Type

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

Types

type AgreementMessage 

type AgreementMessage struct {
	View        View                  `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	InstanceID  InstanceID            `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id"`
	Type        AgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=dqpbftpb.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) GetInstanceID 

func (m *AgreementMessage) GetInstanceID() InstanceID

func (*AgreementMessage) GetType 

func (m *AgreementMessage) GetType() AgreementMessage_Type

func (*AgreementMessage) GetView 

func (m *AgreementMessage) GetView() View

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 DQPBFTMessage 

type DQPBFTMessage struct {
	// Types that are valid to be assigned to Type:
	//	*DQPBFTMessage_Agreement
	//	*DQPBFTMessage_OAgreement
	Type isDQPBFTMessage_Type `protobuf_oneof:"type"`
}

func WrapDQPBFTMessage 

func WrapDQPBFTMessage(msg proto.Message) *DQPBFTMessage

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

func (*DQPBFTMessage) Descriptor 

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

func (*DQPBFTMessage) GetAgreement 

func (m *DQPBFTMessage) GetAgreement() *AgreementMessage

func (*DQPBFTMessage) GetOAgreement 

func (m *DQPBFTMessage) GetOAgreement() *OAgreementMessage

func (*DQPBFTMessage) GetType 

func (m *DQPBFTMessage) GetType() isDQPBFTMessage_Type

func (*DQPBFTMessage) Marshal 

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

func (*DQPBFTMessage) MarshalTo 

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

func (*DQPBFTMessage) MarshalToSizedBuffer 

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

func (*DQPBFTMessage) ProtoMessage 

func (*DQPBFTMessage) ProtoMessage()

func (*DQPBFTMessage) Reset 

func (m *DQPBFTMessage) Reset()

func (*DQPBFTMessage) Size 

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

func (*DQPBFTMessage) String 

func (m *DQPBFTMessage) String() string

func (*DQPBFTMessage) Unmarshal 

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

func (*DQPBFTMessage) XXX_DiscardUnknown 

func (m *DQPBFTMessage) XXX_DiscardUnknown()

func (*DQPBFTMessage) XXX_Marshal 

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

func (*DQPBFTMessage) XXX_Merge 

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

func (*DQPBFTMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DQPBFTMessage) XXX_Size 

func (m *DQPBFTMessage) XXX_Size() int

func (*DQPBFTMessage) XXX_Unmarshal 

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

type DQPBFTMessage_Agreement 

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

func (*DQPBFTMessage_Agreement) MarshalTo 

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

func (*DQPBFTMessage_Agreement) MarshalToSizedBuffer 

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

func (*DQPBFTMessage_Agreement) Size 

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

type DQPBFTMessage_OAgreement 

type DQPBFTMessage_OAgreement struct {
	OAgreement *OAgreementMessage `protobuf:"bytes,2,opt,name=o_agreement,json=oAgreement,proto3,oneof" json:"o_agreement,omitempty"`
}

func (*DQPBFTMessage_OAgreement) MarshalTo 

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

func (*DQPBFTMessage_OAgreement) MarshalToSizedBuffer 

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

func (*DQPBFTMessage_OAgreement) Size 

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

type Index 

type Index uint64

func (*Index) GetAndIncrement 

func (idx *Index) GetAndIncrement() Index

type InstanceID 

type InstanceID struct {
	ReplicaID github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 153-byte string literal not displayed */
	Index     Index                                                  `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"`
}

func (*InstanceID) Descriptor 

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

func (InstanceID) Equals 

func (m InstanceID) Equals(other InstanceID) bool

func (*InstanceID) GetIndex 

func (m *InstanceID) GetIndex() Index

func (*InstanceID) GetReplicaID 

func (m *InstanceID) GetReplicaID() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID

func (*InstanceID) Marshal 

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

func (*InstanceID) MarshalTo 

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

func (*InstanceID) MarshalToSizedBuffer 

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

func (*InstanceID) ProtoMessage 

func (*InstanceID) ProtoMessage()

func (*InstanceID) Reset 

func (m *InstanceID) Reset()

func (*InstanceID) Size 

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

func (*InstanceID) String 

func (m *InstanceID) String() string

func (*InstanceID) Unmarshal 

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

func (*InstanceID) XXX_DiscardUnknown 

func (m *InstanceID) XXX_DiscardUnknown()

func (*InstanceID) XXX_Marshal 

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

func (*InstanceID) XXX_Merge 

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

func (*InstanceID) XXX_Size 

func (m *InstanceID) XXX_Size() int

func (*InstanceID) XXX_Unmarshal 

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

type InstanceState 

type InstanceState struct {
	View        View                 `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	InstanceID  InstanceID           `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id"`
	Status      InstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=dqpbftpb.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) GetInstanceID 

func (m *InstanceState) GetInstanceID() InstanceID

func (*InstanceState) GetStatus 

func (m *InstanceState) GetStatus() InstanceState_Status

func (*InstanceState) GetView 

func (m *InstanceState) GetView() View

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 OAgreementMessage 

type OAgreementMessage struct {
	View        View                   `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	Index       Index                  `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"`
	Type        OAgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=dqpbftpb.OAgreementMessage_Type" json:"type,omitempty"`
	Instances   []InstanceID           `protobuf:"bytes,4,rep,name=instances,proto3" json:"instances"`
	CommandHash []byte                 `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"`
}

func (*OAgreementMessage) Descriptor 

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

func (*OAgreementMessage) Equals 

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

func (*OAgreementMessage) GetCommandHash 

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

func (*OAgreementMessage) GetIndex 

func (m *OAgreementMessage) GetIndex() Index

func (*OAgreementMessage) GetInstances 

func (m *OAgreementMessage) GetInstances() []InstanceID

func (*OAgreementMessage) GetType 

func (m *OAgreementMessage) GetType() OAgreementMessage_Type

func (*OAgreementMessage) GetView 

func (m *OAgreementMessage) GetView() View

func (*OAgreementMessage) Marshal 

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

func (*OAgreementMessage) MarshalTo 

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

func (*OAgreementMessage) MarshalToSizedBuffer 

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

func (*OAgreementMessage) ProtoMessage 

func (*OAgreementMessage) ProtoMessage()

func (*OAgreementMessage) Reset 

func (m *OAgreementMessage) Reset()

func (*OAgreementMessage) Size 

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

func (*OAgreementMessage) String 

func (m *OAgreementMessage) String() string

func (*OAgreementMessage) Unmarshal 

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

func (*OAgreementMessage) XXX_DiscardUnknown 

func (m *OAgreementMessage) XXX_DiscardUnknown()

func (*OAgreementMessage) XXX_Marshal 

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

func (*OAgreementMessage) XXX_Merge 

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

func (*OAgreementMessage) XXX_Size 

func (m *OAgreementMessage) XXX_Size() int

func (*OAgreementMessage) XXX_Unmarshal 

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

type OAgreementMessage_Type 

type OAgreementMessage_Type int32
const (
	OAgreementMessage_OPrePrepare OAgreementMessage_Type = 0
	OAgreementMessage_OPrepare    OAgreementMessage_Type = 1
	OAgreementMessage_OCommit     OAgreementMessage_Type = 2
)

func (OAgreementMessage_Type) EnumDescriptor 

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

func (OAgreementMessage_Type) String 

func (x OAgreementMessage_Type) String() string

type OInstanceState 

type OInstanceState struct {
	View        View                  `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"`
	Index       Index                 `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"`
	Status      OInstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=dqpbftpb.OInstanceState_Status" json:"status,omitempty"`
	Instances   []InstanceID          `protobuf:"bytes,4,rep,name=instances,proto3" json:"instances"`
	CommandHash []byte                `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"`
}

func (*OInstanceState) Descriptor 

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

func (*OInstanceState) GetCommandHash 

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

func (*OInstanceState) GetIndex 

func (m *OInstanceState) GetIndex() Index

func (*OInstanceState) GetInstances 

func (m *OInstanceState) GetInstances() []InstanceID

func (*OInstanceState) GetStatus 

func (m *OInstanceState) GetStatus() OInstanceState_Status

func (*OInstanceState) GetView 

func (m *OInstanceState) GetView() View

func (*OInstanceState) IsCommitted 

func (m *OInstanceState) IsCommitted() bool

func (*OInstanceState) IsPrePrepared 

func (m *OInstanceState) IsPrePrepared() bool

func (*OInstanceState) IsPrepared 

func (m *OInstanceState) IsPrepared() bool

func (*OInstanceState) Marshal 

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

func (*OInstanceState) MarshalTo 

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

func (*OInstanceState) MarshalToSizedBuffer 

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

func (*OInstanceState) ProtoMessage 

func (*OInstanceState) ProtoMessage()

func (*OInstanceState) Reset 

func (m *OInstanceState) Reset()

func (*OInstanceState) Size 

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

func (*OInstanceState) String 

func (m *OInstanceState) String() string

func (*OInstanceState) Unmarshal 

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

func (*OInstanceState) XXX_DiscardUnknown 

func (m *OInstanceState) XXX_DiscardUnknown()

func (*OInstanceState) XXX_Marshal 

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

func (*OInstanceState) XXX_Merge 

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

func (*OInstanceState) XXX_Size 

func (m *OInstanceState) XXX_Size() int

func (*OInstanceState) XXX_Unmarshal 

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

type OInstanceState_Status 

type OInstanceState_Status int32
const (
	OInstanceState_None         OInstanceState_Status = 0
	OInstanceState_OPrePrepared OInstanceState_Status = 1
	OInstanceState_OPrepared    OInstanceState_Status = 2
	OInstanceState_OCommitted   OInstanceState_Status = 3
	OInstanceState_OExecuted    OInstanceState_Status = 4
)

func (OInstanceState_Status) EnumDescriptor 

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

func (OInstanceState_Status) String 

func (x OInstanceState_Status) String() string

type View 

type View uint64

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.