commandlog

type CommandLogStore interface {
	// Record persists a command record. The record's ID must be unique.
	Record(ctx context.Context, record CommandRecord) error

	// Get retrieves a single record by ID. Returns ErrNotFound if absent.
	Get(ctx context.Context, id string) (CommandRecord, error)

	// FindByCorrelation returns all records sharing a correlation ID, ordered by Timestamp.
	FindByCorrelation(ctx context.Context, correlationID string) ([]CommandRecord, error)

	// FindByType returns records matching the command type, filtered by opts.
	FindByType(ctx context.Context, commandType string, opts QueryOpts) ([]CommandRecord, error)

	// List returns records ordered by Timestamp descending, filtered by opts.
	List(ctx context.Context, opts QueryOpts) ([]CommandRecord, error)
}

type CommandRecord struct {
	// ID uniquely identifies this record.
	ID string

	// CorrelationID groups related commands (e.g. a saga).
	CorrelationID string

	// CommandType is the routed command name.
	CommandType string

	// Payload is the serialized command body. Bounded by MaxPayloadBytes.
	Payload []byte

	// Metadata holds arbitrary key-value pairs. Bounded by MaxMetadataKeys.
	Metadata map[string]string

	// Status is the execution outcome: pending, accepted, rejected, or failed.
	Status string

	// Error holds the error message if Status is rejected or failed.
	Error string

	// EventIDs lists IDs of events produced by the command. Bounded by MaxEventIDs.
	EventIDs []string

	// Duration is how long the command took to execute.
	Duration time.Duration

	// Timestamp is when the command was recorded.
	Timestamp time.Time
}

type IDFunc func() string

type MiddlewareOption func(*middlewareConfig)

type QueryOpts struct {
	// Limit caps the number of results. Zero means DefaultQueryLimit; capped at MaxQueryLimit.
	Limit int

	// Offset skips this many results (for pagination).
	Offset int

	// After filters to records with Timestamp strictly after this time.
	After time.Time

	// Before filters to records with Timestamp strictly before this time.
	Before time.Time
}