pbft

package
v0.0.0-...-171c4e9 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package pbft is a generated protocol buffer package.

It is generated from these files: 

messages.proto

It has these top-level messages: 

Message
Request
PrePrepare
Prepare
Commit
BlockInfo
Checkpoint
ViewChange
PQset
NewView
FetchRequestBatch
RequestBatch
BatchMessage
Metadata

Index

Constants

View Source 
const (
	// UnreasonableTimeout is an ugly thing, we need to create timers, then stop them before they expire, so use a large timeout
	UnreasonableTimeout = 100 * time.Hour
)

Variables

This section is empty.

Functions

func GetPlugin 

func GetPlugin(c consensus.Stack) consensus.Consenter

GetPlugin returns the handle to the Consenter singleton

func New 

func New(stack consensus.Stack) consensus.Consenter

New creates a new Obc* instance that provides the Consenter interface. Internally, it uses an opaque pbft-core instance.

Types

type BatchMessage 

type BatchMessage struct {
	// Types that are valid to be assigned to Payload:
	//	*BatchMessage_Request
	//	*BatchMessage_RequestBatch
	//	*BatchMessage_PbftMessage
	//	*BatchMessage_Complaint
	Payload isBatchMessage_Payload `protobuf_oneof:"payload"`
}

func (*BatchMessage) Descriptor 

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

func (*BatchMessage) GetComplaint 

func (m *BatchMessage) GetComplaint() *Request

func (*BatchMessage) GetPayload 

func (m *BatchMessage) GetPayload() isBatchMessage_Payload

func (*BatchMessage) GetPbftMessage 

func (m *BatchMessage) GetPbftMessage() []byte

func (*BatchMessage) GetRequest 

func (m *BatchMessage) GetRequest() *Request

func (*BatchMessage) GetRequestBatch 

func (m *BatchMessage) GetRequestBatch() *RequestBatch

func (*BatchMessage) ProtoMessage 

func (*BatchMessage) ProtoMessage()

func (*BatchMessage) Reset 

func (m *BatchMessage) Reset()

func (*BatchMessage) String 

func (m *BatchMessage) String() string

func (*BatchMessage) XXX_OneofFuncs 

func (*BatchMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type BatchMessage_Complaint 

type BatchMessage_Complaint struct {
	Complaint *Request `protobuf:"bytes,4,opt,name=complaint,oneof"`
}

type BatchMessage_PbftMessage 

type BatchMessage_PbftMessage struct {
	PbftMessage []byte `protobuf:"bytes,3,opt,name=pbft_message,json=pbftMessage,proto3,oneof"`
}

type BatchMessage_Request 

type BatchMessage_Request struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,oneof"`
}

type BatchMessage_RequestBatch 

type BatchMessage_RequestBatch struct {
	RequestBatch *RequestBatch `protobuf:"bytes,2,opt,name=request_batch,json=requestBatch,oneof"`
}

type BlockInfo 

type BlockInfo struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=block_number,json=blockNumber" json:"block_number,omitempty"`
	BlockHash   []byte `protobuf:"bytes,2,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
}

func (*BlockInfo) Descriptor 

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

func (*BlockInfo) ProtoMessage 

func (*BlockInfo) ProtoMessage()

func (*BlockInfo) Reset 

func (m *BlockInfo) Reset()

func (*BlockInfo) String 

func (m *BlockInfo) String() string

type Checkpoint 

type Checkpoint struct {
	SequenceNumber uint64 `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,2,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
	Id             string `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
}

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) Reset 

func (m *Checkpoint) Reset()

func (*Checkpoint) String 

func (m *Checkpoint) String() string

type Commit 

type Commit struct {
	View           uint64 `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	BatchDigest    string `protobuf:"bytes,3,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*Commit) Descriptor 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) String 

func (m *Commit) String() string

type FetchRequestBatch 

type FetchRequestBatch struct {
	BatchDigest string `protobuf:"bytes,1,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	ReplicaId   uint64 `protobuf:"varint,2,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*FetchRequestBatch) Descriptor 

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

func (*FetchRequestBatch) ProtoMessage 

func (*FetchRequestBatch) ProtoMessage()

func (*FetchRequestBatch) Reset 

func (m *FetchRequestBatch) Reset()

func (*FetchRequestBatch) String 

func (m *FetchRequestBatch) String() string

type Message 

