sql

Documentation

Index

• func BuildAwsDsn(dsn string, driver string, secretName string, awsConf aws.Config, ...) (awsSecretDsn string, err error)
• 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 BuildAwsDsn

func BuildAwsDsn(dsn string, driver string, secretName string, awsConf aws.Config, getSecretFunc func(secretName string, awsConf aws.Config) (awsSecret string, err error)) (awsSecretDsn string, err error)

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.

func NewSQLInsertProcessorFromConfig

func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlInsertProcessor, error)

NewSQLInsertProcessorFromConfig returns an internal sql_insert processor.

func NewSQLRawProcessorFromConfig

func NewSQLRawProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlRawProcessor, error)

NewSQLRawProcessorFromConfig returns an internal sql_raw processor.

func NewSQLSelectProcessorFromConfig

func NewSQLSelectProcessorFromConfig(conf *service.ParsedConfig, mgr *service.Resources) (*sqlSelectProcessor, error)

NewSQLSelectProcessorFromConfig returns an internal sql_select processor.

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.