Versions in this module Expand all Collapse all v0 v0.3.0 Aug 5, 2020 Changes in this version + type CountingTrigger struct + func NewCountingTrigger(fireEvery int) *CountingTrigger + func (ct *CountingTrigger) Document() docs.Documentation + func (ct *CountingTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error + func (ct *CountingTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) + func (ct *CountingTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, ...) error + func (ct *CountingTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error + type DelayTrigger struct + func NewDelayTrigger(delay time.Duration, clock func() time.Time) *DelayTrigger + func (dt *DelayTrigger) Document() docs.Documentation + func (dt *DelayTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error + func (dt *DelayTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) + func (dt *DelayTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, ...) error + func (dt *DelayTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error + type MultiTrigger struct + func NewMultiTrigger(triggers ...Trigger) *MultiTrigger + func (m *MultiTrigger) Document() docs.Documentation + func (m *MultiTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error + func (m *MultiTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) + func (m *MultiTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, ...) error + func (m *MultiTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error + type TimeSortedKeys struct + func NewTimeSortedKeys(tx storage.StateTransaction) *TimeSortedKeys + func (tsk *TimeSortedKeys) Delete(key octosql.Value, t time.Time) error + func (tsk *TimeSortedKeys) DeleteByKey(key octosql.Value) error + func (tsk *TimeSortedKeys) GetFirst() (octosql.Value, time.Time, error) + func (tsk *TimeSortedKeys) GetUntil(until time.Time, batchSize int) ([]octosql.Value, []time.Time, error) + func (tsk *TimeSortedKeys) Update(key octosql.Value, t time.Time) error + type Trigger interface + KeysFired func(ctx context.Context, tx storage.StateTransaction, key []octosql.Value) error + PollKeysToFire func(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) + RecordReceived func(ctx context.Context, tx storage.StateTransaction, key octosql.Value, ...) error + UpdateWatermark func(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error + type WatermarkTrigger struct + func NewWatermarkTrigger() *WatermarkTrigger + func (wt *WatermarkTrigger) Document() docs.Documentation + func (wt *WatermarkTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, key []octosql.Value) error + func (wt *WatermarkTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) + func (wt *WatermarkTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, ...) error + func (wt *WatermarkTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
Go to main page