Documentation
¶
Overview ¶
Package processor is the smallest processor entity for which the watermark will strictly monotonically increase.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessorEntitier ¶
type ProcessorEntitier interface {
GetName() string
}
ProcessorEntitier defines what can be a processor. The Processor is the smallest unit where the watermark will monotonically increase.
func NewProcessorEntity ¶
func NewProcessorEntity(name string) ProcessorEntitier
NewProcessorEntity returns a new `ProcessorEntitier`.
Source Files
Click to show internal directories.
Click to hide internal directories.