Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMessageFormat ¶
func RegisterMessageFormat(c serde.Format, f serde.FormatEngine)
RegisterMessageFormat register the engine for the provided format.
Types ¶
type EndShuffle ¶
type EndShuffle struct {
}
EndShuffle is the message the node running during the last round should send to all the nodes.
- implements serde.Message
func NewEndShuffle ¶
func NewEndShuffle() EndShuffle
NewEndShuffle creates a new EndShuffle message.
type MessageFactory ¶
type MessageFactory struct {
// contains filtered or unexported fields
}
MessageFactory is a message factory for the different SHUFFLE messages.
- implements serde.Factory
func NewMessageFactory ¶
func NewMessageFactory(f mino.AddressFactory) MessageFactory
NewMessageFactory returns a message factory for the shuffle protocol.
func (MessageFactory) Deserialize ¶
Deserialize implements serde.Factory.
type StartShuffle ¶
type StartShuffle struct {
// contains filtered or unexported fields
}
StartShuffle is the message the initiator of the SHUFFLE protocol should send to all the nodes.
- implements serde.Message
func NewStartShuffle ¶
func NewStartShuffle(formId string, addresses []mino.Address) StartShuffle
NewStartShuffle creates a new StartShuffle message.
func (StartShuffle) GetAddresses ¶
func (s StartShuffle) GetAddresses() []mino.Address
GetAddresses returns the list of addresses.
func (StartShuffle) GetFormId ¶
func (s StartShuffle) GetFormId() string
GetFormId returns the formId.
Source Files
Click to show internal directories.
Click to hide internal directories.