sql

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

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.