type Message struct {
	// Types that are valid to be assigned to Payload:
	//	*Message_RequestBatch
	//	*Message_PrePrepare
	//	*Message_Prepare
	//	*Message_Commit
	//	*Message_Checkpoint
	//	*Message_ViewChange
	//	*Message_NewView
	//	*Message_FetchRequestBatch
	//	*Message_ReturnRequestBatch
	Payload isMessage_Payload `protobuf_oneof:"payload"`
}

func (*Message) Descriptor 

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

func (*Message) GetCheckpoint 

func (m *Message) GetCheckpoint() *Checkpoint

func (*Message) GetCommit 

func (m *Message) GetCommit() *Commit

func (*Message) GetFetchRequestBatch 

func (m *Message) GetFetchRequestBatch() *FetchRequestBatch

func (*Message) GetNewView 

func (m *Message) GetNewView() *NewView

func (*Message) GetPayload 

func (m *Message) GetPayload() isMessage_Payload

func (*Message) GetPrePrepare 

func (m *Message) GetPrePrepare() *PrePrepare

func (*Message) GetPrepare 

func (m *Message) GetPrepare() *Prepare

func (*Message) GetRequestBatch 

func (m *Message) GetRequestBatch() *RequestBatch

func (*Message) GetReturnRequestBatch 

func (m *Message) GetReturnRequestBatch() *RequestBatch

func (*Message) GetViewChange 

func (m *Message) GetViewChange() *ViewChange

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_OneofFuncs 

func (*Message) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Message_Checkpoint 

type Message_Checkpoint struct {
	Checkpoint *Checkpoint `protobuf:"bytes,5,opt,name=checkpoint,oneof"`
}

type Message_Commit 

type Message_Commit struct {
	Commit *Commit `protobuf:"bytes,4,opt,name=commit,oneof"`
}

type Message_FetchRequestBatch 

type Message_FetchRequestBatch struct {
	FetchRequestBatch *FetchRequestBatch `protobuf:"bytes,8,opt,name=fetch_request_batch,json=fetchRequestBatch,oneof"`
}

type Message_NewView 

type Message_NewView struct {
	NewView *NewView `protobuf:"bytes,7,opt,name=new_view,json=newView,oneof"`
}

type Message_PrePrepare 

type Message_PrePrepare struct {
	PrePrepare *PrePrepare `protobuf:"bytes,2,opt,name=pre_prepare,json=prePrepare,oneof"`
}

type Message_Prepare 

type Message_Prepare struct {
	Prepare *Prepare `protobuf:"bytes,3,opt,name=prepare,oneof"`
}

type Message_RequestBatch 

type Message_RequestBatch struct {
	RequestBatch *RequestBatch `protobuf:"bytes,1,opt,name=request_batch,json=requestBatch,oneof"`
}

type Message_ReturnRequestBatch 

type Message_ReturnRequestBatch struct {
	ReturnRequestBatch *RequestBatch `protobuf:"bytes,9,opt,name=return_request_batch,json=returnRequestBatch,oneof"`
}

type Message_ViewChange 

type Message_ViewChange struct {
	ViewChange *ViewChange `protobuf:"bytes,6,opt,name=view_change,json=viewChange,oneof"`
}

type Metadata 

