v3iostream

type Configuration struct {
	trigger.Configuration
	ConsumerGroup                   string
	ContainerName                   string
	StreamPath                      string
	NumTransportWorkers             int
	WorkerAllocationMode            partitionworker.AllocationMode
	SeekTo                          string
	ReadBatchSize                   int
	SessionTimeout                  string
	HeartbeatInterval               string
	SequenceNumberCommitInterval    string
	SequenceNumberShardWaitInterval string
	RecordBatchSizeChan             int
	AckWindowSize                   uint64
	LogLevel                        int

	// backwards compatibility
	PollingIntervalMs int
	// contains filtered or unexported fields
}

type Event struct {
	nuclio.AbstractEvent

	StreamPath string
	// contains filtered or unexported fields
}