spool

package

v0.1.0 Latest Latest Go to latest Published: Mar 12, 2026 License: MIT Imports: 9 Imported by: 0

Details

View Source

const (
	DefaultMaxFiles = 5
	DefaultMaxAge   = 1 * time.Hour
)

This section is empty.

This section is empty.

type Spool struct {
	Dir      string
	MaxFiles int
	MaxAge   time.Duration
}

Spool manages temporary Arrow IPC files for a session.

func NewSpool(sessionID string) (*Spool, error)

NewSpool creates a new result spool for the given session.

func (s *Spool) Cleanup() error

Cleanup removes files exceeding the max count and max age limits.

func (s *Spool) Destroy() error

Destroy removes the entire spool directory.

func (s *Spool) Path(queryID string) string

Path returns the Arrow IPC file path for a given query ID.

func (s *Spool) Write(queryID string, records []arrow.Record) error

Write writes Arrow records to an IPC file.