Documentation
¶
Index ¶
- type Store
- func (s *Store[T]) FetchPending(ctx context.Context, limit int) ([]xoutbox.Event[T], error)
- func (s *Store[T]) InsertEvent(ctx context.Context, event xoutbox.Event[T]) error
- func (s *Store[T]) MarkFailed(ctx context.Context, id T, retryCount int) error
- func (s *Store[T]) MarkPublished(ctx context.Context, id T) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store[T comparable] struct { // contains filtered or unexported fields }
func (*Store[T]) FetchPending ¶
func (*Store[T]) InsertEvent ¶
func (*Store[T]) MarkFailed ¶
Source Files
Click to show internal directories.
Click to hide internal directories.