Documentation
¶
Overview ¶
Package pushsync provides the pushsync protocol implementation.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PushSync ¶
type PushSync struct {
// contains filtered or unexported fields
}
func New ¶
func New(streamer p2p.StreamerDisconnecter, storer storage.Putter, closestPeerer topology.ClosestPeerer, tagger *tags.Tags, unwrap func(swarm.Chunk), logger logging.Logger, accounting accounting.Interface, pricer accounting.Pricer, tracer *tracing.Tracer) *PushSync
func (*PushSync) Metrics ¶
func (s *PushSync) Metrics() []prometheus.Collector
func (*PushSync) Protocol ¶
func (s *PushSync) Protocol() p2p.ProtocolSpec
func (*PushSync) PushChunkToClosest ¶
PushChunkToClosest sends chunk to the closest peer by opening a stream. It then waits for a receipt from that peer and returns error or nil based on the receiving and the validity of the receipt.
type PushSyncer ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.