peerpb

package

v0.0.0-...-3a733ff Latest Latest Go to latest Published: May 24, 2022 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ibalajiarun/go-consensus

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidLengthPeer        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPeer          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPeer = fmt.Errorf("proto: unexpected end of group")
)

View Source

var Algorithm_name = map[int32]string{
	0:  "PBFT",
	1:  "SBFT",
	2:  "Zyzzyva",
	3:  "EzBFT",
	4:  "Hybster",
	5:  "Destiny",
	6:  "Dester",
	7:  "LinHybster",
	8:  "SBFTSlow",
	9:  "Hotstuff",
	10: "Broadcast",
	11: "Prime",
	12: "PreDestiny",
	13: "MinBFT",
	14: "DuoBFT",
	15: "MinBFTSig",
	16: "SBFTx",
	17: "Hybsterx",
	18: "ChainHotstuff",
	19: "RCC",
	20: "MirBFT",
	21: "Dispel",
	22: "DQPBFT",
	23: "DQSBFTSlow",
	24: "ChainDuoBFT",
	25: "MultiChainDuoBFT",
	26: "MultiChainDuoBFTRCC",
}

View Source

var Algorithm_value = map[string]int32{
	"PBFT":                0,
	"SBFT":                1,
	"Zyzzyva":             2,
	"EzBFT":               3,
	"Hybster":             4,
	"Destiny":             5,
	"Dester":              6,
	"LinHybster":          7,
	"SBFTSlow":            8,
	"Hotstuff":            9,
	"Broadcast":           10,
	"Prime":               11,
	"PreDestiny":          12,
	"MinBFT":              13,
	"DuoBFT":              14,
	"MinBFTSig":           15,
	"SBFTx":               16,
	"Hybsterx":            17,
	"ChainHotstuff":       18,
	"RCC":                 19,
	"MirBFT":              20,
	"Dispel":              21,
	"DQPBFT":              22,
	"DQSBFTSlow":          23,
	"ChainDuoBFT":         24,
	"MultiChainDuoBFT":    25,
	"MultiChainDuoBFTRCC": 26,
}

Functions ¶

This section is empty.

Types ¶

type Algorithm ¶

type Algorithm int32

const (
	Algorithm_PBFT                Algorithm = 0
	Algorithm_SBFT                Algorithm = 1
	Algorithm_Zyzzyva             Algorithm = 2
	Algorithm_EzBFT               Algorithm = 3
	Algorithm_Hybster             Algorithm = 4
	Algorithm_Destiny             Algorithm = 5
	Algorithm_Dester              Algorithm = 6
	Algorithm_LinHybster          Algorithm = 7
	Algorithm_SBFTSlow            Algorithm = 8
	Algorithm_Hotstuff            Algorithm = 9
	Algorithm_Broadcast           Algorithm = 10
	Algorithm_Prime               Algorithm = 11
	Algorithm_PreDestiny          Algorithm = 12
	Algorithm_MinBFT              Algorithm = 13
	Algorithm_DuoBFT              Algorithm = 14
	Algorithm_MinBFTSig           Algorithm = 15
	Algorithm_SBFTx               Algorithm = 16
	Algorithm_Hybsterx            Algorithm = 17
	Algorithm_ChainHotstuff       Algorithm = 18
	Algorithm_RCC                 Algorithm = 19
	Algorithm_MirBFT              Algorithm = 20
	Algorithm_Dispel              Algorithm = 21
	Algorithm_DQPBFT              Algorithm = 22
	Algorithm_DQSBFTSlow          Algorithm = 23
	Algorithm_ChainDuoBFT         Algorithm = 24
	Algorithm_MultiChainDuoBFT    Algorithm = 25
	Algorithm_MultiChainDuoBFTRCC Algorithm = 26
)

func (Algorithm) EnumDescriptor ¶

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

func (Algorithm) MarshalJSON ¶

func (a Algorithm) MarshalJSON() ([]byte, error)

func (Algorithm) String ¶

func (x Algorithm) String() string

func (*Algorithm) UnmarshalJSON ¶

func (a *Algorithm) UnmarshalJSON(b []byte) error

type BasicPeerInfo ¶

type BasicPeerInfo struct {
	PodName     string `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	HostMachine string `protobuf:"bytes,2,opt,name=host_machine,json=hostMachine,proto3" json:"host_machine,omitempty"`
	PodIP       string `protobuf:"bytes,3,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
	Region      string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
}

Peer related proto messages.

func (*BasicPeerInfo) Descriptor ¶

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

func (*BasicPeerInfo) GetHostMachine ¶

func (m *BasicPeerInfo) GetHostMachine() string

func (*BasicPeerInfo) GetPodIP ¶

