es

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

type Content interface {
	EventName() string
}

type Event struct {
	// StreamID is the ID of the stream the event belongs to.
	StreamID string
	// StreamType is the type of the stream the event belongs to.
	StreamType string
	// EventNumber is the number of the event in the stream.
	EventNumber int64
	// EventTime is the time the event was recorded in the Store
	EventTime time.Time
	// Content is the actual content of the event. Expected to be a struct defined
	// by the application.
	Content Content
	// StoreEventID is the ID of the event assigned by the Store
	// The StoreEventID is a UUIDv7 with the underlying time matching the EventTime
	StoreEventID string
	// StoreStreamID is the ID of the stream assigned by the Store
	// The StoreStreamID is a UUIDv7 with the underlying time matching the EventTime
	// of the first event in the stream.
	StoreStreamID string
}

type EventBus interface {
	// Write should write the events to all subscriptions
	Write(ctx context.Context, streamType string, events iter.Seq2[Event, error]) error
	// Subscribe a Handler by it's subscriptionID
	Subscribe(ctx context.Context, streamType string, subscriberID string, handler Handler) error
	// GetSubscriberIDs returns a list of all subscription IDs for the streamType
	GetSubscriberIDs(ctx context.Context, streamType string) ([]string, error)
	// WriteTo call all Handler with subscriberIDs with the events
	WriteTo(ctx context.Context, streamType string, events iter.Seq2[Event, error], subscriberIDs ...string) error
	Close() error
}

type EventUpgrade interface {
	Upgrade(ctx context.Context, events iter.Seq2[Event, error]) iter.Seq2[Event, error]
}

type EventUpgradeFunc func(ctx context.Context, i iter.Seq2[Event, error]) iter.Seq2[Event, error]

type Handler interface {
	Handle(ctx context.Context, event Event) error
}

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

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

type Logger interface {
	InfofCtx(ctx context.Context, template string, args ...any)
	ErrorfCtx(ctx context.Context, template string, args ...any)
}

type Option func(*Config)

type ReadWriter interface {
	Reader
	Writer
}

type Reader interface {
	Read(ctx context.Context, streamType string, streamID string, eventNumber int64) iter.Seq2[Event, error]
}

type Storage interface {
	// Read the events of of an streamType with the streamID from eventNumber
	Read(ctx context.Context, streamType string, streamID string, eventNumber int64) iter.Seq2[Event, error]
	// Write writes the events to the store.
	// All of the events must be written by sequence.
	// They should all be written or fully fail.
	Write(ctx context.Context, streamType string, events iter.Seq2[Event, error]) error
	// StartPublish should begin the process where newly written events are published to the Writer.
	// The publishing must be cancelled with the context
	StartPublish(ctx context.Context, w Writer) error
	// Register allows the Storage to Unmarshal multiple shapes of Content for an streamType.
	// It is considered an error if a Storage contains a shape of Content that have not been registered.
	Register(streamType string, types ...Content) error
	// GetStreamReferences returns a list of references to streams for the given streamType.
	// The returned list is ordered by the StoreStreamID and limited in size by the limit.
	// Use the last StreamReference.StoreStreamID as the pagination token.
	GetStreamReferences(ctx context.Context, streamType string, storeStreamID string, limit int64) iter.Seq2[StreamReference, error]
}

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

type Stream interface {
	// Project iterates over all events in the stream and calls the handler for each event.
	// The Stream will stop projecting if the handler returns an error.
	Project(handler Handler) error
	// All returns a iter.Seq2 of all events in the stream.
	// The returned iter.Seq2 will stop and return an error if there was an error
	// reading the events.
	// Calling this method twice will return the same iter.Seq2
	All() iter.Seq2[Event, error]
	// Write writes the given events to the stream.
	// The Events will be written in the order they are given and starting
	// at the most recent event number + 1.
	Write(events ...Content) error
	// Position returns the current position of the stream.
	Position() int64
	Close() error
}

type StreamReference struct {
	StreamType    string
	StreamID      string
	StoreStreamID string
}

type Writer interface {
	Write(ctx context.Context, streamType string, events iter.Seq2[Event, error]) error
}