sink

type Clickhouse interface {
	Sink

	GetCredentials() common.ChCredentials

	GetTableName() string

	GetAsyncInsert() string

	GetWaitForAsyncInsert() string

	GetMaxPartitionsPerInsertBlock() int
}

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

	Credentials common.ChCredentials `pkl:"credentials"`

	TableName string `pkl:"tableName"`

	AsyncInsert string `pkl:"asyncInsert"`

	WaitForAsyncInsert string `pkl:"waitForAsyncInsert"`

	MaxPartitionsPerInsertBlock int `pkl:"maxPartitionsPerInsertBlock"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `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 uint `pkl:"threads"`
}

type Http interface {
	Sink

	GetUrl() string

	GetMethod() method.Method

	GetHeaders() *map[string]string
}

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

	Url string `pkl:"url"`

	Method method.Method `pkl:"method"`

	Headers *map[string]string `pkl:"headers"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `pkl:"threads"`
}

type Kafka interface {
	Sink

	GetCommon() common.Kafka

	GetMaxRequestSize() pkl.DataSize

	GetLingerMs() pkl.Duration

	GetBatchNumMessages() int

	GetTransactionId() *string
}

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

	TransactionId *string `pkl:"transactionId"`

	Name string `pkl:"name"`

	Inputs []string `pkl:"inputs"`

	Threads uint `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 uint `pkl:"threads"`
}

type Sink interface {
	GetName() string

	GetSourceName() string

	GetInputs() []string

	GetThreads() uint
}

type Sinks struct {
}