sharedtest

package
v0.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MySQLDSN    = "strongforce:strongforce@tcp(127.0.0.1:65001)/strongforce?charset=utf8mb4&multiStatements=true&parseTime=true"
	PostgresDSN = "postgresql://strongforce:strongforce@127.0.0.1:65002/strongforce?sslmode=disable"
	NATS        = "127.0.0.1:23945"
)

Functions

func CreateNatsStream

func CreateNatsStream(address string, name string, subject string) error

func CreateOutboxTable

func CreateOutboxTable(db db.DB, name string) error

func GetEventEntities

func GetEventEntities(db db.DB, tableName string) ([]*outbox.EventEntity, error)

func GetNATSStream

func GetNATSStream(address string, name string) (*nats.StreamInfo, error)

Types

This section is empty.

Jump to

Keyboard shortcuts

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