arrio

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 17, 2025 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 9 more Imports: 2 Imported by: 4

Documentation

Overview

Package arrio exposes functions to manipulate records, exposing and using interfaces not unlike the ones defined in the stdlib io package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Copy 

func Copy(dst Writer, src Reader) (n int64, err error)

Copy copies all the records available from src to dst. Copy returns the number of records copied and the first error encountered while copying, if any.

A successful Copy returns err == nil, not err == EOF. Because Copy is defined to read from src until EOF, it does not treat an EOF from Read as an error to be reported.

func CopyN 

func CopyN(dst Writer, src Reader, n int64) (written int64, err error)

CopyN copies n records (or until an error) from src to dst. It returns the number of records copied and the earliest error encountered while copying. On return, written == n if and only if err == nil.

Types

type Reader 

type Reader interface {
	// Read reads the current record from the underlying stream and an error, if any.
	// When the Reader reaches the end of the underlying stream, it returns (nil, io.EOF).
	Read() (array.Record, error)
}

Reader is the interface that wraps the Read method.

type ReaderAt 

type ReaderAt interface {
	// ReadAt reads the i-th record from the underlying stream and an error, if any.
	ReadAt(i int64) (array.Record, error)
}

ReaderAt is the interface that wraps the ReadAt method.

type Writer 

type Writer interface {
	Write(rec array.Record) error
}

Writer is the interface that wraps the Write method.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.