table

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

type BadRow struct {
	Row     row.Row
	Details []string
}

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

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

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

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

type TableCloser interface {
	// Close should release resources being held
	Close(ctx context.Context) error
}

type TableReadCloser interface {
	TableReader
	TableCloser
}

type TableReader interface {
	// GetSchema gets the schema of the rows that this reader will return
	GetSchema() schema.Schema

	// ReadRow reads a row from a table.  If there is a bad row the returned error will be non nil, and calling
	// IsBadRow(err) will be return true. This is a potentially non-fatal error and callers can decide if they want to
	// continue on a bad row, or fail.
	ReadRow(ctx context.Context) (row.Row, error)

	// VerifySchema checks that the incoming schema matches the schema from the existing table
	VerifySchema(outSch schema.Schema) (bool, error)
}

type TableWriteCloser interface {
	TableWriter
	TableCloser
}

type TableWriter interface {
	// GetSchema gets the schema of the rows that this writer writes
	GetSchema() schema.Schema

	// WriteRow will write a row to a table
	WriteRow(ctx context.Context, r row.Row) error
}