streaming

type LocalRangeStore interface {
	OpenRange(ctx context.Context, d digest.Digest, requested httprange.Range) (io.ReadCloser, int64, error)
}

type MetricsHooks struct {
	OnRequest   func(source, outcome string, duration time.Duration, bytes int64)
	OnFirstByte func(source string, duration time.Duration)
	OnInflight  func(source string, delta int)
	OnReject    func(reason string)
}

type Options struct {
	URLPolicy              URLPolicy
	ResolveCanonicalOrigin func(OriginURL) (OriginURL, bool)

	// PeerLookupTimeout, PeerAttemptTimeout, and MaxPeerAttempts use defaults when zero.
	PeerLookupTimeout  time.Duration
	PeerAttemptTimeout time.Duration
	MaxPeerAttempts    int

	SelfPeerID   ifaces.NodeID
	StartupGated bool
	Logger       *slog.Logger
	Metrics      MetricsHooks

	// Cache, when set, absorbs reads no larger than MaxCachedRangeBytes.
	// OverlayBD index reads are tiny and every node wants the same ones, so
	// caching them is what lets peers answer instead of origin.
	Cache               RangeCache
	MaxCachedRangeBytes int64
	// OnCached announces that this node can now serve ranges of d. Peers
	// discover range sources the same way they discover complete blobs, so
	// without this a cached range stays invisible to the swarm.
	OnCached func(d digest.Digest)
}

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

type OriginRangeFetcher interface {
	FetchRange(ctx context.Context, origin OriginURL, requested httprange.Range) (io.ReadCloser, int64, string, error)
}

type OriginStatusError struct {
	StatusCode int
	RetryAfter time.Duration
}

type OriginURL struct {
	Raw       string
	Digest    digest.Digest
	Canonical bool
}

type PeerRangeFetcher interface {
	FetchRangeFromPeer(ctx context.Context, peerAddr string, d digest.Digest, requested httprange.Range) (io.ReadCloser, int64, string, error)
}

type ProviderDiscovery interface {
	FindProviders(ctx context.Context, d digest.Digest) ([]ifaces.Provider, error)
}

type RangeCache interface {
	OpenRange(ctx context.Context, d digest.Digest, requested httprange.Range) (io.ReadCloser, int64, error)
	// Put returns rangecache.ErrFull without consuming r when admission is refused.
	Put(d digest.Digest, total, start int64, r io.Reader) (int64, error)
}

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

type URLPolicy struct {
	AllowedHostSuffixes []string
	AllowHTTP           bool
}