k8s_crd

Documentation

Index

• type Client
  • func NewK8sCRDClient(groupName, groupVersion, namespace string, handlers ...ListenerHandler) (*Client, error)
  • func (c *Client) WatchResources() []cache.Store
• type ListenerHandler

Types

type Client

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

func NewK8sCRDClient

func NewK8sCRDClient(groupName, groupVersion, namespace string, handlers ...ListenerHandler) (*Client, error)

NewK8sCRDClient create an K8sCRD client, for target CRD objects: @objects with given @groupname, @groupVersion, @namespace list and watchFunction would be called by k8s informer

func (*Client) WatchResources

func (c *Client) WatchResources() []cache.Store

func (c *Client) WatchResources() []cache.Store { can only be called once

type ListenerHandler

type ListenerHandler interface {
	AddFunc(obj interface{})
	UpdateFunc(oldObj interface{}, newObj interface{})
	DeleteFunc(obj interface{})
	Watch(opts v1.ListOptions, restClient *rest.RESTClient, ns string) (watch.Interface, error)
	List(opts v1.ListOptions, restClient *rest.RESTClient, ns string) (runtime.Object, error)
	GetObject() runtime.Object
}

nolint