package
1.3.0
Repository: https://github.com/warpstreamlabs/bento.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
DeprecatedProcessorConfig returns a config spec for an sql processor.
InsertProcessorConfig returns a config spec for an sql_insert processor.
NewSQLDeprecatedProcessorFromConfig returns an internal sql processor.
NewSQLInsertProcessorFromConfig returns an internal sql_insert processor.
NewSQLiteBufferFromConfig creates a new SQLite buffer from a parsed config.
NewSQLRawProcessorFromConfig returns an internal sql_raw processor.
NewSQLSelectProcessorFromConfig returns an internal sql_select processor.
RawProcessorConfig returns a config spec for an sql_raw processor.
SelectProcessorConfig returns a config spec for an sql_select processor.
SQLiteBufferConfig returns a config spec for an SQLite buffer.

# Structs

SQLiteBuffer stores messages for consumption through an SQLite DB.