annsensus

package
v0.0.9 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MessageTypeAnnsensus message.GeneralMessageType = 2

Functions

This section is empty.

Types

type AnnsensusMessageAdapter 

type AnnsensusMessageAdapter interface {
	AdaptGeneralMessage(incomingMsg message.GeneralMessage) (annMessage annsensus.AnnsensusMessage, err error)
	AdaptGeneralPeer(gnrPeer message.GeneralPeer) (annsensus.AnnsensusPeer, error)

	AdaptAnnsensusMessage(outgoingMsg annsensus.AnnsensusMessage) (msg message.GeneralMessage, err error)
	AdaptAnnsensusPeer(annPeer annsensus.AnnsensusPeer) (message.GeneralPeer, error)
}

type AnnsensusMessageMessageHandler 

type AnnsensusMessageMessageHandler struct {
	AnnsensusPartner        *annsensus.AnnsensusPartner
	AnnsensusMessageAdapter AnnsensusMessageAdapter
}

func (AnnsensusMessageMessageHandler) Handle 

func (a AnnsensusMessageMessageHandler) Handle(msgEvent *message.GeneralMessageEvent)

type AnnsensusMessageUnmarshaller 

type AnnsensusMessageUnmarshaller struct {
}

func (*AnnsensusMessageUnmarshaller) Unmarshal 

func (a *AnnsensusMessageUnmarshaller) Unmarshal(
	messageType annsensus.AnnsensusMessageType, message []byte) (
	outMsg annsensus.AnnsensusMessage, err error)

type AnnsensusPlugin 

type AnnsensusPlugin struct {
	Communicator     *ProxyAnnsensusPeerCommunicator
	AnnsensusPartner *annsensus.AnnsensusPartner
	// contains filtered or unexported fields
}

func NewAnnsensusPlugin 

func NewAnnsensusPlugin(termProvider annsensus.TermIdProvider,
	myAccountProvider account.AccountProvider,
	proposalGenerator bft.ProposalGenerator,
	proposalValidator bft.ProposalValidator,
	decisionMaker bft.DecisionMaker) *AnnsensusPlugin

func (*AnnsensusPlugin) GetMessageEventHandler 

func (a *AnnsensusPlugin) GetMessageEventHandler() communication.GeneralMessageEventHandler

func (*AnnsensusPlugin) SetOutgoing 

func (o *AnnsensusPlugin) SetOutgoing(outgoing communication.GeneralPeerCommunicatorOutgoing)

func (*AnnsensusPlugin) Start 

func (a *AnnsensusPlugin) Start()

func (*AnnsensusPlugin) Stop 

func (a *AnnsensusPlugin) Stop()

func (*AnnsensusPlugin) SupportedEventHandlers 

func (a *AnnsensusPlugin) SupportedEventHandlers() []eventbus.EventHandlerRegisterInfo

func (AnnsensusPlugin) SupportedMessageTypes 

func (a AnnsensusPlugin) SupportedMessageTypes() []message.GeneralMessageType

type DefaultAnnsensusMessageAdapter 

type DefaultAnnsensusMessageAdapter struct {
	// contains filtered or unexported fields
}

func (*DefaultAnnsensusMessageAdapter) AdaptAnnsensusMessage 

func (d *DefaultAnnsensusMessageAdapter) AdaptAnnsensusMessage(outgoingMsg annsensus.AnnsensusMessage) (msg message.GeneralMessage, err error)

func (*DefaultAnnsensusMessageAdapter) AdaptAnnsensusPeer 

func (d *DefaultAnnsensusMessageAdapter) AdaptAnnsensusPeer(annPeer annsensus.AnnsensusPeer) (message.GeneralPeer, error)

func (*DefaultAnnsensusMessageAdapter) AdaptGeneralMessage 

func (d *DefaultAnnsensusMessageAdapter) AdaptGeneralMessage(incomingMsg message.GeneralMessage) (annMessage annsensus.AnnsensusMessage, err error)

func (*DefaultAnnsensusMessageAdapter) AdaptGeneralPeer 

func (d *DefaultAnnsensusMessageAdapter) AdaptGeneralPeer(gnrPeer message.GeneralPeer) (annsensus.AnnsensusPeer, error)

type GeneralMessageAnnsensus 

type GeneralMessageAnnsensus struct {
	InnerMessageType annsensus.AnnsensusMessageType
	InnerMessage     []byte
}

func (*GeneralMessageAnnsensus) DecodeMsg 

func (z *GeneralMessageAnnsensus) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*GeneralMessageAnnsensus) EncodeMsg 

func (z *GeneralMessageAnnsensus) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*GeneralMessageAnnsensus) GetBytes 

func (m *GeneralMessageAnnsensus) GetBytes() []byte

func (*GeneralMessageAnnsensus) GetType 

func (m *GeneralMessageAnnsensus) GetType() message.GeneralMessageType

func (*GeneralMessageAnnsensus) MarshalMsg 

func (z *GeneralMessageAnnsensus) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*GeneralMessageAnnsensus) Msgsize 

func (z *GeneralMessageAnnsensus) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GeneralMessageAnnsensus) String 

func (m *GeneralMessageAnnsensus) String() string

func (*GeneralMessageAnnsensus) UnmarshalMsg 

func (z *GeneralMessageAnnsensus) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type ProxyAnnsensusPeerCommunicator 

type ProxyAnnsensusPeerCommunicator struct {
	AnnsensusMessageAdapter AnnsensusMessageAdapter // either TrustfulBftAdapter or PlainBftAdapter
	GeneralOutgoing         communication.GeneralPeerCommunicatorOutgoing
	// contains filtered or unexported fields
}

func (ProxyAnnsensusPeerCommunicator) Broadcast 

func (p ProxyAnnsensusPeerCommunicator) Broadcast(msg annsensus.AnnsensusMessage, peers []annsensus.AnnsensusPeer)

func (ProxyAnnsensusPeerCommunicator) GetPipeIn 

func (p ProxyAnnsensusPeerCommunicator) GetPipeIn() chan *annsensus.AnnsensusMessageEvent

func (ProxyAnnsensusPeerCommunicator) GetPipeOut 

func (p ProxyAnnsensusPeerCommunicator) GetPipeOut() chan *annsensus.AnnsensusMessageEvent

func (*ProxyAnnsensusPeerCommunicator) InitDefault 

func (p *ProxyAnnsensusPeerCommunicator) InitDefault()

func (ProxyAnnsensusPeerCommunicator) Unicast 

func (p ProxyAnnsensusPeerCommunicator) Unicast(msg annsensus.AnnsensusMessage, peer annsensus.AnnsensusPeer)

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.