sharedtest

Documentation

Index

• Variables
• func CreateNatsStream(address string, name string, subject string) error
• func CreateOutboxTable(db db.DB, name string) error
• func GetEventEntities(db db.DB, tableName string) ([]*outbox.EventEntity, error)
• func GetNATSStream(address string, name string) (*nats.StreamInfo, error)

Variables

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)