Documentation ¶
Index ¶
- type 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
- 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
- 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
- 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
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CountingTrigger ¶
type CountingTrigger struct {
// contains filtered or unexported fields
}
func NewCountingTrigger ¶
func NewCountingTrigger(fireEvery int) *CountingTrigger
func (*CountingTrigger) Document ¶
func (ct *CountingTrigger) Document() docs.Documentation
func (*CountingTrigger) KeysFired ¶
func (ct *CountingTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error
func (*CountingTrigger) PollKeysToFire ¶
func (ct *CountingTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error)
func (*CountingTrigger) RecordReceived ¶
func (ct *CountingTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, eventTime time.Time) error
func (*CountingTrigger) UpdateWatermark ¶
func (ct *CountingTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
type DelayTrigger ¶
type DelayTrigger struct {
// contains filtered or unexported fields
}
func NewDelayTrigger ¶
func NewDelayTrigger(delay time.Duration, clock func() time.Time) *DelayTrigger
func (*DelayTrigger) Document ¶
func (dt *DelayTrigger) Document() docs.Documentation
func (*DelayTrigger) KeysFired ¶
func (dt *DelayTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error
func (*DelayTrigger) PollKeysToFire ¶
func (dt *DelayTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error)
func (*DelayTrigger) RecordReceived ¶
func (dt *DelayTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, eventTime time.Time) error
func (*DelayTrigger) UpdateWatermark ¶
func (dt *DelayTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
type MultiTrigger ¶
type MultiTrigger struct {
// contains filtered or unexported fields
}
func NewMultiTrigger ¶
func NewMultiTrigger(triggers ...Trigger) *MultiTrigger
func (*MultiTrigger) Document ¶
func (m *MultiTrigger) Document() docs.Documentation
func (*MultiTrigger) KeysFired ¶
func (m *MultiTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, keys []octosql.Value) error
func (*MultiTrigger) PollKeysToFire ¶
func (m *MultiTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error)
func (*MultiTrigger) RecordReceived ¶
func (m *MultiTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, eventTime time.Time) error
func (*MultiTrigger) UpdateWatermark ¶
func (m *MultiTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
type TimeSortedKeys ¶
type TimeSortedKeys struct {
// contains filtered or unexported fields
}
func NewTimeSortedKeys ¶
func NewTimeSortedKeys(tx storage.StateTransaction) *TimeSortedKeys
func (*TimeSortedKeys) DeleteByKey ¶
func (tsk *TimeSortedKeys) DeleteByKey(key octosql.Value) error
type Trigger ¶
type Trigger interface { RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, eventTime time.Time) error UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error) KeysFired(ctx context.Context, tx storage.StateTransaction, key []octosql.Value) error }
type WatermarkTrigger ¶
type WatermarkTrigger struct { }
func NewWatermarkTrigger ¶
func NewWatermarkTrigger() *WatermarkTrigger
func (*WatermarkTrigger) Document ¶
func (wt *WatermarkTrigger) Document() docs.Documentation
func (*WatermarkTrigger) KeysFired ¶
func (wt *WatermarkTrigger) KeysFired(ctx context.Context, tx storage.StateTransaction, key []octosql.Value) error
func (*WatermarkTrigger) PollKeysToFire ¶
func (wt *WatermarkTrigger) PollKeysToFire(ctx context.Context, tx storage.StateTransaction, batchSize int) ([]octosql.Value, error)
func (*WatermarkTrigger) RecordReceived ¶
func (wt *WatermarkTrigger) RecordReceived(ctx context.Context, tx storage.StateTransaction, key octosql.Value, eventTime time.Time) error
func (*WatermarkTrigger) UpdateWatermark ¶
func (wt *WatermarkTrigger) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.