obcpbft

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2016 License: Apache-2.0 Imports: 18 Imported by: 29

Documentation

Overview

Package obcpbft 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
Checkpoint
ViewChange
NewView
FetchRequest
BatchMessage
SieveMessage
Execute
Verify
SievePbftMessage
VerifySet
Flush
Metadata

Index

Constants

This section is empty.

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
	Payload isBatchMessage_Payload `protobuf_oneof:"payload"`
}

func (*BatchMessage) GetPayload 

func (m *BatchMessage) GetPayload() isBatchMessage_Payload

func (*BatchMessage) GetPbftMessage 

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

func (*BatchMessage) GetRequest 

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

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_PbftMessage 

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

type BatchMessage_Request 

type BatchMessage_Request struct {
	Request []byte `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

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"`
	BlockNumber    uint64 `protobuf:"varint,3,opt,name=block_number" json:"block_number,omitempty"`
	BlockHash      string `protobuf:"bytes,4,opt,name=block_hash" json:"block_hash,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 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     []byte `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	ReplicaId   uint64 `protobuf:"varint,4,opt,name=replica_id" json:"replica_id,omitempty"`
}

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 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"`
}

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 SieveMessage 

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

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() []byte

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_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 []byte `protobuf:"bytes,1,opt,name=request,proto3,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"`
	BlockNumber    uint64 `protobuf:"varint,2,opt,name=block_number" json:"block_number,omitempty"`
	BlockHash      string `protobuf:"bytes,3,opt,name=block_hash" json:"block_hash,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

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.