pusher

Documentation

Overview

Package pusher provides protocol-orchestrating functionality over the pushsync protocol. It makes sure that chunks meant to be distributed over the network are sent used using the pushsync protocol.

Index

• Constants
• Variables
• type Op
• type OpChan
• type Service
  • func New(networkID uint64, storer Storer, pushSyncer pushsync.PushSyncer, ...) *Service
  • func (s *Service) AddFeed(c <-chan *Op)
  • func (s *Service) Close() error
  • func (s *Service) Metrics() []prometheus.Collector
• type Storer

Constants

const (
	ConcurrentPushes  = 100 // how many chunks to push simultaneously
	DefaultRetryCount = 6
)

Variables

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

Types

type Op

type Op struct {
	Chunk  swarm.Chunk
	Err    chan error
	Direct bool
	Span   opentracing.Span
}

type OpChan

type OpChan <-chan *Op

type Service

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

func New

func New(
	networkID uint64,
	storer Storer,
	pushSyncer pushsync.PushSyncer,
	validStamp postage.ValidStampFn,
	logger log.Logger,
	warmupTime time.Duration,
	retryCount int,
) *Service

func (*Service) AddFeed

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

func (*Service) Close

func (s *Service) Close() error

func (*Service) Metrics

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

type Storer

type Storer interface {
	storage.PushReporter
	storage.PushSubscriber
	ReservePutter() storage.Putter
}