observer

Documentation

Index

• type AwaitResourceClient
  • func NewClientForConfigResource(conf *rest.Config, res *metav1.APIResource) (*AwaitResourceClient, error)
  • func (cl *AwaitResourceClient) AwaitResource(res *metav1.APIResource, namespace string, filters []string)
  • func (rc *AwaitResourceClient) Namespace(ns string) dynamic.ResourceInterface

Types

type AwaitResourceClient

type AwaitResourceClient struct {
	Log          *logrus.Logger
	K8RestConfig *rest.Config
	// contains filtered or unexported fields
}

AwaitResourceClient watches for specified resources

func NewClientForConfigResource

func NewClientForConfigResource(conf *rest.Config, res *metav1.APIResource) (*AwaitResourceClient, error)

NewClientForConfigResource returns a new client based on the passed in kubernetes config

func (*AwaitResourceClient) AwaitResource

func (cl *AwaitResourceClient) AwaitResource(res *metav1.APIResource, namespace string, filters []string)

AwaitResource awaits the given resource based on given filters

func (*AwaitResourceClient) Namespace

func (rc *AwaitResourceClient) Namespace(ns string) dynamic.ResourceInterface

Namespace to be watched by the client