Documentation
¶
Index ¶
- Constants
- func DeprecatedProcessorConfig() *service.ConfigSpec
- func InsertProcessorConfig() *service.ConfigSpec
- func IsAWSEnabled(c *service.ParsedConfig) (enabled bool, err error)
- func IsAzureEnabled(c *service.ParsedConfig) (enabled bool, err error)
- 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
- func SetAWSGetCredentialsGeneratorFn(fn func(*service.ParsedConfig) (DSNBuilder, error))
- func SetAzureGetCredentialsGeneratorFn(fn func(*service.ParsedConfig) (DSNBuilder, error))
- type DSNBuilder
- 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 ¶
View Source
const (
SQLConnLintRule = `root = match {this.iam_enabled && this.exists("secret_name") => "both iam_enabled and secret_name cannot be set"}`
)
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 IsAWSEnabled ¶ added in v1.8.0
func IsAWSEnabled(c *service.ParsedConfig) (enabled bool, err error)
func IsAzureEnabled ¶ added in v1.10.1
func IsAzureEnabled(c *service.ParsedConfig) (enabled bool, err error)
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.
func SetAWSGetCredentialsGeneratorFn ¶ added in v1.10.1
func SetAWSGetCredentialsGeneratorFn(fn func(*service.ParsedConfig) (DSNBuilder, error))
func SetAzureGetCredentialsGeneratorFn ¶ added in v1.10.1
func SetAzureGetCredentialsGeneratorFn(fn func(*service.ParsedConfig) (DSNBuilder, error))
Types ¶
type DSNBuilder ¶ added in v1.10.1
func AWSGetCredentialsGeneratorFn ¶ added in v1.8.0
func AWSGetCredentialsGeneratorFn(c *service.ParsedConfig) (DSNBuilder, error)
func AzureGetCredentialsGeneratorFn ¶ added in v1.10.0
func AzureGetCredentialsGeneratorFn(c *service.ParsedConfig) (DSNBuilder, error)
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
¶
Directories
Click to show internal directories.
Click to hide internal directories.