Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeleteOperator ¶
type DeleteOperator struct {
stream.BaseOperator
Name string
}
A DeleteOperator replaces objects in the table
func (*DeleteOperator) Iterate ¶
func (op *DeleteOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
Iterate implements the Operator interface.
func (*DeleteOperator) String ¶
func (op *DeleteOperator) String() string
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) Iterate ¶
func (op *InsertOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
Iterate implements the Operator interface.
func (*InsertOperator) String ¶
func (op *InsertOperator) String() string
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) Iterate ¶
func (op *ReplaceOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
Iterate implements the Operator interface.
func (*ReplaceOperator) String ¶
func (op *ReplaceOperator) String() string
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) Iterate ¶
func (it *ScanOperator) Iterate(in *environment.Environment, fn func(out *environment.Environment) error) error
Iterate over the objects of the table. Each object is stored in the environment that is passed to the fn function, using SetCurrentValue.
func (*ScanOperator) String ¶
func (it *ScanOperator) String() string
type ValidateOperator ¶
type ValidateOperator struct {
stream.BaseOperator
// contains filtered or unexported fields
}
ValidateOperator validates and converts incoming rows against table and field constraints.
func Validate ¶
func Validate(tableName string) *ValidateOperator
func (*ValidateOperator) Iterate ¶
func (op *ValidateOperator) Iterate(in *environment.Environment, fn func(out *environment.Environment) error) error
func (*ValidateOperator) String ¶
func (op *ValidateOperator) String() string
Source Files