Documentation ¶
Index ¶
- func SetLogger(cfg Config)
- type App
- func (app *App) ApplyChanges(blob *pg.WALBlob)
- func (app *App) GetCurrentState() Runtime
- func (app *App) GetEsClient() *es7.Client
- func (app *App) GetIndexName(table, datetime string) string
- func (app *App) GetPgConn() *pgconn.PgConn
- func (app *App) GetReplConn() *pgconn.PgConn
- func (app *App) GetSlotName() string
- func (app *App) IndexSnapshotData(snapshotName string)
- func (app *App) Init()
- func (app *App) Remove()
- func (app *App) Run()
- func (app *App) UpdateCurrentState(runtime Runtime)
- type Config
- type Runtime
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type App ¶
type App struct { Config Config PgConn *pgconn.PgConn ReplConn *pgconn.PgConn Es *es7.Client Processor []*pg.FnProcessData }
App struct
func (*App) ApplyChanges ¶
ApplyChanges takes WAL changes as a blob and processes each of those
func (*App) GetCurrentState ¶
GetCurrentState retrieves saved state from Elasticsearch
func (*App) GetEsClient ¶
GetEsClient returns Elasticsearch client
func (*App) GetIndexName ¶
GetIndexName ...
func (*App) GetReplConn ¶
GetReplConn get datatabase connection for replication
func (*App) IndexSnapshotData ¶
IndexSnapshotData ...
func (*App) UpdateCurrentState ¶
UpdateCurrentState ...
type Config ¶
type Config struct { IndexName string IndexFormat bool IndexSeparator string IndexDateFormat string IndexFor []string IndexWith []string IndexColumn string IndexSource string IndexTarget string IndexTargetURL string IndexTargetCloudID string IndexTargetUsername string IndexTargetPassword string LogFormat string LogOutput string LogLevel string MetricEnabled bool MetricPort int }
Config struct
Click to show internal directories.
Click to hide internal directories.