memory

package

v0.3.2 Latest Latest Go to latest Published: Sep 30, 2026 License: MIT Imports: 8 Imported by: 0

Details

Package memory provides a process-local implementation of core.Store.

This section is empty.

This section is empty.

This section is empty.

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

Store keeps delivery state in memory (doesn't survive process restarts).

func New[T any]() *Store[T]

New returns an empty Store.

func (s *Store[T]) ActivateDestination(ctx context.Context, plan core.PlanID, destination core.DestinationID) error

ActivateDestination lets the destination receive newly enqueued work again.

func (s *Store[T]) Admit(ctx context.Context, plan core.Plan, items []core.Item[T]) error

Admit registers the plan and creates one delivery obligation per plan destination for each item.

func (s *Store[T]) Claim(ctx context.Context, request core.ClaimRequest) ([]core.Work[T], error)

Claim implements core.Store.

func (s *Store[T]) PendingPlans(ctx context.Context) ([]core.PlanID, error)

PendingPlans returns every plan that still holds unfinished deliveries.

func (s *Store[T]) QuarantineDestination(
	ctx context.Context, plan core.PlanID, destination core.DestinationID, failure string,
) error

QuarantineDestination blocks the destination and terminalizes its work.

func (s *Store[T]) Resolve(ctx context.Context, resolution core.Resolution) error

Resolve implements core.Store.