crdclient

Documentation

Overview

Package crdclient provides a client for the Liqo custom resources.

Index

• Variables
• func AddToRegistry(api string, singular, plural runtime.Object, keyer KeyerFunc, ...)
• func NewFakeCustomInformer(handlers cache.ResourceEventHandlerFuncs, keyer KeyerFunc, ...) (cache.Store, chan struct{})
• func NewKubeconfig(configPath string, gv *schema.GroupVersion, ...) (*rest.Config, error)
• func WatchRealResources(clientSet NamespacedCRDClientInterface, resource, namespace string, ...) (cache.Store, chan struct{}, error)
• func WatchResources(clientSet NamespacedCRDClientInterface, resource, namespace string, ...) (cache.Store, chan struct{}, error)
• func WatchfakeResources(resource string, handlers cache.ResourceEventHandlerFuncs) (cache.Store, chan struct{}, error)
• type CRDClient
  • func NewFromConfig(config *rest.Config) (*CRDClient, error)
  • func (c *CRDClient) Client() kubernetes.Interface
  • func (c *CRDClient) Config() *rest.Config
  • func (c *CRDClient) Resource(api string) CrdClientInterface
• type Client
  • func (c *Client) Create(obj runtime.Object, opts *metav1.CreateOptions) (runtime.Object, error)
  • func (c *Client) Delete(name string, opts *metav1.DeleteOptions) error
  • func (c *Client) Get(name string, opts *metav1.GetOptions) (runtime.Object, error)
  • func (c *Client) List(opts *metav1.ListOptions) (runtime.Object, error)
  • func (c *Client) Namespace(namespace string) CrdClientInterface
  • func (c *Client) Update(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)
  • func (c *Client) UpdateStatus(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)
  • func (c *Client) Watch(opts *metav1.ListOptions) (watch.Interface, error)
• type CrdClientInterface
• type FakeClient
  • func (c *FakeClient) Create(obj runtime.Object, _ *metav1.CreateOptions) (runtime.Object, error)
  • func (c *FakeClient) Delete(name string, opts *metav1.DeleteOptions) error
  • func (c *FakeClient) Get(name string, _ *metav1.GetOptions) (runtime.Object, error)
  • func (c *FakeClient) List(_ *metav1.ListOptions) (runtime.Object, error)
  • func (c *FakeClient) Namespace(namespace string) CrdClientInterface
  • func (c *FakeClient) Update(name string, obj runtime.Object, _ *metav1.UpdateOptions) (runtime.Object, error)
  • func (c *FakeClient) UpdateStatus(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)
  • func (c *FakeClient) Watch(_ *metav1.ListOptions) (watch.Interface, error)
• type KeyerFunc
• type NamespacedCRDClientInterface
• type RegistryType

Variables

var Fake bool

var Registry = make(map[string]RegistryType)

Functions

func AddToRegistry

func AddToRegistry(api string, singular, plural runtime.Object, keyer KeyerFunc, resource schema.GroupResource)

func NewFakeCustomInformer

func NewFakeCustomInformer(handlers cache.ResourceEventHandlerFuncs,
	keyer KeyerFunc,
	groupResource schema.GroupResource) (cache.Store, chan struct{})

NewFakeCustomInformer creates a new FakeCustomInformer, registers the callbacks and start the watching routine that implements the caching functionality and the callbak notifications.

func NewKubeconfig

func NewKubeconfig(configPath string, gv *schema.GroupVersion, configOptions func(config *rest.Config)) (*rest.Config, error)

func WatchRealResources

func WatchRealResources(clientSet NamespacedCRDClientInterface,
	resource, namespace string,
	resyncPeriod time.Duration,
	handlers cache.ResourceEventHandlerFuncs,
	lo metav1.ListOptions) (cache.Store, chan struct{}, error)

Watch RealResources creates.

func WatchResources

func WatchResources(clientSet NamespacedCRDClientInterface,
	resource, namespace string,
	resyncPeriod time.Duration,
	handlers cache.ResourceEventHandlerFuncs,
	lo metav1.ListOptions) (cache.Store, chan struct{}, error)

