ppspp

package

v0.0.0-...-249e25c Latest Latest Go to latest Published: Jun 10, 2025 License: AGPL-3.0 Imports: 40 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/MemeLabs/strims

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type ChannelReader
- func (c *ChannelReader) HandleMessage(b []byte) (err error)
type Conn
type DeliveryMode
type MetricsSnapshot
type PeerMetricsSnapshot
type Runner
- func NewRunner(ctx context.Context, logger *zap.Logger) *Runner
- func (r *Runner) RunPeer(id []byte, w Conn) (*ChannelReader, *RunnerPeer)
type RunnerPeer
- func (p *RunnerPeer) MetricsSnapshot(t timeutil.Time) PeerMetricsSnapshot
- func (p *RunnerPeer) RunSwarm(s *Swarm, channel, peerChannel codec.Channel) error
- func (p *RunnerPeer) Stop()
- func (p *RunnerPeer) StopSwarm(s *Swarm)
type SchedulingMethod
type Swarm
- func NewDefaultSwarm(id SwarmID) (s *Swarm)
- func NewSwarm(id SwarmID, o SwarmOptions) (*Swarm, error)
- func (s *Swarm) Close() error
- func (s *Swarm) ExportCache() (*swarmpb.Cache, error)
- func (s *Swarm) ID() SwarmID
- func (s *Swarm) ImportCache(c *swarmpb.Cache) error
- func (s *Swarm) Reader() *store.BufferReader
- func (s *Swarm) URI() *URI
type SwarmID
- func DecodeSwarmID(key string) (SwarmID, error)
- func NewSwarmID(key []byte) SwarmID
- func (s SwarmID) Compare(o SwarmID) int
- func (s SwarmID) Equals(o SwarmID) bool
- func (s SwarmID) String() string
type SwarmOptions
- func NewDefaultSwarmOptions() SwarmOptions
- func (o SwarmOptions) IntegrityVerifierOptions() integrity.SwarmVerifierOptions
- func (o SwarmOptions) IntegrityWriterOptions() integrity.SwarmWriterOptions
- func (o SwarmOptions) URIOptions() URIOptions
type TransferMetricsSnapshot
type URI
- func NewURI(id SwarmID, options URIOptions) *URI
- func ParseURI(s string) (u *URI, err error)
- func (u *URI) String() string
type URIOptions
- func (o URIOptions) SwarmOptions() SwarmOptions
type Writer
- func NewWriter(o WriterOptions) (*Writer, error)
- func (w *Writer) Close() (err error)
- func (w *Writer) Flush() error
- func (w *Writer) Reset()
- func (w *Writer) Swarm() *Swarm
- func (w *Writer) Write(p []byte) (int, error)
type WriterOptions

Constants ¶

View Source

const (
	ProtocolVersion        uint8 = 2
	MinimumProtocolVersion uint8 = 2
)

protocol ooptions

Variables ¶

View Source

var (
	ErrInvalidURI = errors.New("invalid uri")
)

errors ...

Functions ¶

This section is empty.

Types ¶

type ChannelReader ¶

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

ChannelReader ...

func (*ChannelReader) HandleMessage ¶

func (c *ChannelReader) HandleMessage(b []byte) (err error)

HandleMessage ...

type Conn ¶

type Conn interface {
	ioutil.BufferedWriteFlusher
	SetQOSWeight(w uint64)
}

Conn ...

type DeliveryMode ¶

type DeliveryMode int

const (
	LowLatencyDeliveryMode DeliveryMode
	BestEffortDeliveryMode
	MandatoryDeliveryMode
)

type MetricsSnapshot ¶

type MetricsSnapshot struct {
	Read  TransferMetricsSnapshot
	Write TransferMetricsSnapshot
}

type PeerMetricsSnapshot ¶

type PeerMetricsSnapshot struct {
	MetricsSnapshot
	Swarms map[*Swarm]MetricsSnapshot
}

