obcpbft

package
v0.0.0-...-1d5e6b2 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2016 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package obcpbft is a generated protocol buffer package.

It is generated from these files: 

obcpbft/messages.proto

It has these top-level messages: 

Message
Request
PrePrepare
Prepare
Commit
BlockInfo
Checkpoint
ViewChange
PQset
NewView
FetchRequest
RequestBlock
BatchMessage
SieveMessage
Execute
Verify
SievePbftMessage
VerifySet
Flush
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_PbftMessage
	//	*BatchMessage_Complaint
	Payload isBatchMessage_Payload `protobuf_oneof:"payload"`
}

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) 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), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type BatchMessage_Complaint 

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

type BatchMessage_PbftMessage 

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

type BatchMessage_Request 

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

type BlockInfo 

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

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:"sequence_number,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,2,opt,name=replica_id" json:"replica_id,omitempty"`
	Id             string `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
}

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:"sequence_number,omitempty"`
	RequestDigest  string `protobuf:"bytes,3,opt,name=request_digest" json:"request_digest,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,4,opt,name=replica_id" json:"replica_id,omitempty"`
}

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) String 

func (m *Commit) String() string

type CustodyPair 

type CustodyPair struct {
	Hash    string
	Request *Request
}

CustodyPair is a tuple of enqueued id and data object

type Execute 

type Execute struct {
	View        uint64   `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	BlockNumber uint64   `protobuf:"varint,2,opt,name=block_number" json:"block_number,omitempty"`
	Request     *Request `protobuf:"bytes,3,opt,name=request" json:"request,omitempty"`
	ReplicaId   uint64   `protobuf:"varint,4,opt,name=replica_id" json:"replica_id,omitempty"`
}

func (*Execute) GetRequest 

func (m *Execute) GetRequest() *Request

func (*Execute) ProtoMessage 

func (*Execute) ProtoMessage()

func (*Execute) Reset 

func (m *Execute) Reset()

func (*Execute) String 

func (m *Execute) String() string

type FetchRequest 

type FetchRequest struct {
	RequestDigest string `protobuf:"bytes,1,opt,name=request_digest" json:"request_digest,omitempty"`
	ReplicaId     uint64 `protobuf:"varint,2,opt,name=replica_id" json:"replica_id,omitempty"`
}

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) String 

func (m *FetchRequest) String() string

type Flush 

type Flush struct {
	View      uint64 `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	ReplicaId uint64 `protobuf:"varint,2,opt,name=replica_id" json:"replica_id,omitempty"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Flush) ProtoMessage 

func (*Flush) ProtoMessage()

func (*Flush) Reset 

func (m *Flush) Reset()

func (*Flush) String 

func (m *Flush) String() string

type Message 

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

func (*Message) GetCheckpoint 

func (m *Message) GetCheckpoint() *Checkpoint

func (*Message) GetCommit 

func (m *Message) GetCommit() *Commit

func (*Message) GetFetchRequest 

func (m *Message) GetFetchRequest() *FetchRequest

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) GetRequest 

func (m *Message) GetRequest() *Request

func (*Message) GetReturnRequest 

func (m *Message) GetReturnRequest() *Request

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), []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_FetchRequest 

type Message_FetchRequest struct {
	FetchRequest *FetchRequest `protobuf:"bytes,8,opt,name=fetch_request,oneof"`
}

type Message_NewView 

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

type Message_PrePrepare 

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

type Message_Prepare 

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

type Message_Request 

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

type Message_ReturnRequest 

type Message_ReturnRequest struct {
	ReturnRequest *Request `protobuf:"bytes,9,opt,name=return_request,oneof"`
}

type Message_ViewChange 

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

type Metadata 

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

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:"replica_id,omitempty"`
}

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) 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:"sequence_number,omitempty"`
	RequestDigest  string   `protobuf:"bytes,3,opt,name=request_digest" json:"request_digest,omitempty"`
	Request        *Request `protobuf:"bytes,4,opt,name=request" json:"request,omitempty"`
	ReplicaId      uint64   `protobuf:"varint,5,opt,name=replica_id" json:"replica_id,omitempty"`
}

func (*PrePrepare) GetRequest 

