storage

type LifetimeInputOperations interface {
	Start(ctx context.Context) (time.Time, error)
	Stop() error

	FirstUpdate(ctx context.Context, offsetAfter time.Time) (bool, error)
	Update(ctx context.Context) (bool, error)
	Delete(deletePolicy lifetimesapi.DeletePolicy) error
}

type LifetimeOutputOperations interface {
	Start(ctx context.Context) error
	Stop() error

	Delete(deletePolicy lifetimesapi.DeletePolicy) error
}