Categorygithub.com/ThreeDotsLabs/watermill-sqlpkgsql
package
0.1.1
Repository: https://github.com/threedotslabs/watermill-sql.git
Documentation: pkg.go.dev
Overview
Versions
5
Dependencies
12
Dependents
6
Files
725 SLOC

# Functions

No description provided by the author
No description provided by the author

# Variables

No description provided by the author
No description provided by the author
No description provided by the author

# Structs

DefaultMySQLOffsetsAdapter is adapter for storing offsets for MySQL (or MariaDB) databases.
DefaultSchema is a default implementation of SchemaAdapter.
Publisher inserts the Messages as rows into a SQL table..
No description provided by the author
Subscriber makes SELECT queries on the chosen table with the interval defined in the config.
No description provided by the author

# Interfaces

No description provided by the author
SchemaAdapter produces the SQL queries and arguments appropriately for a specific schema and dialect It also transforms sql.Rows into Watermill messages.