feeder

package
v0.0.0-...-d88ec87 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 13, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SQLWALFeeder 

type SQLWALFeeder struct {
	WALFeeder
	// contains filtered or unexported fields
}

SQLWALFeeder is an implementation of WALFeeder that creates a feed from a SQL DB

func (*SQLWALFeeder) CreateFeed 

func (feeder *SQLWALFeeder) CreateFeed() <-chan *model.WALEntry

CreateFeed streams WALEntries from the SQL DB

type WALFeeder 

type WALFeeder interface {
	CreateFeed() <-chan *model.WALEntry
}

WALFeeder creates a feed of WALEntries that represent the desired object's state

func NewSQLWALFeeder 

func NewSQLWALFeeder(akubraConfig *config.Config,
	sqlFeederConfig *WALFeederConfig,
	dbClientFactory database.DBClientFactory) (WALFeeder, error)

NewSQLWALFeeder construct an instance of SQLWALFeeder

type WALFeederConfig 

type WALFeederConfig struct {
	NoRecordsSleepDuration time.Duration `yaml:"NoRecordsSleepDuration"`
	MaxRecordsPerQuery     uint          `yaml:"MaxRecordsPerQuery"`
	FailureDelay           time.Duration `yaml:"FailureDelay"`
}

WALFeederConfig is a configuration for SQLWALFeeder

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.