db

Documentation

Index

• func CheckAndCreateReplConn(session *types.Session) error
• func CreateConfig(dbName, pgUser, pgPass, pgHost string, pgPort int)
• func Init(session *types.Session) error
• func LRListenAck(session *types.Session, wsErr chan<- error)
• func LRStream(session *types.Session)
• func SnapshotData(session *types.Session, requestParams *types.SnapshotDataJSON) ([]map[string]interface{}, error)

Functions

func CheckAndCreateReplConn

func CheckAndCreateReplConn(session *types.Session) error

CheckAndCreateReplConn creates a new replication connection

func CreateConfig

func CreateConfig(dbName, pgUser, pgPass, pgHost string, pgPort int)

Initialize the database configuration

func Init

func Init(session *types.Session) error

Init function - creates a db connection - creates a replication connection - delete existing replication slots - creates a new replication slot - gets the consistent point LSN and snapshot name - populates the Session object

func LRListenAck

func LRListenAck(session *types.Session, wsErr chan<- error)

LRListenAck listens on the websocket for ack messages The commited LSN is extracted and is updated to the server

func LRStream

func LRStream(session *types.Session)

LRStream will start streaming changes from the given slotName over the websocket connection

func SnapshotData

func SnapshotData(session *types.Session, requestParams *types.SnapshotDataJSON) ([]map[string]interface{}, error)

SnapshotData queries the snapshot for data from the given table and returns the results as a JSON array