func (m *PrePrepare) GetRequest() *Request

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:"sequence_number,omitempty"`
	RequestDigest  string `protobuf:"bytes,3,opt,name=request_digest" json:"request_digest,omitempty"`
	ReplicaId      uint64 `protobuf:"varint,4,opt,name=replica_id" json:"replica_id,omitempty"`
}

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:"replica_id,omitempty"`
	Signature []byte                     `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

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 RequestBlock 

type RequestBlock struct {
	Requests []*Request `protobuf:"bytes,1,rep,name=requests" json:"requests,omitempty"`
}

func (*RequestBlock) GetRequests 

func (m *RequestBlock) GetRequests() []*Request

func (*RequestBlock) ProtoMessage 

func (*RequestBlock) ProtoMessage()

func (*RequestBlock) Reset 

func (m *RequestBlock) Reset()

func (*RequestBlock) String 

func (m *RequestBlock) String() string

type SieveMessage 

type SieveMessage struct {
	// Types that are valid to be assigned to Payload:
	//	*SieveMessage_Request
	//	*SieveMessage_Execute
	//	*SieveMessage_Verify
	//	*SieveMessage_PbftMessage
	//	*SieveMessage_Complaint
	Payload isSieveMessage_Payload `protobuf_oneof:"payload"`
}

func (*SieveMessage) GetComplaint 

func (m *SieveMessage) GetComplaint() *Request

func (*SieveMessage) GetExecute 

func (m *SieveMessage) GetExecute() *Execute

func (*SieveMessage) GetPayload 

func (m *SieveMessage) GetPayload() isSieveMessage_Payload

func (*SieveMessage) GetPbftMessage 

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

func (*SieveMessage) GetRequest 

func (m *SieveMessage) GetRequest() *Request

func (*SieveMessage) GetVerify 

func (m *SieveMessage) GetVerify() *Verify

func (*SieveMessage) ProtoMessage 

func (*SieveMessage) ProtoMessage()

func (*SieveMessage) Reset 

func (m *SieveMessage) Reset()

func (*SieveMessage) String 

func (m *SieveMessage) String() string

func (*SieveMessage) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type SieveMessage_Complaint 

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

type SieveMessage_Execute 

type SieveMessage_Execute struct {
	Execute *Execute `protobuf:"bytes,2,opt,name=execute,oneof"`
}

type SieveMessage_PbftMessage 

type SieveMessage_PbftMessage struct {
	PbftMessage []byte `protobuf:"bytes,4,opt,name=pbft_message,proto3,oneof"`
}

type SieveMessage_Request 

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

type SieveMessage_Verify 

type SieveMessage_Verify struct {
	Verify *Verify `protobuf:"bytes,3,opt,name=verify,oneof"`
}

type SievePbftMessage 

type SievePbftMessage struct {
	// Types that are valid to be assigned to Payload:
	//	*SievePbftMessage_VerifySet
	//	*SievePbftMessage_Flush
	Payload isSievePbftMessage_Payload `protobuf_oneof:"payload"`
}

func (*SievePbftMessage) GetFlush 

func (m *SievePbftMessage) GetFlush() *Flush

func (*SievePbftMessage) GetPayload 

func (m *SievePbftMessage) GetPayload() isSievePbftMessage_Payload

func (*SievePbftMessage) GetVerifySet 

func (m *SievePbftMessage) GetVerifySet() *VerifySet

func (*SievePbftMessage) ProtoMessage 

func (*SievePbftMessage) ProtoMessage()

func (*SievePbftMessage) Reset 

func (m *SievePbftMessage) Reset()

func (*SievePbftMessage) String 

func (m *SievePbftMessage) String() string

func (*SievePbftMessage) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type SievePbftMessage_Flush 

type SievePbftMessage_Flush struct {
	Flush *Flush `protobuf:"bytes,2,opt,name=flush,oneof"`
}

type SievePbftMessage_VerifySet 

type SievePbftMessage_VerifySet struct {
	VerifySet *VerifySet `protobuf:"bytes,1,opt,name=verify_set,oneof"`
}

type Verify 

type Verify struct {
	View          uint64 `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	BlockNumber   uint64 `protobuf:"varint,2,opt,name=block_number" json:"block_number,omitempty"`
	RequestDigest string `protobuf:"bytes,3,opt,name=request_digest" json:"request_digest,omitempty"`
	ResultDigest  []byte `protobuf:"bytes,4,opt,name=result_digest,proto3" json:"result_digest,omitempty"`
	ReplicaId     uint64 `protobuf:"varint,5,opt,name=replica_id" json:"replica_id,omitempty"`
	Signature     []byte `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Verify) ProtoMessage 

func (*Verify) ProtoMessage()

func (*Verify) Reset 

func (m *Verify) Reset()

func (*Verify) String 

func (m *Verify) String() string

type VerifySet 

type VerifySet struct {
	View          uint64    `protobuf:"varint,1,opt,name=view" json:"view,omitempty"`
	BlockNumber   uint64    `protobuf:"varint,2,opt,name=block_number" json:"block_number,omitempty"`
	RequestDigest string    `protobuf:"bytes,3,opt,name=request_digest" json:"request_digest,omitempty"`
	Dset          []*Verify `protobuf:"bytes,4,rep,name=dset" json:"dset,omitempty"`
	ReplicaId     uint64    `protobuf:"varint,5,opt,name=replica_id" json:"replica_id,omitempty"`
	Signature     []byte    `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*VerifySet) GetDset 

func (m *VerifySet) GetDset() []*Verify

func (*VerifySet) ProtoMessage 

func (*VerifySet) ProtoMessage()

func (*VerifySet) Reset 

func (m *VerifySet) Reset()

func (*VerifySet) String 

func (m *VerifySet) 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:"replica_id,omitempty"`
	Signature []byte           `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
}

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:"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) 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:"sequence_number,omitempty"`
	Digest         string `protobuf:"bytes,2,opt,name=digest" json:"digest,omitempty"`
	View           uint64 `protobuf:"varint,3,opt,name=view" json:"view,omitempty"`
}

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

Directories

Path Synopsis

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.