func (m *BasicPeerInfo) GetPodIP() string

func (*BasicPeerInfo) GetPodName ¶

func (m *BasicPeerInfo) GetPodName() string

func (*BasicPeerInfo) GetRegion ¶

func (m *BasicPeerInfo) GetRegion() string

func (*BasicPeerInfo) Marshal ¶

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

func (*BasicPeerInfo) MarshalTo ¶

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

func (*BasicPeerInfo) MarshalToSizedBuffer ¶

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

func (*BasicPeerInfo) ProtoMessage ¶

func (*BasicPeerInfo) ProtoMessage()

func (*BasicPeerInfo) Reset ¶

func (m *BasicPeerInfo) Reset()

func (*BasicPeerInfo) Size ¶

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

func (*BasicPeerInfo) String ¶

func (m *BasicPeerInfo) String() string

func (*BasicPeerInfo) Unmarshal ¶

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

func (*BasicPeerInfo) XXX_DiscardUnknown ¶

func (m *BasicPeerInfo) XXX_DiscardUnknown()

func (*BasicPeerInfo) XXX_Marshal ¶

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

func (*BasicPeerInfo) XXX_Merge ¶

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

func (*BasicPeerInfo) XXX_Size ¶

func (m *BasicPeerInfo) XXX_Size() int

func (*BasicPeerInfo) XXX_Unmarshal ¶

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

type Message ¶

