sql

Documentation

Index

• func ResetSQLDB(dsn string)
• type Config
  • func (c Config) DBDsn() string
• type PostgreSQLSchema
  • func (s PostgreSQLSchema) SchemaInitializingQueries(topic string) []string
• type SQLQueue
  • 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)

Functions

func ResetSQLDB

func ResetSQLDB(dsn string)

Types

type Config

type Config struct {
	DBName string
	DBHost string
	DBUser string
	DBPass string
}

func (Config) DBDsn

func (c Config) DBDsn() string

type PostgreSQLSchema

type PostgreSQLSchema struct {
	wmSql.DefaultPostgreSQLSchema
}

PostgreSQLSchema is an implementation of SchemaAdapter based on PostgreSQL.

func (PostgreSQLSchema) SchemaInitializingQueries

func (s PostgreSQLSchema) SchemaInitializingQueries(topic string) []string

type SQLQueue

type SQLQueue struct {
	// contains filtered or unexported fields
}

func NewSQLQueue

func NewSQLQueue(c Config) *SQLQueue

func (*SQLQueue) Close

func (q *SQLQueue) Close()

func (*SQLQueue) Publish

func (q *SQLQueue) Publish(ctx context.Context, msgs ...message.Message) error

func (*SQLQueue) RegisterCtxKey

func (q *SQLQueue) RegisterCtxKey(key interface{ String() string }, fn func([]byte) interface{})

func (*SQLQueue) Subscribe

func (q *SQLQueue) Subscribe(topCtx context.Context, fn func(context.Context, message.Message) error)