store

type ApplyOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToApply(*ApplyOptions)
}

type ApplyOptions struct {
}

type BranchUnstructuredStore interface {
	UnstructuredStore
}

type CreateOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToCreate(*CreateOptions)
}

type CreateOptions struct {
}

type DeleteOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToDelete(*DeleteOptions)
}

type DeleteOptions struct {
}

type GetOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToGet(*GetOptions)
}

type GetOptions struct {
	Commit *object.Commit
}

type Key struct {
	Branch string
	types.NamespacedName
}

type ListOption interface {
	// ApplyToList applies this configuration to the given get options.
	ApplyToList(*ListOptions)
}

type ListOptions struct {
	Commit *object.Commit
	Watch  bool
}

type Storer[T1 any] interface {
	// Starting the watcher manager
	Start(context.Context)

	// Stopping the watcher manager
	Stop()
	// Retrieve retrieves data for the given key from the storage
	Get(key Key, opts ...GetOption) (T1, error)

	// Retrieve retrieves data for the given key from the storage
	List(visitorFunc func(Key, T1), opts ...ListOption)

	// Retrieve retrieves data for the given key from the storage
	ListKeys(opts ...ListOption) []string

	// Len returns the # entries in the store
	Len(opts ...ListOption) int

	Apply(key Key, data T1, opts ...ApplyOption) error

	// Create data with the given key in the storage
	Create(key Key, data T1, opts ...CreateOption) error

	// Update data with the given key in the storage
	Update(key Key, data T1, opts ...UpdateOption) error

	// Update data in a concurrent way through a function
	UpdateWithKeyFn(key Key, updateFunc func(obj T1) T1)

	// Delete deletes data and key from the storage
	Delete(key Key, opts ...DeleteOption) error

	// Watch watches change
	Watch(ctx context.Context, opts ...ListOption) (watch.WatchInterface[T1], error)
}

type UnstructuredStore interface {
	// Retrieve retrieves data for the given key from the storage
	Get(key Key, opts ...GetOption) (runtime.Unstructured, error)

	// Retrieve retrieves data for the given key from the storage
	List(visitorFunc func(key Key, obj runtime.Unstructured), opts ...ListOption)

	// Retrieve retrieves data for the given key from the storage
	ListKeys(opts ...ListOption) []string

	// Len returns the # entries in the store
	Len(opts ...ListOption) int

	Apply(key Key, obj runtime.Unstructured, opts ...ApplyOption) error

	// Create data with the given key in the storage
	Create(key Key, obj runtime.Unstructured, opts ...CreateOption) error

	// Update data with the given key in the storage
	Update(key Key, obj runtime.Unstructured, opts ...UpdateOption) error

	// Update data in a concurrent way through a function
	UpdateWithKeyFn(key Key, updateFunc func(obj runtime.Unstructured, opts ...UpdateOption) runtime.Unstructured)

	// Delete deletes data and key from the storage
	Delete(key Key, opts ...DeleteOption) error

	// Watch watches change
	Watch(ctx context.Context, opts ...ListOption) (watch.WatchInterface[runtime.Unstructured], error)
}

type UpdateOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToUpdate(*UpdateOptions)
}

type UpdateOptions struct {
}