Versions in this module Expand all Collapse all v0 v0.3.0 Aug 5, 2020 Changes in this version + type InstantStreamOutput struct + StreamID *execution.StreamID + func NewInstantStreamOutput(streamID *execution.StreamID) *InstantStreamOutput + func (o *InstantStreamOutput) AddRecord(ctx context.Context, tx storage.StateTransaction, inputIndex int, ...) error + func (o *InstantStreamOutput) Close(ctx context.Context, storage storage.Storage) error + func (o *InstantStreamOutput) GetEndOfStream(ctx context.Context, tx storage.StateTransaction) (bool, error) + func (o *InstantStreamOutput) GetErrorMessage(ctx context.Context, tx storage.StateTransaction) (string, error) + func (o *InstantStreamOutput) GetWatermark(ctx context.Context, tx storage.StateTransaction) (time.Time, error) + func (o *InstantStreamOutput) MarkEndOfStream(ctx context.Context, tx storage.StateTransaction) error + func (o *InstantStreamOutput) MarkError(ctx context.Context, tx storage.StateTransaction, err error) error + func (o *InstantStreamOutput) Next(ctx context.Context, tx storage.StateTransaction) (*execution.Record, error) + func (o *InstantStreamOutput) ReadyForMore(ctx context.Context, tx storage.StateTransaction) error + func (o *InstantStreamOutput) TriggerKeys(ctx context.Context, tx storage.StateTransaction, batchSize int) (int, error) + func (o *InstantStreamOutput) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error + type StreamPrinter struct + func NewStreamPrinter(stateStorage storage.Storage, recordSink execution.IntermediateRecordStore, ...) *StreamPrinter + func (sp *StreamPrinter) Run(ctx context.Context) error