table

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeleteIterator added in v0.17.0 

type DeleteIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*DeleteIterator) Error added in v0.17.0 

func (it *DeleteIterator) Error() error

func (*DeleteIterator) Next added in v0.17.0 

func (it *DeleteIterator) Next() bool

func (*DeleteIterator) Row added in v0.17.0 

func (it *DeleteIterator) Row() (database.Row, error)

type DeleteOperator 

type DeleteOperator struct {
	stream.BaseOperator
	Name string
}

A DeleteOperator replaces objects in the table

func Delete 

func Delete(tableName string) *DeleteOperator

Delete deletes rows from the table.

func (*DeleteOperator) Iterator added in v0.17.0 

func (op *DeleteOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

Iterate implements the Operator interface.

func (*DeleteOperator) String 

func (op *DeleteOperator) String() string

type GenerateKeyIterator added in v0.17.0 

type GenerateKeyIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*GenerateKeyIterator) Error added in v0.17.0 

func (it *GenerateKeyIterator) Error() error

func (*GenerateKeyIterator) Next added in v0.17.0 

func (it *GenerateKeyIterator) Next() bool

func (*GenerateKeyIterator) Row added in v0.17.0 

func (it *GenerateKeyIterator) Row() (database.Row, error)

type GenerateKeyOperator added in v0.17.0 

type GenerateKeyOperator struct {
	stream.BaseOperator

	TableName           string
	OnConflict          *stream.Stream
	OnConflictDoNothing bool
}

GenerateKeyOperator

func GenerateKey added in v0.17.0 

func GenerateKey(tableName string) *GenerateKeyOperator

func GenerateKeyOnConflict added in v0.17.0 

func GenerateKeyOnConflict(tableName string, onConflict *stream.Stream) *GenerateKeyOperator

func GenerateKeyOnConflictDoNothing added in v0.17.0 

func GenerateKeyOnConflictDoNothing(tableName string) *GenerateKeyOperator

func (*GenerateKeyOperator) Iterator added in v0.17.0 

func (op *GenerateKeyOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*GenerateKeyOperator) String added in v0.17.0 

func (op *GenerateKeyOperator) String() string

type InsertIterator added in v0.17.0 

type InsertIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*InsertIterator) Error added in v0.17.0 

func (it *InsertIterator) Error() error

func (*InsertIterator) Next added in v0.17.0 

func (it *InsertIterator) Next() bool

func (*InsertIterator) Row added in v0.17.0 

func (it *InsertIterator) Row() (database.Row, error)

type InsertOperator 

type InsertOperator struct {
	stream.BaseOperator
	Name string
}

A InsertOperator inserts incoming rows to the table.

func Insert 

func Insert(tableName string) *InsertOperator

Insert inserts incoming rows to the table.

func (*InsertOperator) Columns added in v0.17.0 

func (op *InsertOperator) Columns(env *environment.Environment) ([]string, error)

func (*InsertOperator) Iterator added in v0.17.0 

func (op *InsertOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

Iterate implements the Operator interface.

func (*InsertOperator) String 

func (op *InsertOperator) String() string

type ReplaceIterator added in v0.17.0 

type ReplaceIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*ReplaceIterator) Error added in v0.17.0 

func (it *ReplaceIterator) Error() error

func (*ReplaceIterator) Next added in v0.17.0 

func (it *ReplaceIterator) Next() bool

func (*ReplaceIterator) Row added in v0.17.0 

func (it *ReplaceIterator) Row() (database.Row, error)

type ReplaceOperator 

type ReplaceOperator struct {
	stream.BaseOperator
	Name string
}

A ReplaceOperator replaces objects in the table

func Replace 

func Replace(tableName string) *ReplaceOperator

Replace replaces objects in the table.

func (*ReplaceOperator) Iterator added in v0.17.0 

func (op *ReplaceOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

Iterate implements the Operator interface.

func (*ReplaceOperator) String 

func (op *ReplaceOperator) String() string

type ScanIterator added in v0.17.0 

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

func (*ScanIterator) Close added in v0.17.0 

func (it *ScanIterator) Close() error

func (*ScanIterator) Error added in v0.17.0 

func (it *ScanIterator) Error() error

func (*ScanIterator) Next added in v0.17.0 

func (it *ScanIterator) Next() bool

func (*ScanIterator) Row added in v0.17.0 

func (it *ScanIterator) Row() (database.Row, error)

type ScanOperator 

type ScanOperator struct {
	stream.BaseOperator
	TableName string
	Ranges    stream.Ranges
	Reverse   bool
	// If set, the operator will scan this table.
	// It not set, it will get the scan from the catalog.
	Table *database.Table
}

A ScanOperator iterates over the objects of a table.

func Scan 

func Scan(tableName string, ranges ...stream.Range) *ScanOperator

Scan creates an iterator that iterates over each object of the given table that match the given ranges. If no ranges are provided, it iterates over all objects.

func ScanReverse 

func ScanReverse(tableName string, ranges ...stream.Range) *ScanOperator

ScanReverse creates an iterator that iterates over each object of the given table in reverse order.

func (*ScanOperator) Columns added in v0.17.0 

func (it *ScanOperator) Columns(env *environment.Environment) ([]string, error)

func (*ScanOperator) Iterator added in v0.17.0 

func (op *ScanOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*ScanOperator) String 

func (it *ScanOperator) String() string

type ValidateIterator added in v0.17.0 

type ValidateIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*ValidateIterator) Error added in v0.17.0 

func (it *ValidateIterator) Error() error

func (*ValidateIterator) Next added in v0.17.0 

func (it *ValidateIterator) Next() bool

func (*ValidateIterator) Row added in v0.17.0 

func (it *ValidateIterator) Row() (database.Row, error)

type ValidateOperator 

type ValidateOperator struct {
	stream.BaseOperator

	TableName string
}

ValidateOperator validates and converts incoming rows against table and column constraints.

func Validate 

func Validate(tableName string) *ValidateOperator

func (*ValidateOperator) Iterator added in v0.17.0 

func (op *ValidateOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*ValidateOperator) String 

func (op *ValidateOperator) String() string

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.