gossip

Documentation

Index

• Constants
• type Protocol
  • func NewProtocol(config config.SwarmConfig, base baseNetwork, ...) *Protocol
  • func (prot *Protocol) Broadcast(payload []byte, nextProt string) error
  • func (prot *Protocol) Close()
  • func (prot *Protocol) Relay(sender p2pcrypto.PublicKey, protocol string, msg service.Data) error
  • func (prot *Protocol) SetPriority(protoName string, priority priorityq.Priority)
  • func (prot *Protocol) Start()

Constants

const ProtocolName = "/p2p/1.0/gossip"

Types

type Protocol

type Protocol struct {
	log.Log
	// contains filtered or unexported fields
}

Protocol is the gossip protocol

func NewProtocol

func NewProtocol(config config.SwarmConfig, base baseNetwork, localNodePubkey p2pcrypto.PublicKey, log2 log.Log) *Protocol

NewProtocol creates a new gossip protocol instance. Call Start to start reading peers

func (*Protocol) Broadcast

func (prot *Protocol) Broadcast(payload []byte, nextProt string) error

Broadcast is the actual broadcast procedure - process the message internally and loop on peers and add the message to their queues

func (*Protocol) Close

func (prot *Protocol) Close()

func (*Protocol) Relay

func (prot *Protocol) Relay(sender p2pcrypto.PublicKey, protocol string, msg service.Data) error

func (*Protocol) SetPriority

func (prot *Protocol) SetPriority(protoName string, priority priorityq.Priority)

func (*Protocol) Start

func (prot *Protocol) Start()

Start a loop that process peers events