repository

Documentation

Index

• type Base
  • func NewBase(nc *nats.EncodedConn, mongoDB *mongo.Database, log zerolog.Logger) (b *Base, err error)
  • func (repo *Base) GetTopic(event events.Event) string
  • func (repo *Base) LoadAggregate(category, id string) (aggregate events.AggregateDB, err error)
  • func (repo *Base) Publish(event events.Event) error
  • func (repo *Base) SaveEvents(eventCategory, aggregateID string, aggregateEvents []events.Event, ...) (err error)

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)