type Metadata struct {
	SeqNo uint64 `protobuf:"varint,1,opt,name=seqNo" json:"seqNo,omitempty"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

type NewView 

type NewView struct {
	View      uint64            `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	Vset      []*ViewChange     `protobuf:"bytes,2,rep,name=vset" json:"vset,omitempty"`
	Xset      map[uint64]string `` /* 129-byte string literal not displayed */
	ReplicaId uint64            `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*NewView) Descriptor 

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

func (*NewView) GetVset 

func (m *NewView) GetVset() []*ViewChange

func (*NewView) GetXset 

func (m *NewView) GetXset() map[uint64]string

func (*NewView) ProtoMessage 

func (*NewView) ProtoMessage()

func (*NewView) Reset 

func (m *NewView) Reset()

func (*NewView) String 

func (m *NewView) String() string

type PQset 

type PQset struct {
	Set []*ViewChange_PQ `protobuf:"bytes,1,rep,name=set" json:"set,omitempty"`
}

func (*PQset) Descriptor 

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

func (*PQset) GetSet 

func (m *PQset) GetSet() []*ViewChange_PQ

func (*PQset) ProtoMessage 

func (*PQset) ProtoMessage()

func (*PQset) Reset 

func (m *PQset) Reset()

func (*PQset) String 

func (m *PQset) String() string

type PrePrepare 

type PrePrepare struct {
	View           uint64        `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	SequenceNumber uint64        `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	BatchDigest    string        `protobuf:"bytes,3,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	RequestBatch   *RequestBatch `protobuf:"bytes,4,opt,name=request_batch,json=requestBatch" json:"request_batch,omitempty"`
	ReplicaId      uint64        `protobuf:"varint,5,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*PrePrepare) Descriptor 

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

func (*PrePrepare) GetRequestBatch 

func (m *PrePrepare) GetRequestBatch() *RequestBatch

func (*PrePrepare) ProtoMessage 

func (*PrePrepare) ProtoMessage()

func (*PrePrepare) Reset 

func (m *PrePrepare) Reset()

func (*PrePrepare) String 

func (m *PrePrepare) String() string

type Prepare 

type Prepare struct {
	View           uint64 `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	BatchDigest    string `protobuf:"bytes,3,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*Prepare) Descriptor 

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

func (*Prepare) ProtoMessage 

func (*Prepare) ProtoMessage()

func (*Prepare) Reset 

func (m *Prepare) Reset()

func (*Prepare) String 

func (m *Prepare) String() string

type Request 

type Request struct {
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Payload   []byte                     `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	ReplicaId uint64                     `protobuf:"varint,3,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
	Signature []byte                     `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Request) Descriptor 

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

func (*Request) GetTimestamp 

func (m *Request) GetTimestamp() *google_protobuf.Timestamp

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type RequestBatch 

type RequestBatch struct {
	Batch []*Request `protobuf:"bytes,1,rep,name=batch" json:"batch,omitempty"`
}

func (*RequestBatch) Descriptor 

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

func (*RequestBatch) GetBatch 

func (m *RequestBatch) GetBatch() []*Request

func (*RequestBatch) ProtoMessage 

func (*RequestBatch) ProtoMessage()

func (*RequestBatch) Reset 

func (m *RequestBatch) Reset()

func (*RequestBatch) String 

func (m *RequestBatch) String() string

type ViewChange 

type ViewChange struct {
	View      uint64           `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	H         uint64           `protobuf:"varint,2,opt,name=h" json:"h,omitempty"`
	Cset      []*ViewChange_C  `protobuf:"bytes,3,rep,name=cset" json:"cset,omitempty"`
	Pset      []*ViewChange_PQ `protobuf:"bytes,4,rep,name=pset" json:"pset,omitempty"`
	Qset      []*ViewChange_PQ `protobuf:"bytes,5,rep,name=qset" json:"qset,omitempty"`
	ReplicaId uint64           `protobuf:"varint,6,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
	Signature []byte           `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*ViewChange) Descriptor 

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

func (*ViewChange) GetCset 

func (m *ViewChange) GetCset() []*ViewChange_C

func (*ViewChange) GetPset 

func (m *ViewChange) GetPset() []*ViewChange_PQ

func (*ViewChange) GetQset 

func (m *ViewChange) GetQset() []*ViewChange_PQ

func (*ViewChange) ProtoMessage 

func (*ViewChange) ProtoMessage()

func (*ViewChange) Reset 

func (m *ViewChange) Reset()

func (*ViewChange) String 

func (m *ViewChange) String() string

type ViewChange_C 

type ViewChange_C struct {
	SequenceNumber uint64 `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	Id             string `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
}

This message should go away and become a checkpoint once replica_id is removed

func (*ViewChange_C) Descriptor 

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

func (*ViewChange_C) ProtoMessage 

func (*ViewChange_C) ProtoMessage()

func (*ViewChange_C) Reset 

func (m *ViewChange_C) Reset()

func (*ViewChange_C) String 

func (m *ViewChange_C) String() string

type ViewChange_PQ 

type ViewChange_PQ struct {
	SequenceNumber uint64 `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	BatchDigest    string `protobuf:"bytes,2,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	View           uint64 `protobuf:"varint,3,opt,name=view" json:"view,omitempty"`
}

func (*ViewChange_PQ) Descriptor 

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

func (*ViewChange_PQ) ProtoMessage 

func (*ViewChange_PQ) ProtoMessage()

func (*ViewChange_PQ) Reset 

func (m *ViewChange_PQ) Reset()

func (*ViewChange_PQ) String 

func (m *ViewChange_PQ) String() string

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.