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 CommitConfiguration struct {
	Strategy commitstrategy.CommitStrategy `pkl:"strategy"`

	Interval pkl.Duration `pkl:"interval"`
}

type Input interface {
	GetName() string

	GetSourceName() string

	GetThreads() uint

	GetOutputBufferSize() uint
}

type Inputs struct {
}

type Kafka interface {
	Input

	GetCommon() common.Kafka

	GetCommitSrategy() CommitConfiguration

	GetConsumerGroupID() string

	GetAutoOffsetReset() autooffsetreset.AutoOffsetReset

	GetBalancerStrategy() []strategy.Strategy

	GetIsolationLevel() isolationlevel.IsolationLevel

	GetMaxPartitionFetchBytes() pkl.DataSize

	GetFetchMaxBytes() pkl.DataSize
}

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

	Common common.Kafka `pkl:"common"`

	CommitSrategy CommitConfiguration `pkl:"commitSrategy"`

	ConsumerGroupID string `pkl:"consumerGroupID"`

	AutoOffsetReset autooffsetreset.AutoOffsetReset `pkl:"autoOffsetReset"`

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

	IsolationLevel isolationlevel.IsolationLevel `pkl:"isolationLevel"`

	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"`
}