crds

Documentation

Index

• type CRDStore
  • func NewCRDStore(opts ...CRDStoreOption) *CRDStore
  • func (c *CRDStore) CreateCluster(ctx context.Context, cluster *corev1.Cluster) error
  • func (c *CRDStore) CreateRole(ctx context.Context, role *corev1.Role) error
  • func (c *CRDStore) CreateRoleBinding(ctx context.Context, rb *corev1.RoleBinding) error
  • func (c *CRDStore) CreateToken(ctx context.Context, ttl time.Duration, opts ...storage.TokenCreateOption) (*corev1.BootstrapToken, error)
  • func (c *CRDStore) DeleteCluster(ctx context.Context, ref *corev1.Reference) error
  • func (c *CRDStore) DeleteRole(ctx context.Context, ref *corev1.Reference) error
  • func (c *CRDStore) DeleteRoleBinding(ctx context.Context, ref *corev1.Reference) error
  • func (c *CRDStore) DeleteToken(ctx context.Context, ref *corev1.Reference) error
  • func (c *CRDStore) GetCluster(ctx context.Context, ref *corev1.Reference) (*corev1.Cluster, error)
  • func (c *CRDStore) GetRole(ctx context.Context, ref *corev1.Reference) (*corev1.Role, error)
  • func (c *CRDStore) GetRoleBinding(ctx context.Context, ref *corev1.Reference) (*corev1.RoleBinding, error)
  • func (c *CRDStore) GetToken(ctx context.Context, ref *corev1.Reference) (*corev1.BootstrapToken, error)
  • func (e *CRDStore) KeyringStore(prefix string, ref *corev1.Reference) storage.KeyringStore
  • func (c *CRDStore) ListClusters(ctx context.Context, matchLabels *corev1.LabelSelector, ...) (*corev1.ClusterList, error)
  • func (c *CRDStore) ListRoleBindings(ctx context.Context) (*corev1.RoleBindingList, error)
  • func (c *CRDStore) ListRoles(ctx context.Context) (*corev1.RoleList, error)
  • func (c *CRDStore) ListTokens(ctx context.Context) ([]*corev1.BootstrapToken, error)
  • func (c *CRDStore) UpdateCluster(ctx context.Context, ref *corev1.Reference, ...) (*corev1.Cluster, error)
  • func (c *CRDStore) UpdateToken(ctx context.Context, ref *corev1.Reference, ...) (*corev1.BootstrapToken, error)
  • func (c *CRDStore) WatchCluster(ctx context.Context, ref *corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
  • func (c *CRDStore) WatchClusters(_ context.Context, _ []*corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
• type CRDStoreOption
  • func WithCommandTimeout(timeout time.Duration) CRDStoreOption
  • func WithNamespace(ns string) CRDStoreOption
  • func WithRestConfig(rc *rest.Config) CRDStoreOption
• type CRDStoreOptions

Types

type CRDStore

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

func NewCRDStore

func NewCRDStore(opts ...CRDStoreOption) *CRDStore

func (*CRDStore) CreateCluster

func (c *CRDStore) CreateCluster(ctx context.Context, cluster *corev1.Cluster) error

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) DeleteCluster

func (c *CRDStore) DeleteCluster(ctx context.Context, ref *corev1.Reference) 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) GetCluster

func (c *CRDStore) GetCluster(ctx context.Context, ref *corev1.Reference) (*corev1.Cluster, 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) ListClusters

func (c *CRDStore) ListClusters(ctx context.Context, matchLabels *corev1.LabelSelector, matchOptions corev1.MatchOptions) (*corev1.ClusterList, error)

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) UpdateCluster

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

func (*CRDStore) UpdateToken

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

func (*CRDStore) WatchCluster

func (c *CRDStore) WatchCluster(
	ctx context.Context,
	ref *corev1.Cluster,
) (<-chan storage.WatchEvent[*corev1.Cluster], error)

func (*CRDStore) WatchClusters

func (c *CRDStore) WatchClusters(
	_ context.Context,
	_ []*corev1.Cluster,
) (<-chan storage.WatchEvent[*corev1.Cluster], error)

type CRDStoreOption

type CRDStoreOption func(*CRDStoreOptions)

func WithCommandTimeout

func WithCommandTimeout(timeout time.Duration) CRDStoreOption

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
}