pricing

Documentation

Index

• type Interface
• type PaymentThresholdObserver
• type Service
  • func New(streamer p2p.Streamer, logger logging.Logger, paymentThreshold *big.Int) *Service
  • func (s *Service) AnnouncePaymentThreshold(ctx context.Context, peer infinity.Address, paymentThreshold *big.Int) error
  • func (s *Service) Protocol() p2p.ProtocolSpec
  • func (s *Service) SetPaymentThresholdObserver(observer PaymentThresholdObserver)

Types

type Interface

type Interface interface {
	AnnouncePaymentThreshold(ctx context.Context, peer infinity.Address, paymentThreshold *big.Int) error
}

Interface is the main interface of the pricing protocol

type PaymentThresholdObserver

type PaymentThresholdObserver interface {
	NotifyPaymentThreshold(peer infinity.Address, paymentThreshold *big.Int) error
}

PaymentThresholdObserver is used for being notified of payment threshold updates

type Service

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

func New

func New(streamer p2p.Streamer, logger logging.Logger, paymentThreshold *big.Int) *Service

func (*Service) AnnouncePaymentThreshold

func (s *Service) AnnouncePaymentThreshold(ctx context.Context, peer infinity.Address, paymentThreshold *big.Int) error

AnnouncePaymentThreshold announces the payment threshold to per

func (*Service) Protocol

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

func (*Service) SetPaymentThresholdObserver

func (s *Service) SetPaymentThresholdObserver(observer PaymentThresholdObserver)

SetPaymentThresholdObserver sets the PaymentThresholdObserver to be used when receiving a new payment threshold