omap

package

v0.5.0 Latest Latest Go to latest Published: Jul 27, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (
	NameVolumes   = "ironcore.csi.volumes"
	NameSnapshots = "ironcore.csi.snapshots"
)

View Source

var ErrResourceVersionNotLatest = errors.New("resourceVersion is not latest")

This section is empty.

type CreateStrategy[E apiutils.Object] interface {
	PrepareForCreate(obj E)
}

type Options[E apiutils.Object] struct {
	OmapName       string
	NewFunc        func() E
	CreateStrategy CreateStrategy[E]
	IteratorSize   int64
}

type Store[E apiutils.Object] struct {
	// contains filtered or unexported fields
}

func New[E apiutils.Object](log logr.Logger, conn *rados.Conn, pool string, opts Options[E]) (*Store[E], error)

func (s *Store[E]) Create(ctx context.Context, obj E) (E, error)

func (s *Store[E]) Delete(ctx context.Context, id string) error

func (s *Store[E]) Get(ctx context.Context, id string) (E, error)

func (s *Store[E]) List(ctx context.Context) ([]E, error)

func (s *Store[E]) Update(ctx context.Context, obj E) (E, error)

func (s *Store[E]) Watch(ctx context.Context) (store.Watch[E], error)