eventx

type EventConstraint interface {
	// GetID returns the event id
	GetID() uint64

	// GetSequence returns the event sequence number, = 0 if sequence is null
	GetSequence() uint64

	// GetSize returns the approximate size (in bytes) of the event, for limit batch size by event data size
	// using WithSubscriberSizeLimit for configuring this limit
	GetSize() uint64
}

type GetSequenceFunc func(ctx context.Context) (sql.NullInt64, error)

type Option func(opts *eventxOptions)

type Repository[E EventConstraint] interface {
	// GetLastEvents returns top *limit* events (events with the highest sequence numbers),
	// by sequence number in ascending order, ignore events with null sequence number
	GetLastEvents(ctx context.Context, limit uint64) ([]E, error)

	// GetUnprocessedEvents returns list of events with the smallest event *id* (not sequence number)
	// *AND* have NULL sequence numbers, in ascending order of event *id*
	// size of the list is limited by *limit*
	GetUnprocessedEvents(ctx context.Context, limit uint64) ([]E, error)

	// GetEventsFrom returns list of events with sequence number >= *from*
	// in ascending order of event sequence numbers, ignoring events with null sequence numbers
	// size of the list is limited by *limit*
	GetEventsFrom(ctx context.Context, from uint64, limit uint64) ([]E, error)

	// UpdateSequences updates only sequence numbers of *events*
	UpdateSequences(ctx context.Context, events []E) error
}

type RetentionJob[E EventConstraint] struct {
	// contains filtered or unexported fields
}

type RetentionOption func(opts *retentionOptions)

type RetentionRepository interface {
	// GetMinSequence returns the min sequence number of all events (except events with null sequence numbers)
	// returns null if no events with sequence number existed
	GetMinSequence(ctx context.Context) (sql.NullInt64, error)

	// DeleteEventsBefore deletes events with sequence number < *beforeSeq*
	DeleteEventsBefore(ctx context.Context, beforeSeq uint64) error
}

type RetryConsumer[E EventConstraint] struct {
	// contains filtered or unexported fields
}

type RetryConsumerOption func(conf *retryConsumerConfig)

type Runner[E EventConstraint] struct {
	// contains filtered or unexported fields
}

type SetSequenceFunc func(ctx context.Context, seq uint64) error

type Subscriber[E EventConstraint] struct {
	// contains filtered or unexported fields
}

type SubscriberOption func(opts *subscriberOptions)

type Timer interface {
	Reset()
	ResetAfterChan()
	Chan() <-chan time.Time
}