opslevel_k8s_controller

Apr 26, 2024

Changes in this version

type K8SFilter

+ func (f *K8SFilter) MatchesFilter(data any) bool

+ func (f *K8SFilter) MatchesNamespace(data any) bool

+ type K8SResource struct

+ Metadata v1.ObjectMeta

Jan 13, 2024

Changes in this version

+ const ReleaseVersion

+ type K8SClient struct

+ Client kubernetes.Interface

+ Dynamic dynamic.Interface

+ Mapper *restmapper.DeferredDiscoveryRESTMapper

+ func NewK8SClient() (*K8SClient, error)

+ func (c *K8SClient) GetAllNamespaces() ([]string, error)

+ func (c *K8SClient) GetGVR(selector K8SSelector) (*schema.GroupVersionResource, error)

+ func (c *K8SClient) GetInformerFactory(resync time.Duration) dynamicinformer.DynamicSharedInformerFactory

+ func (c *K8SClient) GetMapping(selector K8SSelector) (*meta.RESTMapping, error)

+ func (c *K8SClient) GetNamespaces(selector K8SSelector) ([]string, error)

+ func (c *K8SClient) Query(selector K8SSelector) (output []unstructured.Unstructured, err error)

+ type K8SController struct

+ OnAdd K8SControllerHandler

+ OnDelete K8SControllerHandler

+ OnUpdate K8SControllerHandler

+ func NewK8SController(selector K8SSelector, resyncInterval time.Duration) (*K8SController, error)

+ func (c *K8SController) Start(wg *sync.WaitGroup)

+ type K8SControllerEventType string

+ const ControllerEventTypeCreate

+ const ControllerEventTypeDelete

+ const ControllerEventTypeUpdate

+ type K8SControllerHandler func(interface{})

+ type K8SEvent struct

+ Key string

+ Type K8SControllerEventType

+ type K8SFilter struct

+ func NewK8SFilter(selector K8SSelector) *K8SFilter

+ func (f *K8SFilter) Matches(data any) bool

+ type K8SSelector struct

+ ApiVersion string

+ Excludes []string

+ Kind string

+ Labels []string

+ Namespaces []string

+ func (selector *K8SSelector) GetListOptions() metav1.ListOptions

+ func (selector *K8SSelector) LabelSelector() string