input

type Input interface {
	GetName() string

	GetSourceName() string

	GetThreads() int

	GetOutputBufferSize() int
}

type Inputs struct {
}

type KafkaConsumer interface {
	Input

	GetSaslEnabled() *bool

	GetSaslMechanism() *saslmechanism.SASLMechanism

	GetSaslUsername() *string

	GetSaslPassword() *string

	GetBrokers() string

	GetVersion() *string

	GetTopics() []string

	GetSchemaRegistry() *string

	GetAutoCommitEnabled() *bool

	GetConsumerGroupID() string

	GetMaxPartitionFetchBytes() *pkl.DataSize

	GetFetchMaxBytes() *pkl.DataSize

	GetAutoOffsetReset() autooffsetreset.AutoOffsetReset

	GetBalancerStrategy() *[]strategy.Strategy
}

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

	SaslEnabled *bool `pkl:"saslEnabled"`

	SaslMechanism *saslmechanism.SASLMechanism `pkl:"saslMechanism"`

	SaslUsername *string `pkl:"saslUsername"`

	SaslPassword *string `pkl:"saslPassword"`

	Brokers string `pkl:"brokers"`

	Version *string `pkl:"version"`

	Topics []string `pkl:"topics"`

	SchemaRegistry *string `pkl:"schemaRegistry"`

	AutoCommitEnabled *bool `pkl:"autoCommitEnabled"`

	ConsumerGroupID string `pkl:"consumerGroupID"`

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

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

	AutoOffsetReset autooffsetreset.AutoOffsetReset `pkl:"autoOffsetReset"`

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

	Name string `pkl:"name"`

	Threads int `pkl:"threads"`

	OutputBufferSize int `pkl:"outputBufferSize"`
}

type Pipelaner interface {
	Input

	GetHost() *string

	GetPort() int

	GetTls() *bool

	GetCertFile() *string

	GetKeyFile() *string

	GetConnectionType() *string

	GetUnixSocketPasth() string
}

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

	Host *string `pkl:"host"`

	Port int `pkl:"port"`

	Tls *bool `pkl:"tls"`

	CertFile *string `pkl:"certFile"`

	KeyFile *string `pkl:"keyFile"`

	ConnectionType *string `pkl:"connectionType"`

	UnixSocketPasth string `pkl:"unixSocketPasth"`

	Name string `pkl:"name"`

	Threads int `pkl:"threads"`

	OutputBufferSize int `pkl:"outputBufferSize"`
}