crds

package

v0.12.0-rc1 Latest Latest Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rancher/opni

Documentation ¶

Index ¶

func NewCRDValueStore[O client.Object, T driverutil.ConfigType[T]](objectRef client.ObjectKey, methods ValueStoreMethods[O, T], ...) storage.ValueStoreT[T]
type CRDStore
- func NewCRDStore(opts ...CRDStoreOption) *CRDStore
type CRDStoreOption
- func WithNamespace(ns string) CRDStoreOption
- func WithRestConfig(rc *rest.Config) CRDStoreOption
type CRDStoreOptions
type CRDValueStore
type CRDValueStoreOption
- func WithClient(client client.WithWatch) CRDValueStoreOption
type CRDValueStoreOptions
type ValueStoreMethods

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewCRDValueStore ¶ added in v0.12.0

func NewCRDValueStore[O client.Object, T driverutil.ConfigType[T]](
	objectRef client.ObjectKey,
	methods ValueStoreMethods[O, T],
	opts ...CRDValueStoreOption,
) storage.ValueStoreT[T]

Types ¶

type CRDStore ¶

type CRDStore struct {
	CRDStoreOptions
	// contains filtered or unexported fields
}

func NewCRDStore ¶

func NewCRDStore(opts ...CRDStoreOption) *CRDStore

func (*CRDStore) CreateRole ¶

func (c *CRDStore) CreateRole(ctx context.Context, role *corev1.Role) error

func (*CRDStore) CreateRoleBinding ¶

func (c *CRDStore) CreateRoleBinding(ctx context.Context, rb *corev1.RoleBinding) error

func (*CRDStore) CreateToken ¶

func (c *CRDStore) CreateToken(ctx context.Context, ttl time.Duration, opts ...storage.TokenCreateOption) (*corev1.BootstrapToken, error)

func (*CRDStore) DeleteRole ¶

func (c *CRDStore) DeleteRole(ctx context.Context, ref *corev1.Reference) error

func (*CRDStore) DeleteRoleBinding ¶

func (c *CRDStore) DeleteRoleBinding(ctx context.Context, ref *corev1.Reference) error

func (*CRDStore) DeleteToken ¶

func (c *CRDStore) DeleteToken(ctx context.Context, ref *corev1.Reference) error

func (*CRDStore) GetRole ¶

func (c *CRDStore) GetRole(ctx context.Context, ref *corev1.Reference) (*corev1.Role, error)

func (*CRDStore) GetRoleBinding ¶

func (c *CRDStore) GetRoleBinding(ctx context.Context, ref *corev1.Reference) (*corev1.RoleBinding, error)

func (*CRDStore) GetToken ¶

func (c *CRDStore) GetToken(ctx context.Context, ref *corev1.Reference) (*corev1.BootstrapToken, error)

func (*CRDStore) KeyringStore ¶

func (e *CRDStore) KeyringStore(prefix string, ref *corev1.Reference) storage.KeyringStore

func (*CRDStore) ListRoleBindings ¶

func (c *CRDStore) ListRoleBindings(ctx context.Context) (*corev1.RoleBindingList, error)

func (*CRDStore) ListRoles ¶

func (c *CRDStore) ListRoles(ctx context.Context) (*corev1.RoleList, error)

func (*CRDStore) ListTokens ¶

func (c *CRDStore) ListTokens(ctx context.Context) ([]*corev1.BootstrapToken, error)

func (*CRDStore) UpdateRole ¶ added in v0.11.0

func (c *CRDStore) UpdateRole(ctx context.Context, ref *corev1.Reference, mutator storage.MutatorFunc[*corev1.Role]) (*corev1.Role, error)

func (*CRDStore) UpdateRoleBinding ¶ added in v0.11.0

func (c *CRDStore) UpdateRoleBinding(ctx context.Context, ref *corev1.Reference, mutator storage.MutatorFunc[*corev1.RoleBinding]) (*corev1.RoleBinding, error)

func (*CRDStore) UpdateToken ¶

func (c *CRDStore) UpdateToken(ctx context.Context, ref *corev1.Reference, mutator storage.MutatorFunc[*corev1.BootstrapToken]) (*corev1.BootstrapToken, error)

type CRDStoreOption ¶

type CRDStoreOption func(*CRDStoreOptions)

func WithNamespace ¶

func WithNamespace(ns string) CRDStoreOption

func WithRestConfig ¶

func WithRestConfig(rc *rest.Config) CRDStoreOption

type CRDStoreOptions ¶

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

type CRDValueStore ¶ added in v0.12.0

type CRDValueStore[O client.Object, T driverutil.ConfigType[T]] struct {
	CRDValueStoreOptions
	// contains filtered or unexported fields
}

func (*CRDValueStore[O, T]) Delete ¶ added in v0.12.0

func (s *CRDValueStore[O, T]) Delete(ctx context.Context, opts ...storage.DeleteOpt) error

func (*CRDValueStore[O, T]) Get ¶ added in v0.12.0

func (s *CRDValueStore[O, T]) Get(ctx context.Context, opts ...storage.GetOpt) (T, error)

func (*CRDValueStore[O, T]) History ¶ added in v0.12.0

func (s *CRDValueStore[O, T]) History(ctx context.Context, opts ...storage.HistoryOpt) ([]storage.KeyRevision[T], error)

func (*CRDValueStore[O, T]) Put ¶ added in v0.12.0

func (s *CRDValueStore[O, T]) Put(ctx context.Context, value T, opts ...storage.PutOpt) error

func (*CRDValueStore[O, T]) Watch ¶ added in v0.12.0

func (s *CRDValueStore[O, T]) Watch(ctx context.Context, opts ...storage.WatchOpt) (<-chan storage.WatchEvent[storage.KeyRevision[T]], error)

type CRDValueStoreOption ¶ added in v0.12.0

type CRDValueStoreOption func(*CRDValueStoreOptions)

func WithClient ¶ added in v0.12.0

func WithClient(client client.WithWatch) CRDValueStoreOption

type CRDValueStoreOptions ¶ added in v0.12.0

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

type ValueStoreMethods ¶ added in v0.12.0

type ValueStoreMethods[O client.Object, T driverutil.ConfigType[T]] interface {
	ControllerReference() (client.Object, bool)
	FillObjectFromConfig(obj O, conf T)
	FillConfigFromObject(obj O, conf T)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL