stores

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMemoryEventStore 

func NewMemoryEventStore(logger forge.Logger, metrics forge.Metrics) core.EventStore

NewMemoryEventStore creates a new in-memory event store

Types

type MemoryEventStore 

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

MemoryEventStore implements EventStore interface using in-memory storage

func (*MemoryEventStore) Close 

func (mes *MemoryEventStore) Close(ctx context.Context) error

Close closes the event store connection

func (*MemoryEventStore) CreateSnapshot 

func (mes *MemoryEventStore) CreateSnapshot(ctx context.Context, snapshot *core.Snapshot) error

CreateSnapshot creates a snapshot of an aggregate's state

func (*MemoryEventStore) DeleteEvent 

func (mes *MemoryEventStore) DeleteEvent(ctx context.Context, eventID string) error

func (*MemoryEventStore) DeleteEventsByAggregate 

func (mes *MemoryEventStore) DeleteEventsByAggregate(ctx context.Context, aggregateID string) error

func (*MemoryEventStore) DeleteSnapshot 

func (mes *MemoryEventStore) DeleteSnapshot(ctx context.Context, snapshotID string) error

func (*MemoryEventStore) GetEvent 

func (mes *MemoryEventStore) GetEvent(ctx context.Context, eventID string) (*core.Event, error)

GetEvent retrieves a single event by ID

func (*MemoryEventStore) GetEventCount 

func (mes *MemoryEventStore) GetEventCount(ctx context.Context) (int64, error)

GetEventCount gets the total count of events

func (*MemoryEventStore) GetEventCountByType 

func (mes *MemoryEventStore) GetEventCountByType(ctx context.Context, eventType string) (int64, error)

GetEventCountByType gets the count of events by type

func (*MemoryEventStore) GetEvents 

func (mes *MemoryEventStore) GetEvents(ctx context.Context, criteria core.EventCriteria) (*core.EventCollection, error)

GetEvents retrieves events by various criteria

func (*MemoryEventStore) GetEventsByAggregate 

func (mes *MemoryEventStore) GetEventsByAggregate(ctx context.Context, aggregateID string, fromVersion int) ([]*core.Event, error)

GetEventsByAggregate retrieves all events for a specific aggregate

func (*MemoryEventStore) GetEventsByType 

func (mes *MemoryEventStore) GetEventsByType(ctx context.Context, eventType string, limit int, offset int64) ([]*core.Event, error)

GetEventsByType retrieves events of a specific type

func (*MemoryEventStore) GetEventsInRange 

func (mes *MemoryEventStore) GetEventsInRange(ctx context.Context, start, end time.Time, limit int, offset int64) ([]*core.Event, error)

GetEventsInRange retrieves events within a time range

func (*MemoryEventStore) GetEventsSince 

func (mes *MemoryEventStore) GetEventsSince(ctx context.Context, since time.Time, limit int, offset int64) ([]*core.Event, error)

GetEventsSince retrieves events since a specific timestamp

func (*MemoryEventStore) GetLastEvent 

func (mes *MemoryEventStore) GetLastEvent(ctx context.Context, aggregateID string) (*core.Event, error)

GetLastEvent gets the last event for an aggregate

func (*MemoryEventStore) GetSnapshot 

func (mes *MemoryEventStore) GetSnapshot(ctx context.Context, aggregateID string) (*core.Snapshot, error)

GetSnapshot retrieves the latest snapshot for an aggregate

func (*MemoryEventStore) HealthCheck 

func (mes *MemoryEventStore) HealthCheck(ctx context.Context) error

HealthCheck checks if the event store is healthy

func (*MemoryEventStore) SaveEvent 

func (mes *MemoryEventStore) SaveEvent(ctx context.Context, event *core.Event) error

SaveEvent saves a single event

func (*MemoryEventStore) SaveEvents 

func (mes *MemoryEventStore) SaveEvents(ctx context.Context, events []*core.Event) error

SaveEvents saves multiple events atomically

type MongoEvent 

type MongoEvent struct {
	ID          string                 `bson:"_id"`
	AggregateID string                 `bson:"aggregate_id"`
	Type        string                 `bson:"type"`
	Version     int                    `bson:"version"`
	Data        any                    `bson:"data"`
	Metadata    map[string]interface{} `bson:"metadata,omitempty"`
	Source      string                 `bson:"source,omitempty"`
	Timestamp   time.Time              `bson:"timestamp"`
	CreatedAt   time.Time              `bson:"created_at"`
}

MongoEvent represents an event document in MongoDB

type MongoEventStore 

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

MongoEventStore implements EventStore using MongoDB

func NewMongoEventStore 

func NewMongoEventStore(client *mongo.Client, dbName string, config *core.EventStoreConfig, logger forge.Logger, metrics forge.Metrics) (*MongoEventStore, error)

NewMongoEventStore creates a new MongoDB event store

func (*MongoEventStore) Close 

func (mes *MongoEventStore) Close(ctx context.Context) error

Close implements EventStore

func (*MongoEventStore) CreateSnapshot 

func (mes *MongoEventStore) CreateSnapshot(ctx context.Context, snapshot *core.Snapshot) error

