input

type Cmd interface {
	Input

	GetExec() []string
}

type CmdImpl struct {
	SourceName string `pkl:"sourceName"`

	Exec []string `pkl:"exec"`

	Name string `pkl:"name"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

type Input interface {
	GetName() string

	GetSourceName() string

	GetThreads() uint

	GetOutputBufferSize() uint
}

type Inputs struct {
}

type Kafka interface {
	Input

	GetCommon() *common.Kafka

	GetAutoCommitEnabled() bool

	GetConsumerGroupID() string

	GetAutoOffsetReset() autooffsetreset.AutoOffsetReset

	GetBalancerStrategy() []strategy.Strategy

	GetMaxPartitionFetchBytes() *pkl.DataSize

	GetFetchMaxBytes() *pkl.DataSize
}

type KafkaImpl struct {
	SourceName string `pkl:"sourceName"`

	Common *common.Kafka `pkl:"common"`

	AutoCommitEnabled bool `pkl:"autoCommitEnabled"`

	ConsumerGroupID string `pkl:"consumerGroupID"`

	AutoOffsetReset autooffsetreset.AutoOffsetReset `pkl:"autoOffsetReset"`

	BalancerStrategy []strategy.Strategy `pkl:"balancerStrategy"`

	MaxPartitionFetchBytes *pkl.DataSize `pkl:"maxPartitionFetchBytes"`

	FetchMaxBytes *pkl.DataSize `pkl:"fetchMaxBytes"`

	Name string `pkl:"name"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}

type Pipelaner interface {
	Input

	GetCommonConfig() *common.Pipelaner

	GetConnectionType() connectiontype.ConnectionType

	GetUnixSocketPath() *string
}

type PipelanerImpl struct {
	SourceName string `pkl:"sourceName"`

	CommonConfig *common.Pipelaner `pkl:"commonConfig"`

	ConnectionType connectiontype.ConnectionType `pkl:"connectionType"`

	UnixSocketPath *string `pkl:"unixSocketPath"`

	Name string `pkl:"name"`

	Threads uint `pkl:"threads"`

	OutputBufferSize uint `pkl:"outputBufferSize"`
}