type Message struct {
	From        PeerID            `protobuf:"varint,1,opt,name=from,proto3,casttype=PeerID" json:"from,omitempty"`
	To          PeerID            `protobuf:"varint,2,opt,name=to,proto3,casttype=PeerID" json:"to,omitempty"`
	Content     []byte            `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Certificate []byte            `protobuf:"bytes,4,opt,name=certificate,proto3" json:"certificate,omitempty"`
	TraceInfo   map[string]string `` /* 176-byte string literal not displayed */
}

func (*Message) Descriptor ¶

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

func (*Message) GetCertificate ¶

func (m *Message) GetCertificate() []byte

func (*Message) GetContent ¶

func (m *Message) GetContent() []byte

func (*Message) GetFrom ¶

func (m *Message) GetFrom() PeerID

func (*Message) GetTo ¶

func (m *Message) GetTo() PeerID

func (*Message) GetTraceInfo ¶

func (m *Message) GetTraceInfo() map[string]string

func (*Message) Marshal ¶

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

func (*Message) MarshalTo ¶

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

func (*Message) MarshalToSizedBuffer ¶

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

func (*Message) ProtoMessage ¶

func (*Message) ProtoMessage()

func (*Message) Reset ¶

func (m *Message) Reset()

func (*Message) Size ¶

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

func (*Message) String ¶

func (m *Message) String() string

func (*Message) Unmarshal ¶

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

func (*Message) XXX_DiscardUnknown ¶

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal ¶

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

func (*Message) XXX_Merge ¶

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

func (*Message) XXX_Size ¶

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal ¶

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

type MultiChainDuoBFTConfig ¶

type MultiChainDuoBFTConfig struct {
	RCCMode          bool   `protobuf:"varint,1,opt,name=rcc_mode,json=rccMode,proto3" json:"rcc_mode,omitempty"`
	InstancesPerPeer uint32 `protobuf:"varint,2,opt,name=instances_per_peer,json=instancesPerPeer,proto3" json:"instances_per_peer,omitempty"`
	SkipSlowPath     bool   `protobuf:"varint,3,opt,name=skip_slow_path,json=skipSlowPath,proto3" json:"skip_slow_path,omitempty"`
}

func (*MultiChainDuoBFTConfig) Descriptor ¶

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

func (*MultiChainDuoBFTConfig) GetInstancesPerPeer ¶

func (m *MultiChainDuoBFTConfig) GetInstancesPerPeer() uint32

func (*MultiChainDuoBFTConfig) GetRCCMode ¶

func (m *MultiChainDuoBFTConfig) GetRCCMode() bool

func (*MultiChainDuoBFTConfig) GetSkipSlowPath ¶

func (m *MultiChainDuoBFTConfig) GetSkipSlowPath() bool

func (*MultiChainDuoBFTConfig) Marshal ¶

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

func (*MultiChainDuoBFTConfig) MarshalTo ¶

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

func (*MultiChainDuoBFTConfig) MarshalToSizedBuffer ¶

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

func (*MultiChainDuoBFTConfig) ProtoMessage ¶

func (*MultiChainDuoBFTConfig) ProtoMessage()

func (*MultiChainDuoBFTConfig) Reset ¶

func (m *MultiChainDuoBFTConfig) Reset()

func (*MultiChainDuoBFTConfig) Size ¶

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

func (*MultiChainDuoBFTConfig) String ¶

func (m *MultiChainDuoBFTConfig) String() string

func (*MultiChainDuoBFTConfig) Unmarshal ¶

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

func (*MultiChainDuoBFTConfig) XXX_DiscardUnknown ¶

func (m *MultiChainDuoBFTConfig) XXX_DiscardUnknown()

func (*MultiChainDuoBFTConfig) XXX_Marshal ¶

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

func (*MultiChainDuoBFTConfig) XXX_Merge ¶

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

func (*MultiChainDuoBFTConfig) XXX_Size ¶

func (m *MultiChainDuoBFTConfig) XXX_Size() int

func (*MultiChainDuoBFTConfig) XXX_Unmarshal ¶

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

type PeerConfig ¶

type PeerConfig struct {
	PeerDetails            []PeerInfo              `protobuf:"bytes,1,rep,name=peer_details,json=peerDetails,proto3" json:"peer_details"`
	ListenPort             int32                   `protobuf:"varint,2,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	LogVerbose             bool                    `protobuf:"varint,3,opt,name=log_verbose,json=logVerbose,proto3" json:"log_verbose,omitempty"`
	Algorithm              Algorithm               `protobuf:"varint,4,opt,name=algorithm,proto3,enum=peerpb.Algorithm" json:"algorithm,omitempty"`
	MaxFailures            int32                   `protobuf:"varint,5,opt,name=max_failures,json=maxFailures,proto3" json:"max_failures,omitempty"`
	MaxFastFailures        int32                   `protobuf:"varint,6,opt,name=max_fast_failures,json=maxFastFailures,proto3" json:"max_fast_failures,omitempty"`
	LeaderID               PeerID                  `protobuf:"varint,7,opt,name=leader_id,json=leaderId,proto3,casttype=PeerID" json:"leader_id,omitempty"`
	SecretKeys             []string                `protobuf:"bytes,8,rep,name=secret_keys,json=secretKeys,proto3" json:"secret_keys,omitempty"`
	PublicKeys             []string                `protobuf:"bytes,9,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"`
	EnclavePath            string                  `protobuf:"bytes,10,opt,name=enclave_path,json=enclavePath,proto3" json:"enclave_path,omitempty"`
	EnclaveBatchSize       int32                   `protobuf:"varint,11,opt,name=enclave_batch_size,json=enclaveBatchSize,proto3" json:"enclave_batch_size,omitempty"`
	DqOBatchSize           uint32                  `protobuf:"varint,12,opt,name=dq_o_batch_size,json=dqOBatchSize,proto3" json:"dq_o_batch_size,omitempty"`
	DqOBatchTimeout        uint32                  `protobuf:"varint,22,opt,name=dq_o_batch_timeout,json=dqOBatchTimeout,proto3" json:"dq_o_batch_timeout,omitempty"`
	Workers                map[string]uint32       `` /* 157-byte string literal not displayed */
	WorkersQueueSizes      map[string]uint32       `` /* 204-byte string literal not displayed */
	CmdBatchSize           uint32                  `protobuf:"varint,15,opt,name=cmd_batch_size,json=cmdBatchSize,proto3" json:"cmd_batch_size,omitempty"`
	CmdBatchTimeout        uint32                  `protobuf:"varint,16,opt,name=cmd_batch_timeout,json=cmdBatchTimeout,proto3" json:"cmd_batch_timeout,omitempty"`
	ReqBufThreshold        int32                   `protobuf:"varint,17,opt,name=req_buf_threshold,json=reqBufThreshold,proto3" json:"req_buf_threshold,omitempty"`
	ThreshsignFastLagrange bool                    `` /* 131-byte string literal not displayed */
	RccAlgorithm           Algorithm               `protobuf:"varint,20,opt,name=rcc_algorithm,json=rccAlgorithm,proto3,enum=peerpb.Algorithm" json:"rcc_algorithm,omitempty"`
	DispelWaitForAllRb     bool                    `protobuf:"varint,21,opt,name=dispel_wait_for_all_rb,json=dispelWaitForAllRb,proto3" json:"dispel_wait_for_all_rb,omitempty"`
	MultiChainDuoBFT       *MultiChainDuoBFTConfig `protobuf:"bytes,23,opt,name=multichainduobft,proto3" json:"multichainduobft,omitempty"`
}

func (*PeerConfig) Descriptor ¶

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

func (*PeerConfig) GetAlgorithm ¶

func (m *PeerConfig) GetAlgorithm() Algorithm

func (*PeerConfig) GetCmdBatchSize ¶

func (m *PeerConfig) GetCmdBatchSize() uint32

