partitioned

type AbstractPartition struct {
	Logger logger.Logger
	Stream *AbstractStream
	Worker *worker.Worker
}

type AbstractStream struct {
	trigger.AbstractTrigger
	// contains filtered or unexported fields
}

type Configuration struct {
	trigger.Configuration
}

type Event struct {
	nuclio.AbstractEvent
}

type Partition interface {

	// Read starts reading from stream partition
	Read() error
}

type Stream interface {

	// CreatePartitions creates partitions, as per configuration
	CreatePartitions() ([]Partition, error)

	// Start starts reading from partitions
	Start(checkpoint functionconfig.Checkpoint) error

	// Start stops reading from partitions
	Stop(force bool) (functionconfig.Checkpoint, error)
}