CreateSnapshot implements EventStore

func (*MongoEventStore) GetEvent 

func (mes *MongoEventStore) GetEvent(ctx context.Context, eventID string) (*core.Event, error)

GetEvent implements EventStore

func (*MongoEventStore) GetEventsByAggregate 

func (mes *MongoEventStore) GetEventsByAggregate(ctx context.Context, aggregateID string, fromVersion int) ([]*core.Event, error)

GetEventsByAggregate implements EventStore

func (*MongoEventStore) GetEventsByType 

func (mes *MongoEventStore) GetEventsByType(ctx context.Context, eventType string, fromTime, toTime time.Time) ([]*core.Event, error)

GetEventsByType implements EventStore

func (*MongoEventStore) GetSnapshot 

func (mes *MongoEventStore) GetSnapshot(ctx context.Context, aggregateID string) (*core.Snapshot, error)

GetSnapshot implements EventStore

func (*MongoEventStore) GetStats 

func (mes *MongoEventStore) GetStats() *core.EventStoreStats

GetStats implements EventStore

func (*MongoEventStore) QueryEvents 

func (mes *MongoEventStore) QueryEvents(ctx context.Context, criteria *core.EventCriteria) ([]*core.Event, error)

QueryEvents implements EventStore

func (*MongoEventStore) SaveEvent 

func (mes *MongoEventStore) SaveEvent(ctx context.Context, event *core.Event) error

SaveEvent implements EventStore

func (*MongoEventStore) SaveEvents 

func (mes *MongoEventStore) SaveEvents(ctx context.Context, events []*core.Event) error

SaveEvents implements EventStore

type MongoSnapshot 

type MongoSnapshot struct {
	ID          string                 `bson:"_id"`
	AggregateID string                 `bson:"aggregate_id"`
	Type        string                 `bson:"type"`
	Version     int                    `bson:"version"`
	Data        any                    `bson:"data"`
	Metadata    map[string]interface{} `bson:"metadata,omitempty"`
	Timestamp   time.Time              `bson:"timestamp"`
	CreatedAt   time.Time              `bson:"created_at"`
}

MongoSnapshot represents a snapshot document in MongoDB

type PostgresEventRow 

type PostgresEventRow struct {
	ID          string
	AggregateID string
	Type        string
	Version     int
	Data        []byte
	Metadata    []byte
	Source      string
	Timestamp   time.Time
	CreatedAt   time.Time
}

PostgresEventRow represents an event row in PostgreSQL

type PostgresEventStore 

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

PostgresEventStore implements EventStore using PostgreSQL

func NewPostgresEventStore 

func NewPostgresEventStore(db *sql.DB, config *core.EventStoreConfig, logger forge.Logger, metrics forge.Metrics) (*PostgresEventStore, error)

NewPostgresEventStore creates a new PostgreSQL event store

func (*PostgresEventStore) Close 

func (pes *PostgresEventStore) Close(ctx context.Context) error

Close implements EventStore

func (*PostgresEventStore) CreateSnapshot 

func (pes *PostgresEventStore) CreateSnapshot(ctx context.Context, snapshot *core.Snapshot) error

CreateSnapshot implements EventStore

func (*PostgresEventStore) GetEvent 

func (pes *PostgresEventStore) GetEvent(ctx context.Context, eventID string) (*core.Event, error)

GetEvent implements EventStore

func (*PostgresEventStore) GetEventsByAggregate 

func (pes *PostgresEventStore) GetEventsByAggregate(ctx context.Context, aggregateID string, fromVersion int) ([]*core.Event, error)

GetEventsByAggregate implements EventStore

func (*PostgresEventStore) GetEventsByType 

func (pes *PostgresEventStore) GetEventsByType(ctx context.Context, eventType string, fromTime, toTime time.Time) ([]*core.Event, error)

GetEventsByType implements EventStore

func (*PostgresEventStore) GetSnapshot 

func (pes *PostgresEventStore) GetSnapshot(ctx context.Context, aggregateID string) (*core.Snapshot, error)

GetSnapshot implements EventStore

func (*PostgresEventStore) GetStats 

func (pes *PostgresEventStore) GetStats() *core.EventStoreStats

GetStats implements EventStore

func (*PostgresEventStore) QueryEvents 

func (pes *PostgresEventStore) QueryEvents(ctx context.Context, criteria *core.EventCriteria) ([]*core.Event, error)

QueryEvents implements EventStore

func (*PostgresEventStore) SaveEvent 

func (pes *PostgresEventStore) SaveEvent(ctx context.Context, event *core.Event) error

SaveEvent implements EventStore

func (*PostgresEventStore) SaveEvents 

func (pes *PostgresEventStore) SaveEvents(ctx context.Context, events []*core.Event) error

SaveEvents implements EventStore

type PostgresSnapshotRow 

type PostgresSnapshotRow struct {
	ID          string
	AggregateID string
	Type        string
	Version     int
	Data        []byte
	Metadata    []byte
	Timestamp   time.Time
	CreatedAt   time.Time
}

PostgresSnapshotRow represents a snapshot row in PostgreSQL

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.