message

package
v0.0.0-...-23aeb14 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2019 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Message_UNDEFINED = iota + 0
	Message_DISC_HELLO
	Message_DISC_DISCONNECT
	Message_DISC_GET_PEERS
	Message_DISC_PEERS
	Message_DISC_NEWMSG
	Message_CHAIN_TASKS
	Message_RESPONSE
	Message_CONSENSUS = 20
)
View Source 
const (
	Message_Undefined = iota + 0
	Message_Request
	Message_RequestBatch
	Message_PrePrepare
	Message_Prepare
	Message_Commit
	Message_Checkpoint
	Message_ViewChange
	Message_NewView
	Message_FetchRequestBatch
	Message_ReturnRequestBatch // == Message_RequestBatch
)

Variables

This section is empty.

Functions

func Digest 

func Digest(msg MessageInterface) pbftTypes.MessageDigest

func MarshalMsg 

func MarshalMsg(msgType uint32, msg MessageInterface) ([]byte, error)

func MarshalMsgList 

func MarshalMsgList(msgType uint32, msgList interface{}) ([]byte, error)

func UnmarshalMsg 

func UnmarshalMsg(buff []byte, msg *MessageInterface) error

func UnmarshalMsgList 

func UnmarshalMsgList(buff []byte) (interface{}, error)

Types

type Block 

type Block struct {
	ConsensusMetadata []byte
	PreviousBlockHash pbftTypes.MessageDigest
	StateResults      []*Result
	Tasks             []*Task
}

type Checkpoint 

type Checkpoint struct {
	SequenceNumber uint64              `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	ReplicaId      pbftTypes.ReplicaID `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) Marshal 

func (cpt *Checkpoint) Marshal() ([]byte, error)

func (*Checkpoint) Sender 

func (pp *Checkpoint) Sender() pbftTypes.ReplicaID

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    pbftTypes.MessageDigest `protobuf:"bytes,3,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	ReplicaId      pbftTypes.ReplicaID     `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*Commit) Marshal 

func (cmt *Commit) Marshal() ([]byte, error)

func (*Commit) Sender 

func (pp *Commit) Sender() pbftTypes.ReplicaID

type FetchRequestBatch 

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

func (*FetchRequestBatch) Marshal 

func (fr *FetchRequestBatch) Marshal() ([]byte, error)

func (*FetchRequestBatch) Sender 

func (pp *FetchRequestBatch) Sender() pbftTypes.ReplicaID

type Message 

type Message struct {
	Type      uint32 `protobuf:"varint,1,opt,name=type,enum=protos.Message_Type" json:"type,omitempty"`
	Timestamp uint64 `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	Sender    pbftTypes.PeerID
	Payload   []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Message) Unmarshal 

func (msg *Message) Unmarshal() (MessageInterface, error)

type MessageInterface 

type MessageInterface interface {
	Marshal() ([]byte, error)
	Sender() pbftTypes.ReplicaID
}

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]pbftTypes.MessageDigest `` /* 129-byte string literal not displayed */
	ReplicaId pbftTypes.ReplicaID                `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*NewView) Marshal 

func (nv *NewView) Marshal() ([]byte, error)

func (*NewView) Sender 

func (pp *NewView) Sender() pbftTypes.ReplicaID

type PbftMessage 

type PbftMessage struct {
	PbftType  uint32
	Timestamp uint64
	Sender    pbftTypes.PeerID
	Payload   []byte
	Signature []byte
}

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    pbftTypes.MessageDigest `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      pbftTypes.ReplicaID     `protobuf:"varint,5,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*PrePrepare) Marshal 

func (pp *PrePrepare) Marshal() ([]byte, error)

func (*PrePrepare) Sender 

func (pp *PrePrepare) Sender() pbftTypes.ReplicaID

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    pbftTypes.MessageDigest `protobuf:"bytes,3,opt,name=batch_digest,json=batchDigest" json:"batch_digest,omitempty"`
	ReplicaId      pbftTypes.ReplicaID     `protobuf:"varint,4,opt,name=replica_id,json=replicaId" json:"replica_id,omitempty"`
}

func (*Prepare) Marshal 

func (pre *Prepare) Marshal() ([]byte, error)

func (*Prepare) Sender 

func (pp *Prepare) Sender() pbftTypes.ReplicaID

type RawMessage 

type RawMessage struct {
	Type    uint32
	Payload []byte
}

type Request 

type Request struct {
	Timestamp uint64
	ReplicaId pbftTypes.ReplicaID
	Tasks     []*Task
	Signature []byte
}

func (*Request) Marshal 

func (req *Request) Marshal() ([]byte, error)

func (*Request) Sender 

func (req *Request) Sender() pbftTypes.ReplicaID

type RequestBatch 

type RequestBatch []*Request

func (*RequestBatch) Marshal 

func (req *RequestBatch) Marshal() ([]byte, error)

func (*RequestBatch) Sender 

func (req *RequestBatch) Sender() pbftTypes.ReplicaID

type Result 

type Result struct {
	Type      uint32
	TimeStamp uint64
	Payload   []byte
}

type ReturnRequestBatch 

type ReturnRequestBatch []*Request

func (*ReturnRequestBatch) Marshal 

func (req *ReturnRequestBatch) Marshal() ([]byte, error)

func (*ReturnRequestBatch) Sender 

func (pp *ReturnRequestBatch) Sender() pbftTypes.ReplicaID

type StateInfo 

type StateInfo struct {
	Hash    pbftTypes.MessageDigest
	Number  uint64
	Payload interface{}
}

func (*StateInfo) Digest 

func (info *StateInfo) Digest() pbftTypes.MessageDigest

func (*StateInfo) Height 

func (info *StateInfo) Height() uint64

type Task 

type Task struct {
	Type      uint32
	TimeStamp uint64
	ReadOnly  bool
	Payload   []byte
}

type TaskExecuteInterface 

type TaskExecuteInterface interface {
	Execute(ctxt context.Context, task *Task) (Result, error)
}

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 pbftTypes.ReplicaID `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) GetID 

func (vc *ViewChange) GetID() pbftTypes.ReplicaID

func (*ViewChange) GetSignature 

func (vc *ViewChange) GetSignature() []byte

func (*ViewChange) Marshal 

func (vc *ViewChange) Marshal() ([]byte, error)

func (*ViewChange) Sender 

func (pp *ViewChange) Sender() pbftTypes.ReplicaID

func (*ViewChange) Serialize 

func (vc *ViewChange) Serialize() ([]byte, error)

func (*ViewChange) SetID 

func (vc *ViewChange) SetID(id pbftTypes.ReplicaID)

func (*ViewChange) SetSignature 

func (vc *ViewChange) SetSignature(sig []byte)

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

type ViewChange_PQ 

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

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.