trafficprotocol

Documentation

Index

• type Interface
• type Service
  • func New(streamer p2p.Streamer, logging logging.Logger, address common.Address) *Service
  • func (s *Service) EmitCheque(ctx context.Context, peer boson.Address, cheque *cheque.SignedCheque) error
  • func (s *Service) Protocol() p2p.ProtocolSpec
  • func (s *Service) SetTraffic(traffic Traffic)
• type Traffic

Types

type Interface

type Interface interface {
	// EmitCheque sends a signed cheque to a peer.
	EmitCheque(ctx context.Context, peer boson.Address, cheque *cheque.SignedCheque) error
}

type Service

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

func New

func New(streamer p2p.Streamer, logging logging.Logger, address common.Address) *Service

func (*Service) EmitCheque

func (s *Service) EmitCheque(ctx context.Context, peer boson.Address, cheque *cheque.SignedCheque) error

func (*Service) Protocol

func (s *Service) Protocol() p2p.ProtocolSpec

func (*Service) SetTraffic

func (s *Service) SetTraffic(traffic Traffic)

type Traffic

type Traffic interface {
	ReceiveCheque(ctx context.Context, peer boson.Address, cheque *cheque.SignedCheque) error

	Handshake(peer boson.Address, beneficiary common.Address, cheque *cheque.SignedCheque) error

	LastReceivedCheque(peer boson.Address) (*cheque.SignedCheque, error)

	UpdatePeerBalance(peer boson.Address) error
}