streaming

type BackpressureConfig struct {
	BufferSize      int           `json:"buffer_size"`
	HighWaterMark   float64       `json:"high_water_mark"` // 0.0-1.0
	LowWaterMark    float64       `json:"low_water_mark"`  // 0.0-1.0
	SlowConsumerTTL time.Duration `json:"slow_consumer_ttl"`
	DropPolicy      DropPolicy    `json:"drop_policy"`
}

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

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

type DropPolicy int

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

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

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

type StreamStats struct {
	Produced   int64     `json:"produced"`
	Consumed   int64     `json:"consumed"`
	Dropped    int64     `json:"dropped"`
	Blocked    int64     `json:"blocked"`
	BufferSize int       `json:"buffer_size"`
	BufferCap  int       `json:"buffer_cap"`
	IsPaused   bool      `json:"is_paused"`
	LastWrite  time.Time `json:"last_write"`
	LastRead   time.Time `json:"last_read"`
}

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

type Token struct {
	Content   string    `json:"content"`
	Index     int       `json:"index"`
	Timestamp time.Time `json:"timestamp"`
	Final     bool      `json:"final"`
}

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