sql

package

v0.2.0 Latest Latest Go to latest Published: Jul 6, 2021 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/GabrielCarpr/cqrs

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 (q *SQLQueue) Subscribe(topCtx context.Context, fn func(context.Context, message.Message) error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL