sink

type Clickhouse interface {
	Sink

	GetAddress() string

	GetUser() string

	GetPassword() string

	GetDatabase() string

	GetTableName() string

	GetAsyncInsert() string

	GetWaitForAsyncInsert() string
}

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

	Address string `pkl:"address"`

	User string `pkl:"user"`

	Password string `pkl:"password"`

	Database string `pkl:"database"`

	TableName string `pkl:"tableName"`

	AsyncInsert string `pkl:"asyncInsert"`

	WaitForAsyncInsert string `pkl:"waitForAsyncInsert"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Console interface {
	Sink

	GetLogFormat() logformat.LogFormat
}

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

	LogFormat logformat.LogFormat `pkl:"logFormat"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Http interface {
	Sink

	GetUrl() string

	GetMethod() method.Method
}

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

	Url string `pkl:"url"`

	Method method.Method `pkl:"method"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Kafka interface {
	Sink

	GetCommon() *common.Kafka

	GetMaxRequestSize() *pkl.DataSize

	GetLingerMs() *pkl.Duration

	GetBatchNumMessages() int
}

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

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

	MaxRequestSize *pkl.DataSize `pkl:"maxRequestSize"`

	LingerMs *pkl.Duration `pkl:"lingerMs"`

	BatchNumMessages int `pkl:"batchNumMessages"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Pipelaner interface {
	Sink

	GetCommonConfig() *common.Pipelaner
}

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

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

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads int `pkl:"threads"`
}

type Sink interface {
	GetName() string

	GetSourceName() string

	GetInputs() []string

	GetThreads() int
}

type Sinks struct {
}