stream

type Backpressure int

type BackpressureHandler interface {
	// Send delivers a chunk to the target channel, applying the strategy
	// when the channel is full. Returns ErrBackpressure or context errors.
	Send(ctx context.Context, ch chan *Chunk, chunk *Chunk) error
}

type Checksum struct {
	Algorithm string // "sha256", "blake3", "xxhash"
	Value     []byte
}

type Chunk struct {
	// Index is the sequential chunk number within the stream (0-based).
	Index int

	// Offset is the byte offset of this chunk within the full object.
	Offset int64

	// Data holds the chunk payload. The backing slice comes from a ChunkPool
	// and must be returned after processing.
	Data []byte

	// Size is the number of valid bytes in Data (may be less than cap(Data)
	// for the final chunk).
	Size int

	// Checksum holds an optional integrity hash for this chunk.
	Checksum Checksum

	// Final marks this as the last chunk in the stream.
	Final bool
}

type ChunkAck struct {
	Index int
	ETag  string
	Err   error
}

type ChunkHook func(*Chunk, ChunkAck)

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

type ChunkPoolStats struct {
	Allocated int64 `json:"allocated"`
	Released  int64 `json:"released"`
	ChunkSize int64 `json:"chunk_size"`
}

type CompleteHook func(*driver.ObjectInfo)

type ControlMsg struct {
	Type   ControlType
	Offset int64 // For CtrlSeek.
}

type ControlType int

type Direction int

type ErrorHook func(error)

type Metrics struct {
	BytesSent atomic.Int64
	BytesRecv atomic.Int64
	Chunks    atomic.Int64
	Retries   atomic.Int64
	StartTime time.Time
}

type MetricsSnapshot struct {
	ActiveStreams int64         `json:"active_streams"`
	TotalBytes    int64         `json:"total_bytes"`
	TotalChunks   int64         `json:"total_chunks"`
	FailedStreams int64         `json:"failed_streams"`
	RetryCount    int64         `json:"retry_count"`
	AvgThroughput float64       `json:"avg_throughput_bps"`
	P99Latency    time.Duration `json:"p99_latency"`
}

type Option func(*streamConfig)

type Pool struct {
	ID      id.ID
	Name    string
	Config  PoolConfig
	Metrics *PoolMetrics
	// contains filtered or unexported fields
}

type PoolConfig struct {
	// MaxStreams is the maximum number of concurrent streams.
	MaxStreams int `json:"max_streams" yaml:"max_streams"`

	// MaxBandwidth limits total throughput in bytes/sec (0 = unlimited).
	MaxBandwidth int64 `json:"max_bandwidth" yaml:"max_bandwidth"`

	// ChunkSize is the default chunk size for streams in this pool.
	ChunkSize int64 `json:"chunk_size" yaml:"chunk_size"`

	// BufferCount is the initial number of buffers in the chunk pool.
	BufferCount int `json:"buffer_count" yaml:"buffer_count"`

	// StreamTimeout is the maximum lifetime of a single stream.
	StreamTimeout time.Duration `json:"stream_timeout" yaml:"stream_timeout"`

	// IdleTimeout closes a stream that has been idle for this duration.
	IdleTimeout time.Duration `json:"idle_timeout" yaml:"idle_timeout"`

	// BackpressureMode is the default backpressure strategy for streams.
	BackpressureMode Backpressure `json:"backpressure" yaml:"backpressure"`
}

type PoolMetrics struct {
	ActiveStreams atomic.Int64
	TotalBytes    atomic.Int64
	TotalChunks   atomic.Int64
	FailedStreams atomic.Int64
	RetryCount    atomic.Int64
	// contains filtered or unexported fields
}

type Progress struct {
	StreamID  id.ID
	BytesSent int64
	BytesRecv int64
	TotalSize int64
	Percent   int
	Speed     float64 // bytes/sec
}

type ProgressHook func(Progress)

type Snapshot struct {
	BytesSent  int64         `json:"bytes_sent"`
	BytesRecv  int64         `json:"bytes_recv"`
	Chunks     int64         `json:"chunks"`
	Retries    int64         `json:"retries"`
	Throughput float64       `json:"throughput_bps"`
	Elapsed    time.Duration `json:"elapsed"`
}

type State string

type Stream struct {
	ID        id.ID
	Direction Direction
	Bucket    string
	Key       string
	// contains filtered or unexported fields
}