zsync

type RunGroup struct {

	// OnStart is called for all runners before they actually run.
	// The runner is given by the first argument.
	OnStart func(r Runner)
	// OnExit is called for all runners after they exited.
	// The runner is given by the first argument.
	// The error its runner returned is passed by the second argument.
	OnExit func(r Runner, err error)
	// contains filtered or unexported fields
}

type Runner interface {
	// Run run the process that implements this interface.
	Run(context.Context) error
}

type RunnerFunc func(context.Context) error

type Store[K comparable, T any] interface {
	// Store sets the value for a key.
	// It the key already exists, it replaces the value.
	Store(key K, value T)
	// Load returns the stored value for a key.
	// If the kwy was not found, it returns zero value of type T and false.
	Load(key K) (value T, ok bool)
	// Delete deletes the value for a key.
	Delete(key K)
	// Clear deletes all the entries.
	Clear()
	// Swap swaps the value for a key and returns the previous value if any.
	// The loaded result reports whether the key was present.
	Swap(key K, value T) (previous T, loaded bool)
	// LoadAndDelete deletes the value for a key, returning the previous value if any.
	// The loaded result reports whether the key was present.
	LoadAndDelete(key K) (value T, loaded bool)
	// LoadOrStore returns the existing value for the key if present.
	// Otherwise, it stores and returns the given value.
	// The loaded result is true if the value was loaded, false if stored.
	LoadOrStore(key K, value T) (actual T, loaded bool)
	// CompareAndSwap swaps the old and new values for key
	// if the value stored is equal to old.
	// The old value must be of a comparable type.
	CompareAndSwap(key K, old, new T) (swapped bool)
	// CompareAndDelete deletes the entry for key if its value is equal to old.
	// The old value must be of a comparable type.
	// If there is no current value for key, CompareAndDelete returns false.
	CompareAndDelete(key K, old T) (deleted bool)
	// Range calls f sequentially for each key and value.
	// If f returns false, range stops the iteration.
	Range(f func(key K, value any) bool)
}