events

type Config struct {
	Persistence Persistence `yaml:"persistence"`
	Path        string      `yaml:"-"`
}

type DataType int

type Event struct {
	ID      ulid.ULID `json:"id"`
	Topic   string    `json:"topic"`
	Payload Payload   `json:"payload"`
}

type FetchFromIteratorRequest struct {
	ID    string
	Batch int
}

type Iterator interface {
	ID() string
	Fetch(batch int) ([]*Event, error)
	Close(err error)
	Done() <-chan struct{}
	Err() error
}

type NewIteratorRequest struct {
	Topic string    `json:"topic"`
	Since time.Time `json:"since"`
}

type Payload struct {
	Data any
	Type DataType
}

type Persistence struct {
	Driver StorageDriver `yaml:"driver"`
	DSN    string        `yaml:"dsn"`
}

type Repository interface {
	Store(e *Event) error
	Iterator(ctx context.Context, since time.Time) (Iterator, error)
	Close() error
}

type Service interface {
	Up()
	Down()
	Store(topic string, payload Payload, ids ...ulid.ULID) error
	NewIterator(topic string, since time.Time) (string, error)
	Iterator(id string) (Iterator, error)

	// Iterator
	FetchFromIterator(batch int, id string) ([]*Event, error)
	CloseIterator(id string) error
}

type ServiceMiddleware func(Service) Service

type StorageDriver string

type StoreRequest struct {
	ID      ulid.ULID `json:"id"`
	Topic   string    `json:"topic"`
	Payload Payload   `json:"payload"`
}