Documentation
¶
Index ¶
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeprecatedProcessorConfig ¶
func DeprecatedProcessorConfig() *service.ConfigSpec
DeprecatedProcessorConfig returns a config spec for an sql processor.
func InsertProcessorConfig ¶
func InsertProcessorConfig() *service.ConfigSpec
InsertProcessorConfig returns a config spec for an sql_insert processor.
func NewSQLDeprecatedProcessorFromConfig ¶
func NewSQLDeprecatedProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlRawProcessor, error)
NewSQLDeprecatedProcessorFromConfig returns an internal sql processor. nolint:revive // Not bothered as this is internal anyway
func NewSQLInsertProcessorFromConfig ¶
func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlInsertProcessor, error)
NewSQLInsertProcessorFromConfig returns an internal sql_insert processor. nolint:revive // Not bothered as this is internal anyway
func NewSQLRawProcessorFromConfig ¶
func NewSQLRawProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlRawProcessor, error)
NewSQLRawProcessorFromConfig returns an internal sql_raw processor. nolint:revive // Not bothered as this is internal anyway
func NewSQLSelectProcessorFromConfig ¶
func NewSQLSelectProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlSelectProcessor, error)
NewSQLSelectProcessorFromConfig returns an internal sql_select processor. nolint:revive // Not bothered as this is internal anyway
func RawProcessorConfig ¶
func RawProcessorConfig() *service.ConfigSpec
RawProcessorConfig returns a config spec for an sql_raw processor.
func SQLiteBufferConfig ¶
func SQLiteBufferConfig() *service.ConfigSpec
SQLiteBufferConfig returns a config spec for an SQLite buffer.
func SelectProcessorConfig ¶
func SelectProcessorConfig() *service.ConfigSpec
SelectProcessorConfig returns a config spec for an sql_select processor.
Types ¶
type SQLiteBuffer ¶
type SQLiteBuffer struct {
// contains filtered or unexported fields
}
SQLiteBuffer stores messages for consumption through an SQLite DB.
func NewSQLiteBufferFromConfig ¶
func NewSQLiteBufferFromConfig(conf *service.ParsedConfig, res *service.Resources) (*SQLiteBuffer, error)
NewSQLiteBufferFromConfig creates a new SQLite buffer from a parsed config.
func (*SQLiteBuffer) Close ¶
func (m *SQLiteBuffer) Close(ctx context.Context) error
Close the underlying DB connection.
func (*SQLiteBuffer) EndOfInput ¶
func (m *SQLiteBuffer) EndOfInput()
EndOfInput signals to the buffer that the input is finished and therefore once the DB is drained it should close.
func (*SQLiteBuffer) ReadBatch ¶
func (m *SQLiteBuffer) ReadBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
ReadBatch attempts to pop a row from the DB.
func (*SQLiteBuffer) WriteBatch ¶
func (m *SQLiteBuffer) WriteBatch(ctx context.Context, msgBatch service.MessageBatch, aFn service.AckFunc) error
WriteBatch adds a new message to the DB.
Source Files