lib

Documentation

Index

• Constants
• func GetValuesFromColumns(columns []*pglogrepl.TupleDataColumn, rel *pglogrepl.RelationMessage, ...) map[string]interface{}
• func InitializeReplicationConnection(pgDns, outputPlugin, slotName string) (*pglogrepl.IdentifySystemResult, *pgconn.PgConn, error)
• func ProcessWebhookTasks(tasks chan providers.Task, webhookServiceUrl string, ...)

Constants

const (
	MaxRetries = 400 // Around 22 hours.
)

Functions

func GetValuesFromColumns

func GetValuesFromColumns(columns []*pglogrepl.TupleDataColumn, rel *pglogrepl.RelationMessage, info *pgtype.ConnInfo) map[string]interface{}

func InitializeReplicationConnection

func InitializeReplicationConnection(pgDns, outputPlugin, slotName string) (*pglogrepl.IdentifySystemResult, *pgconn.PgConn, error)

func ProcessWebhookTasks

func ProcessWebhookTasks(tasks chan providers.Task, webhookServiceUrl string, handler providers.DbHandler, httpClient providers.HttpClient)