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 documents in the table
func Delete ¶
func Delete(tableName string) *DeleteOperator
Delete deletes documents from the table. Incoming documents must implement the document.Keyer interface.
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 documents to the table.
func Insert ¶
func Insert(tableName string) *InsertOperator
Insert inserts incoming documents 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 documents in the table
func Replace ¶
func Replace(tableName string) *ReplaceOperator
Replace replaces documents in the table. Incoming documents must implement the document.Keyer interface.
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 ¶
A ScanOperator iterates over the documents of a table.
func Scan ¶
func Scan(tableName string, ranges ...stream.Range) *ScanOperator
Scan creates an iterator that iterates over each document of the given table that match the given ranges. If no ranges are provided, it iterates over all documents.
func ScanReverse ¶
func ScanReverse(tableName string, ranges ...stream.Range) *ScanOperator
ScanReverse creates an iterator that iterates over each document 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 documents of the table. Each document 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 documents 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