Versions in this module Expand all Collapse all v0 v0.2.0 Jul 6, 2021 Changes in this version + func ResetSQLDB(dsn string) + type Config struct + DBHost string + DBName string + DBPass string + DBUser string + func (c Config) DBDsn() string + type PostgreSQLSchema struct + func (s PostgreSQLSchema) SchemaInitializingQueries(topic string) []string + type SQLQueue struct + func NewSQLQueue(c Config) *SQLQueue + func (q *SQLQueue) Close() + func (q *SQLQueue) Publish(ctx context.Context, msgs ...message.Message) error + func (q *SQLQueue) RegisterCtxKey(key interface{ ... }, fn func([]byte) interface{}) + func (q *SQLQueue) Subscribe(topCtx context.Context, fn func(context.Context, message.Message) error)