generic

Documentation

Index

• func ClaimTransformer(_ context.Context, newObj runtime.Object, oldObj runtime.Object) (runtime.Object, error)
• func EntryTransformer(_ context.Context, newObj runtime.Object, oldObj runtime.Object) (runtime.Object, error)
• func New(indexKind string, claimKind string, ...) bebackend.Backend
• type Applicator
• type BackendStorage
  • func NewKuidBackendstorage(entryStorage, claimStorage *registry.Store) BackendStorage
• type CacheInstanceContext
  • func NewCacheInstanceContext(tree gtree.GTree, idxType string) *CacheInstanceContext
  • func (r *CacheInstanceContext) Size() int
  • func (r *CacheInstanceContext) Type() string
• type ListOption
• type ListOptions
  • func (o *ListOptions) ApplyOptions(opts []ListOption) *ListOptions
  • func (o *ListOptions) ApplyToList(lo *ListOptions)

Functions

func ClaimTransformer

func ClaimTransformer(_ context.Context, newObj runtime.Object, oldObj runtime.Object) (runtime.Object, error)

func EntryTransformer

func EntryTransformer(_ context.Context, newObj runtime.Object, oldObj runtime.Object) (runtime.Object, error)

func New

func New(
	indexKind string,
	claimKind string,
	indexObjectFn func(runtime.Object) (backend.IndexObject, error),
	claimObjectFn func(runtime.Object) (backend.ClaimObject, error),
	entryObjectFn func(runtime.Object) (backend.EntryObject, error),
	entryFromCacheFn func(k store.Key, vrange, id string, labels map[string]string) backend.EntryObject,
) bebackend.Backend

Types

type Applicator

type Applicator interface {
	Validate(ctx context.Context, claim backend.ClaimObject) error
	Apply(ctx context.Context, claim backend.ClaimObject) error
	Delete(ctx context.Context, claim backend.ClaimObject) error
}

type BackendStorage

type BackendStorage interface {
	ListEntries(ctx context.Context, k store.Key) ([]backend.EntryObject, error)
	CreateEntry(ctx context.Context, obj backend.EntryObject) error
	UpdateEntry(ctx context.Context, obj, old backend.EntryObject) error
	DeleteEntry(ctx context.Context, obj backend.EntryObject) error
	ListClaims(ctx context.Context, k store.Key, opts ...ListOption) (map[string]backend.ClaimObject, error)
	CreateClaim(ctx context.Context, obj backend.ClaimObject) error
	UpdateClaim(ctx context.Context, obj, old backend.ClaimObject) error
	DeleteClaim(ctx context.Context, obj backend.ClaimObject) error
}

func NewKuidBackendstorage

func NewKuidBackendstorage(entryStorage, claimStorage *registry.Store) BackendStorage

type CacheInstanceContext

type CacheInstanceContext struct {
	// contains filtered or unexported fields
}

func NewCacheInstanceContext

func NewCacheInstanceContext(tree gtree.GTree, idxType string) *CacheInstanceContext

func (*CacheInstanceContext) Size

func (r *CacheInstanceContext) Size() int

func (*CacheInstanceContext) Type

func (r *CacheInstanceContext) Type() string

type ListOption

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

type ListOptions

type ListOptions struct {
	OwnerKind string
}

func (*ListOptions) ApplyOptions

func (o *ListOptions) ApplyOptions(opts []ListOption) *ListOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*ListOptions) ApplyToList

func (o *ListOptions) ApplyToList(lo *ListOptions)