eventstore

README

eventstore

Package eventstore provides mongo implementation of domain event store

Download:

go get -u github.com/bradishungry/go-api-learning/pkg/eventstore/mongo

---

Package eventstore provides mongo implementation of domain event store

Documentation

Index

• func New(ctx context.Context, collectionName string, mongoDB *mongo.Database) (baseeventstore.EventStore, error)
• type DTO
  • func NewDTOFromEvent(e *domain.Event) (*DTO, error)
  • func (o *DTO) ToEvent() (*domain.Event, error)
• type EventMetadataDTO

Functions

func New

func New(ctx context.Context, collectionName string, mongoDB *mongo.Database) (baseeventstore.EventStore, error)

New creates new mongo event store

Types

type DTO

type DTO struct {
	ID            string            `bson:"event_id"`
	Type          string            `bson:"event_type"`
	StreamID      string            `bson:"stream_id"`
	StreamName    string            `bson:"stream_name"`
	StreamVersion int               `bson:"stream_version"`
	OccurredAt    time.Time         `bson:"occurred_at"`
	ExpiresAt     *time.Time        `bson:"expires_at,omitempty"`
	Payload       bson.Raw          `bson:"payload"`
	Metadata      *EventMetadataDTO `bson:"metadata,omitempty"`
}

func NewDTOFromEvent

func NewDTOFromEvent(e *domain.Event) (*DTO, error)

func (*DTO) ToEvent

func (o *DTO) ToEvent() (*domain.Event, error)

type EventMetadataDTO

type EventMetadataDTO struct {
	Identity  *identity.Identity `bson:"identity,omitempty"`
	IPAddress net.IP             `bson:"ip_address,omitempty"`
	UserAgent string             `bson:"http_user_agent,omitempty"`
	Referer   string             `bson:"http_referer,omitempty"`
}