postgresql

type EsRepository[K eventsourcing.ID, PK eventsourcing.IDPt[K]] struct {
	Repository
	// contains filtered or unexported fields
}

type Event struct {
	ID               eventid.EventID
	AggregateID      string
	AggregateIDHash  int32
	AggregateVersion uint32
	AggregateKind    eventsourcing.Kind
	Kind             eventsourcing.Kind
	Body             []byte
	IdempotencyKey   store.NilString
	CreatedAt        time.Time
	Migration        int
	Migrated         bool
	Metadata         eventsourcing.Metadata
}

type EventsRepository[K eventsourcing.ID] interface {
	GetEventsByRawIDs(context.Context, []string) ([]*eventsourcing.Event[K], error)
}

type Feed[K eventsourcing.ID, PK eventsourcing.IDPt[K]] struct {
	// contains filtered or unexported fields
}

type FeedOption[K eventsourcing.ID, PK eventsourcing.IDPt[K]] func(*Feed[K, PK])

type KVStore struct {
	Repository
	// contains filtered or unexported fields
}

type Option[K eventsourcing.ID, PK eventsourcing.IDPt[K]] func(*EsRepository[K, PK])

type OutboxRepository[K eventsourcing.ID] struct {
	Repository
	// contains filtered or unexported fields
}

type ProjectionMigrater[K eventsourcing.ID] interface {
	// Name returns the name of the new projection. It is used to track if the projection was fully processed
	Name() string
	// Steps returns the order of the aggregate types to process to recreate the projection
	Steps() []ProjectionMigrationStep[K]
	// Flush is called for each aggregate with the current state
	Flush(context.Context, store.AggregateMetadata[K], eventsourcing.Aggregater[K]) error
}

type ProjectionMigrationStep[K eventsourcing.ID] struct {
	AggregateKind eventsourcing.Kind
	// Factory creates a new aggregate instance
	Factory func() eventsourcing.Aggregater[K]
}

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

type Snapshot struct {
	ID               eventid.EventID
	AggregateID      string
	AggregateVersion uint32
	AggregateKind    eventsourcing.Kind
	Body             []byte
	CreatedAt        time.Time
	Metadata         eventsourcing.Metadata
}