repository

package
v0.0.0-...-5dae249 Latest Latest
Warning

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

Go to latest
Published: Dec 26, 2021 License: Unlicense Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Base

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

func NewBase

func NewBase(nc *nats.EncodedConn, mongoDB *mongo.Database, log zerolog.Logger) (b *Base, err error)

func (*Base) GetTopic

func (repo *Base) GetTopic(event events.Event) string

func (*Base) LoadAggregate

func (repo *Base) LoadAggregate(category, id string) (aggregate events.AggregateDB, err error)

func (*Base) Publish

func (repo *Base) Publish(event events.Event) error

func (*Base) SaveEvents

func (repo *Base) SaveEvents(eventCategory, aggregateID string, aggregateEvents []events.Event, originalVersion int) (err error)

Jump to

Keyboard shortcuts

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