func (*PeerConfig) GetCmdBatchTimeout ¶

func (m *PeerConfig) GetCmdBatchTimeout() uint32

func (*PeerConfig) GetDispelWaitForAllRb ¶

func (m *PeerConfig) GetDispelWaitForAllRb() bool

func (*PeerConfig) GetDqOBatchSize ¶

func (m *PeerConfig) GetDqOBatchSize() uint32

func (*PeerConfig) GetDqOBatchTimeout ¶

func (m *PeerConfig) GetDqOBatchTimeout() uint32

func (*PeerConfig) GetEnclaveBatchSize ¶

func (m *PeerConfig) GetEnclaveBatchSize() int32

func (*PeerConfig) GetEnclavePath ¶

func (m *PeerConfig) GetEnclavePath() string

func (*PeerConfig) GetLeaderID ¶

func (m *PeerConfig) GetLeaderID() PeerID

func (*PeerConfig) GetListenPort ¶

func (m *PeerConfig) GetListenPort() int32

func (*PeerConfig) GetLogVerbose ¶

func (m *PeerConfig) GetLogVerbose() bool

func (*PeerConfig) GetMaxFailures ¶

func (m *PeerConfig) GetMaxFailures() int32

func (*PeerConfig) GetMaxFastFailures ¶

func (m *PeerConfig) GetMaxFastFailures() int32

func (*PeerConfig) GetMultiChainDuoBFT ¶

func (m *PeerConfig) GetMultiChainDuoBFT() *MultiChainDuoBFTConfig

func (*PeerConfig) GetPeerDetails ¶

func (m *PeerConfig) GetPeerDetails() []PeerInfo

func (*PeerConfig) GetPublicKeys ¶

func (m *PeerConfig) GetPublicKeys() []string

func (*PeerConfig) GetRccAlgorithm ¶

func (m *PeerConfig) GetRccAlgorithm() Algorithm

func (*PeerConfig) GetReqBufThreshold ¶

func (m *PeerConfig) GetReqBufThreshold() int32

func (*PeerConfig) GetSecretKeys ¶

func (m *PeerConfig) GetSecretKeys() []string

func (*PeerConfig) GetThreshsignFastLagrange ¶

func (m *PeerConfig) GetThreshsignFastLagrange() bool

func (*PeerConfig) GetWorkers ¶

func (m *PeerConfig) GetWorkers() map[string]uint32

func (*PeerConfig) GetWorkersQueueSizes ¶

func (m *PeerConfig) GetWorkersQueueSizes() map[string]uint32

func (*PeerConfig) Marshal ¶

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

func (*PeerConfig) MarshalTo ¶

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

func (*PeerConfig) MarshalToSizedBuffer ¶

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

func (*PeerConfig) ProtoMessage ¶

func (*PeerConfig) ProtoMessage()

func (*PeerConfig) Reset ¶

func (m *PeerConfig) Reset()

func (*PeerConfig) Size ¶

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

func (*PeerConfig) String ¶

func (m *PeerConfig) String() string

func (*PeerConfig) Unmarshal ¶

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

func (*PeerConfig) XXX_DiscardUnknown ¶

func (m *PeerConfig) XXX_DiscardUnknown()

func (*PeerConfig) XXX_Marshal ¶

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

func (*PeerConfig) XXX_Merge ¶

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

func (*PeerConfig) XXX_Size ¶

func (m *PeerConfig) XXX_Size() int

func (*PeerConfig) XXX_Unmarshal ¶

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

type PeerID ¶

type PeerID uint64

type PeerInfo ¶

type PeerInfo struct {
	BasicPeerInfo `protobuf:"bytes,1,opt,name=peer_info,json=peerInfo,proto3,embedded=peer_info" json:"peer_info"`
	PeerID        PeerID `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3,casttype=PeerID" json:"peer_id,omitempty"`
}

func (*PeerInfo) Descriptor ¶

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

func (*PeerInfo) GetPeerID ¶

func (m *PeerInfo) GetPeerID() PeerID

func (*PeerInfo) Marshal ¶

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

func (*PeerInfo) MarshalTo ¶

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

func (*PeerInfo) MarshalToSizedBuffer ¶

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

func (*PeerInfo) ProtoMessage ¶

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset ¶

func (m *PeerInfo) Reset()

func (*PeerInfo) Size ¶

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

func (*PeerInfo) String ¶

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal ¶

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

func (*PeerInfo) XXX_DiscardUnknown ¶

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal ¶

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

func (*PeerInfo) XXX_Merge ¶

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

func (*PeerInfo) XXX_Size ¶

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal ¶

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

Source Files ¶

View all Source files

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