sql

Documentation

Index

• func DeprecatedProcessorConfig() *service.ConfigSpec
• func InsertProcessorConfig() *service.ConfigSpec
• func NewSQLDeprecatedProcessorFromConfig(conf *service.ParsedConfig, logger *service.Logger) (*sqlRawProcessor, error)
• func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, logger *service.Logger) (*sqlInsertProcessor, error)
• func NewSQLRawProcessorFromConfig(conf *service.ParsedConfig, logger *service.Logger) (*sqlRawProcessor, error)
• func NewSQLSelectProcessorFromConfig(conf *service.ParsedConfig, logger *service.Logger) (*sqlSelectProcessor, error)
• func RawProcessorConfig() *service.ConfigSpec
• func SelectProcessorConfig() *service.ConfigSpec

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, logger *service.Logger) (*sqlRawProcessor, error)

NewSQLDeprecatedProcessorFromConfig returns an internal sql processor. nolint:revive // Not bothered as this is internal anyway

func NewSQLInsertProcessorFromConfig

func NewSQLInsertProcessorFromConfig(conf *service.ParsedConfig, logger *service.Logger) (*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, logger *service.Logger) (*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, logger *service.Logger) (*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 SelectProcessorConfig

func SelectProcessorConfig() *service.ConfigSpec

SelectProcessorConfig returns a config spec for an sql_select processor.