pusher

Aug 4, 2023

Changes in this version

+ const ConcurrentPushes

+ type Storer interface

+ ReservePutter func() storage.Putter

Oct 11, 2022

Changes in this version

+ const DefaultRetryCount

Dec 7, 2021

Changes in this version

+ type Op struct

+ Chunk swarm.Chunk

+ Direct bool

+ Err chan error

+ type OpChan <-chan *Op

type Service

+ func (s *Service) AddFeed(c <-chan *Op)

Jun 21, 2021

Changes in this version

+ var ErrShallowReceipt = errors.New("shallow recipt")

May 20, 2021

Changes in this version

+ var ErrInvalidAddress = errors.New("invalid address")

Jun 29, 2020

Changes in this version

+ type Options struct

+ Logger logging.Logger

+ PeerSuggester topology.ClosestPeerer

+ PushSyncer pushsync.PushSyncer

+ Storer storage.Storer

+ Tags *tags.Tags

+ type Service struct

+ func New(o Options) *Service

+ func (s *Service) Close() error

+ func (s *Service) Metrics() []prometheus.Collector