peerpb

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: 7 Imported by: 0

Documentation

Index

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

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.