nats

package

v0.0.1 Latest Latest Go to latest Published: Sep 20, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func RunEmbeddedNATSServer(cfg Config) (*nats.Conn, *server.Server, error)

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

func NewCDCPublisher(nc *nats.Conn, url string, stream string, maxAge time.Duration, timeout time.Duration) (*CDCPublisher, error)

func (p *CDCPublisher) Publish(cs *sqlite.ChangeSet) error

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

func NewCDCSubscriber(node string, nc *nats.Conn, url string, stream string, db *sql.DB) (*CDCSubscriber, error)

func (s *CDCSubscriber) Close() error

type Config struct {
	Name     string
	Port     int
	StoreDir string
	File     string
}