NewFlusher creates a *Flusher.

NewQueue creates a new *Queue instance.

NewQueues creates a slice of *Queue instances.

IncomingProcTable is the name of the table in the DB.

IncomingTable is the name of the table in the DB.

MigrationsTable is the name of the table in the DB.

IncomingFields are all the field names in the DB table.

IncomingPrimaryFields are the primary key fields in the DB table.

IncomingProcFields are all the field names in the DB table.

IncomingProcPrimaryFields are the primary key fields in the DB table.

MigrationsFields are all the field names in the DB table.

MigrationsPrimaryFields are the primary key fields in the DB table.

Flusher is a context-driven background data flush job.

Incoming generated for db table `incoming`.

IncomingProc generated for db table `incoming_proc`.

Migrations generated for db table `migrations`.

Queue provides a queuing structure for Incoming.

Server implements stats.Stats.