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

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

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

Jump to

Keyboard shortcuts

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