types

package

Go to main page

Versions in this module

v0

v0.10.7

Jan 19, 2026

v0.10.6

Dec 20, 2025

Changes in this version

+ const OverflowStrategyBlock

+ const OverflowStrategyDrop

+ const OverflowStrategyExpand

v0.10.5

Dec 16, 2025

v0.10.4

Nov 15, 2025

Changes in this version

+ type TimeCharacteristic string

+ const EventTime

+ const ProcessingTime

type WindowConfig

+ AllowedLateness time.Duration

+ Callback func([]Row)

+ GroupByKeys []string

+ IdleTimeout time.Duration

+ MaxOutOfOrderness time.Duration

+ PerformanceConfig PerformanceConfig

+ TimeCharacteristic TimeCharacteristic

+ WatermarkInterval time.Duration

v0.10.3

Aug 29, 2025

Changes in this version

+ type AggregationFieldInfo struct

+ AggType aggregator.AggregateType

+ FullCall string

+ FuncName string

+ InputField string

+ Placeholder string

type Config

+ PostAggExpressions []PostAggregationExpression

+ type PostAggregationExpression struct

+ ExpressionTemplate string

+ OriginalExpr string

+ OutputField string

+ RequiredFields []AggregationFieldInfo

v0.10.2

Aug 8, 2025

v0.10.1

Jul 30, 2025

Changes in this version

type Config

+ FieldOrder []string

v0.10.0

Jul 27, 2025

Changes in this version

+ type BufferConfig struct

+ DataChannelSize int

+ EnableDynamicResize bool

+ MaxBufferSize int

+ ResultChannelSize int

+ UsageThreshold float64

+ WindowOutputSize int

+ type Config struct

+ Distinct bool

+ FieldAlias map[string]string

+ FieldExpressions map[string]FieldExpression

+ GroupFields []string

+ Having string

+ Limit int

+ NeedWindow bool

+ PerformanceConfig PerformanceConfig

+ Projections []Projection

+ SelectFields map[string]aggregator.AggregateType

+ SimpleFields []string

+ Where string

+ WindowConfig WindowConfig

+ func NewConfig() Config

+ func NewConfigWithPerformance(perfConfig PerformanceConfig) Config

+ type ExpansionConfig struct

+ ExpansionTimeout time.Duration

+ GrowthFactor float64

+ MinIncrement int

+ TriggerThreshold float64

+ type FieldExpression struct

+ Expression string

+ Field string

+ Fields []string

+ type MonitoringConfig struct

+ EnableDetailedStats bool

+ EnableMonitoring bool

+ StatsUpdateInterval time.Duration

+ WarningThresholds WarningThresholds

+ type OverflowConfig struct

+ AllowDataLoss bool

+ BlockTimeout time.Duration

+ ExpansionConfig ExpansionConfig

+ PersistenceConfig *PersistenceConfig

+ Strategy string

+ type PerformanceConfig struct

+ BufferConfig BufferConfig

+ MonitoringConfig MonitoringConfig

+ OverflowConfig OverflowConfig

+ WorkerConfig WorkerConfig

+ func DefaultPerformanceConfig() PerformanceConfig

+ func HighPerformanceConfig() PerformanceConfig

+ func LowLatencyConfig() PerformanceConfig

+ func PersistencePerformanceConfig() PerformanceConfig

+ func ZeroDataLossConfig() PerformanceConfig

+ type PersistenceConfig struct

+ DataDir string

+ FlushInterval time.Duration

+ MaxFileSize int64

+ MaxRetries int

+ RetryInterval time.Duration

+ type Projection struct

+ InputName string

+ OutputName string

+ SourceType ProjectionSourceType

+ type ProjectionSourceType int

+ const SourceAggregateResult

+ const SourceGroupKey

+ const SourceWindowProperty

+ type Row struct

+ Data interface{}

+ Slot *TimeSlot

+ Timestamp time.Time

+ func (r *Row) GetTimestamp() time.Time

+ type RowEvent interface

+ GetTimestamp func() time.Time

+ type TimeSlot struct

+ End *time.Time

+ Start *time.Time

+ func NewTimeSlot(start, end *time.Time) *TimeSlot

+ func (ts *TimeSlot) GetEndTime() *time.Time

+ func (ts *TimeSlot) GetStartTime() *time.Time

+ func (ts *TimeSlot) WindowEnd() int64

+ func (ts *TimeSlot) WindowStart() int64

+ func (ts TimeSlot) Contains(t time.Time) bool

+ func (ts TimeSlot) Hash() uint64

+ type WarningThresholds struct

+ BufferUsageCritical float64

+ BufferUsageWarning float64

+ DropRateCritical float64

+ DropRateWarning float64

+ type WindowConfig struct

+ GroupByKey string

+ Params map[string]interface{}

+ TimeUnit time.Duration

+ TsProp string

+ Type string

+ type WorkerConfig struct

+ MaxRetryRoutines int

+ SinkPoolSize int

+ SinkWorkerCount int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL