pubsub

type DeadLetter[T any] struct {
	// Error that resulted in the event being dead-lettered.
	Error string `json:"error"`
	Event T      `json:"event"`
}

type Event[T any] struct {
	// contains filtered or unexported fields
}

type EventPayload interface {
	// EventID returns the unique identifier for the event.
	//
	// This is required for idempotence and deduplication in the face of multiple retries.
	EventID() string
}

type InMemoryTopic[T any] struct {
	// contains filtered or unexported fields
}

type Topic[T any] interface {
	// Publish publishes a message to the topic.
	Publish(ctx context.Context, msg Event[T]) error
	// Subscribe subscribes to a topic.
	Subscribe(ctx context.Context, handler func(ctx context.Context, event Event[T]) error) error
	// Close the topic.
	Close() error
}