Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + func DeprecatedProcessorConfig() *service.ConfigSpec + func InsertProcessorConfig() *service.ConfigSpec + func NewSQLDeprecatedProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlRawProcessor, error) + func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlInsertProcessor, error) + func NewSQLRawProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlRawProcessor, error) + func NewSQLSelectProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlSelectProcessor, error) + func RawProcessorConfig() *service.ConfigSpec + func SQLiteBufferConfig() *service.ConfigSpec + func SelectProcessorConfig() *service.ConfigSpec + type SQLiteBuffer struct + func NewSQLiteBufferFromConfig(conf *service.ParsedConfig, res *service.Resources) (*SQLiteBuffer, error) + func (m *SQLiteBuffer) Close(ctx context.Context) error + func (m *SQLiteBuffer) EndOfInput() + func (m *SQLiteBuffer) ReadBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error) + func (m *SQLiteBuffer) WriteBatch(ctx context.Context, msgBatch service.MessageBatch, aFn service.AckFunc) error
Go to main page