type Runner ¶

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

func NewRunner ¶

func NewRunner(ctx context.Context, logger *zap.Logger) *Runner

func (*Runner) RunPeer ¶

func (r *Runner) RunPeer(id []byte, w Conn) (*ChannelReader, *RunnerPeer)

type RunnerPeer ¶

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

RunnerPeer ...

func (*RunnerPeer) MetricsSnapshot ¶

func (p *RunnerPeer) MetricsSnapshot(t timeutil.Time) PeerMetricsSnapshot

func (*RunnerPeer) RunSwarm ¶

func (p *RunnerPeer) RunSwarm(s *Swarm, channel, peerChannel codec.Channel) error

RunSwarm ...

func (*RunnerPeer) Stop ¶

func (p *RunnerPeer) Stop()

Stop ...

func (*RunnerPeer) StopSwarm ¶

func (p *RunnerPeer) StopSwarm(s *Swarm)

StopSwarm ...

type SchedulingMethod ¶

type SchedulingMethod int

const (
	SeedSchedulingMethod SchedulingMethod = iota + 1
	PeerSchedulingMethod
)

type Swarm ¶

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

Swarm ...

func NewDefaultSwarm ¶

func NewDefaultSwarm(id SwarmID) (s *Swarm)

NewDefaultSwarm ...

func NewSwarm ¶

func NewSwarm(id SwarmID, o SwarmOptions) (*Swarm, error)

NewSwarm ...

func (*Swarm) Close ¶

func (s *Swarm) Close() error

Close ...

func (*Swarm) ExportCache ¶

func (s *Swarm) ExportCache() (*swarmpb.Cache, error)

func (*Swarm) ID ¶

func (s *Swarm) ID() SwarmID

ID ...

func (*Swarm) ImportCache ¶

func (s *Swarm) ImportCache(c *swarmpb.Cache) error

func (*Swarm) Reader ¶

func (s *Swarm) Reader() *store.BufferReader

Reader ...

func (*Swarm) URI ¶

func (s *Swarm) URI() *URI

URI ...

type SwarmID ¶

type SwarmID []byte

SwarmID ...

func DecodeSwarmID ¶

func DecodeSwarmID(key string) (SwarmID, error)

DecodeSwarmID ...

func NewSwarmID ¶

func NewSwarmID(key []byte) SwarmID

NewSwarmID ...

func (SwarmID) Compare ¶

func (s SwarmID) Compare(o SwarmID) int

Compare ...

func (SwarmID) Equals ¶

func (s SwarmID) Equals(o SwarmID) bool

Equals ...

func (SwarmID) String ¶

func (s SwarmID) String() string

String ...

type SwarmOptions ¶

type SwarmOptions struct {
	Label              string
	ChunkSize          int
	ChunksPerSignature int
	StreamCount        int
	LiveWindow         int
	Integrity          integrity.VerifierOptions
	SchedulingMethod   SchedulingMethod
	DeliveryMode       DeliveryMode
	BufferLayout       store.BufferLayout
}

SwarmOptions ...

func NewDefaultSwarmOptions ¶

func NewDefaultSwarmOptions() SwarmOptions

NewDefaultSwarmOptions ...

func (SwarmOptions) IntegrityVerifierOptions ¶

func (o SwarmOptions) IntegrityVerifierOptions() integrity.SwarmVerifierOptions

IntegrityVerifierOptions ...

func (SwarmOptions) IntegrityWriterOptions ¶

func (o SwarmOptions) IntegrityWriterOptions() integrity.SwarmWriterOptions

IntegrityWriterOptions ...

func (SwarmOptions) URIOptions ¶

func (o SwarmOptions) URIOptions() URIOptions

URIOptions ...

type TransferMetricsSnapshot ¶

type TransferMetricsSnapshot struct {
	Count uint64
	Rate  uint64
}

type URI ¶

type URI struct {
	ID      SwarmID
	Options URIOptions
}