services

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

type Event struct {

	// Primary identifiers and timestamps (8-byte aligned)
	PublishedAt time.Time `json:"published_at" theorydb:"index:tenant-timestamp-index,sk"`
	CreatedAt   time.Time `json:"created_at" theorydb:"created_at"`
	ExpiresAt   time.Time `json:"expires_at,omitempty" theorydb:"omitempty"`

	// String fields (16 bytes each)
	ID            string `json:"id" theorydb:"index:event-id-index,pk"`
	EventType     string `json:"event_type"`
	TenantID      string `json:"tenant_id" theorydb:"index:tenant-timestamp-index,pk"`
	SourceID      string `json:"source_id"`
	PartitionKey  string `json:"partition_key" theorydb:"pk,attr:pk"`
	SortKey       string `json:"sort_key" theorydb:"sk,attr:sk"`
	CorrelationID string `json:"correlation_id,omitempty" theorydb:"omitempty"`

	// Complex types
	Payload  json.RawMessage   `json:"payload"`
	Metadata map[string]string `json:"metadata,omitempty" theorydb:"omitempty"`
	Tags     []string          `json:"tags,omitempty" theorydb:"set,omitempty"`

	// TTL is stored in the DynamoDB TTL attribute ("ttl") as a Unix timestamp in seconds.
	TTL int64 `json:"-" theorydb:"ttl,omitempty"`

	// Smaller numeric types
	Version    int `json:"version"`
	RetryCount int `json:"retry_count"`
	// contains filtered or unexported fields
}

type EventBus interface {
	// Publish publishes an event to the bus and returns the event ID.
	Publish(ctx context.Context, event *Event) (string, error)

	// Query retrieves events based on filters. Implementations may mutate
	// query.NextKey to return a pagination cursor.
	Query(ctx context.Context, query *EventQuery) ([]*Event, error)

	// Subscribe registers a handler for specific event types (for stream processing).
	Subscribe(ctx context.Context, eventType string, handler EventHandler) error

	// GetEvent retrieves a specific event by ID.
	GetEvent(ctx context.Context, eventID string) (*Event, error)

	// DeleteEvent removes an event (for cleanup/GDPR).
	DeleteEvent(ctx context.Context, eventID string) error
}

type EventBusConfig struct {
	TableName        string
	MetricsNamespace string
	TTL              time.Duration
	RetryBaseDelay   time.Duration
	RetryAttempts    int
	MaxBatchSize     int
	EnableMetrics    bool
	EmitMetric       func(MetricRecord)
}

type EventHandler func(ctx context.Context, event *Event) error

type EventQuery struct {
	// Lift-compatible cursor shape.
	LastEvaluatedKey map[string]any
	NextKey          map[string]any // Returned pagination token for next query

	StartTime *time.Time
	EndTime   *time.Time

	TenantID  string
	EventType string
	Tags      []string
	Limit     int
}

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

type MetricRecord struct {
	Namespace string
	Name      string
	Value     float64
	Tags      map[string]string
}