rowiterator

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPGBaseSelectClause 

func NewPGBaseSelectClause(table Table) *tree.Select

Types

type Iterator 

type Iterator interface {
	Conn() dbconn.Conn
	HasNext(ctx context.Context) bool
	Error() error
	Peek(ctx context.Context) tree.Datums
	Next(ctx context.Context) tree.Datums
}

func NewPointLookupIterator 

func NewPointLookupIterator(conn dbconn.Conn, table Table, pks []tree.Datums) Iterator

NewPointLookupIterator returns a row iterator does a point lookup.

func NewScanIterator 

func NewScanIterator(
	ctx context.Context,
	conn dbconn.Conn,
	table ScanTable,
	rowBatchSize int,
	rateLimiter *rate.Limiter,
) (Iterator, error)

NewScanIterator returns a row iterator which scans the given table.

type ScanTable 

type ScanTable struct {
	Table
	AOST        *time.Time
	StartPKVals []tree.Datum
	EndPKVals   []tree.Datum
}

type Table 

type Table struct {
	dbtable.Name
	ColumnsWithAttr   dbtable.ColumnListWithAttr
	ColumnOIDs        []oid.Oid
	PrimaryKeyColumns []tree.Name
}

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.