Documentation
¶
Index ¶
Constants ¶
View Source
const ( ActionInsert actionType = "INSERT" ActionUpdate actionType = "UPDATE" ActionDelete actionType = "DELETE" )
Variables ¶
View Source
var ( ErrNoKey = errors.New("no key") ErrNoOrderingColumn = errors.New("no ordering column") ErrWrongTrackingIDType = errors.New("tracking id wrong type") ErrWrongTrackingOperatorType = errors.New("tracking column wrong type") ErrNoInitializedIterator = errors.New("not initialized iterator") ErrUnknownOperatorType = errors.New("unknown iterator type") )
Functions ¶
This section is empty.
Types ¶
type CombinedIterator ¶
type CombinedIterator struct {
// contains filtered or unexported fields
}
CombinedIterator combined iterator.
func NewCombinedIterator ¶
func NewCombinedIterator(ctx context.Context, params CombinedParams) (*CombinedIterator, error)
NewCombinedIterator - create new iterator.
func (*CombinedIterator) HasNext ¶
func (c *CombinedIterator) HasNext(ctx context.Context) (bool, error)
HasNext returns a bool indicating whether the iterator has the next record to return or not. If the underlying snapshot iterator returns false, the combined iterator will try to switch to the cdc iterator.
func (*CombinedIterator) Stop ¶
func (c *CombinedIterator) Stop() error
Stop the underlying iterators.
Source Files
Click to show internal directories.
Click to hide internal directories.