omap

Documentation

Index

• Constants
• Variables
• type CreateStrategy
• type Options
• type Store
  • func New[E api.Object](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)

Constants

const (
	OmapNameVolumes  = "ironcore.csi.volumes"
	OmapNameOsImages = "ironcore.csi.os-images"
)

Variables

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

Types

type CreateStrategy

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

type Options

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

type Store

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

func New

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

func (*Store[E]) Create

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

func (*Store[E]) Delete

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

func (*Store[E]) Get

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

func (*Store[E]) List

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

func (*Store[E]) Update

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

func (*Store[E]) Watch

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