WatchResources is a wrapper cache function that allows to create either a real cache or a fake one, depending on the global variable Fake.

func WatchfakeResources

func WatchfakeResources(resource string, handlers cache.ResourceEventHandlerFuncs) (cache.Store, chan struct{}, error)

WatchfakeResources creates a Fake custom informer, useful for testing purposes TODO: to implement all the caching functionality, such as resync, filtering, etc.

Types

type CRDClient

type CRDClient struct {
	Store cache.Store
	Stop  chan struct{}
	// contains filtered or unexported fields
}

func NewFromConfig

func NewFromConfig(config *rest.Config) (*CRDClient, error)

func (*CRDClient) Client

func (c *CRDClient) Client() kubernetes.Interface

func (*CRDClient) Config

func (c *CRDClient) Config() *rest.Config

func (*CRDClient) Resource

func (c *CRDClient) Resource(api string) CrdClientInterface

type Client

type Client struct {
	Client rest.Interface
	// contains filtered or unexported fields
}

func (*Client) Create

func (c *Client) Create(obj runtime.Object, opts *metav1.CreateOptions) (runtime.Object, error)

func (*Client) Delete

func (c *Client) Delete(name string, opts *metav1.DeleteOptions) error

func (*Client) Get

func (c *Client) Get(name string, opts *metav1.GetOptions) (runtime.Object, error)

func (*Client) List

func (c *Client) List(opts *metav1.ListOptions) (runtime.Object, error)

func (*Client) Namespace

func (c *Client) Namespace(namespace string) CrdClientInterface

func (*Client) Update

func (c *Client) Update(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)

func (*Client) UpdateStatus

func (c *Client) UpdateStatus(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)

func (*Client) Watch

func (c *Client) Watch(opts *metav1.ListOptions) (watch.Interface, error)

type CrdClientInterface

type CrdClientInterface interface {
	Namespace(namespace string) CrdClientInterface
	List(opts *metav1.ListOptions) (runtime.Object, error)
	Get(name string, opts *metav1.GetOptions) (runtime.Object, error)
	Create(obj runtime.Object, opts *metav1.CreateOptions) (runtime.Object, error)
	Watch(opts *metav1.ListOptions) (watch.Interface, error)
	Update(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)
	UpdateStatus(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)
	Delete(name string, opts *metav1.DeleteOptions) error
}

type FakeClient

type FakeClient struct {
	Client rest.Interface
	// contains filtered or unexported fields
}

func (*FakeClient) Create

func (c *FakeClient) Create(obj runtime.Object, _ *metav1.CreateOptions) (runtime.Object, error)

func (*FakeClient) Delete

func (c *FakeClient) Delete(name string, opts *metav1.DeleteOptions) error

func (*FakeClient) Get

func (c *FakeClient) Get(name string, _ *metav1.GetOptions) (runtime.Object, error)

func (*FakeClient) List

func (c *FakeClient) List(_ *metav1.ListOptions) (runtime.Object, error)

func (*FakeClient) Namespace

func (c *FakeClient) Namespace(namespace string) CrdClientInterface

func (*FakeClient) Update

func (c *FakeClient) Update(name string, obj runtime.Object, _ *metav1.UpdateOptions) (runtime.Object, error)

func (*FakeClient) UpdateStatus

func (c *FakeClient) UpdateStatus(name string, obj runtime.Object, opts *metav1.UpdateOptions) (runtime.Object, error)

func (*FakeClient) Watch

func (c *FakeClient) Watch(_ *metav1.ListOptions) (watch.Interface, error)

type KeyerFunc

type KeyerFunc func(obj runtime.Object) (string, error)

type NamespacedCRDClientInterface

type NamespacedCRDClientInterface interface {
	Resource(resource string) CrdClientInterface
}

type RegistryType

type RegistryType struct {
	SingularType reflect.Type
	PluralType   reflect.Type

	Keyer    KeyerFunc
	Resource schema.GroupResource
}