mongo

Documentation

Index

• func NewEventRepository(cfg events.Persistence) (events.Repository, error)
• type Config
• type Event
  • func NewEvent(e *events.Event) *Event
  • func (e *Event) Event() *events.Event
• type EventRepository
• type PayloadCodec
  • func NewPayloadCodec() PayloadCodec
• type ULIDCodec
  • func NewULIDCodec() ULIDCodec

Functions

func NewEventRepository

func NewEventRepository(cfg events.Persistence) (events.Repository, error)

Types

type Config

type Config struct {
	URI        string
	Database   string
	Collection string
	Duration   time.Duration
}

type Event

type Event struct {
	Time    time.Time      `bson:"_time"`
	ID      ulid.ULID      `bson:"id"`
	Topic   string         `bson:"topic"`
	Payload events.Payload `bson:"payload"`
}

func NewEvent

func NewEvent(e *events.Event) *Event

func (*Event) Event

func (e *Event) Event() *events.Event

type EventRepository

type EventRepository interface {
	events.Repository
	DropDatabase(name string) error
}

type PayloadCodec

type PayloadCodec interface {
	bsoncodec.ValueEncoder
	bsoncodec.ValueDecoder
}

func NewPayloadCodec

func NewPayloadCodec() PayloadCodec

type ULIDCodec

type ULIDCodec interface {
	bsoncodec.ValueEncoder
	bsoncodec.ValueDecoder
}

func NewULIDCodec

func NewULIDCodec() ULIDCodec