k8s

Documentation

Index

• Constants
• func GetGVRFromResource(discoveryMapper *restmapper.DeferredDiscoveryRESTMapper, resource string) (schema.GroupVersionResource, error)
• func NewKubeConfig() clientcmd.ClientConfig
• type Client
  • func NewClient(config *rest.Config) (*Client, error)
• type Controller
  • func NewController(resource port.AggregatedResource, informer informers.GenericInformer, ...) *Controller
  • func (c *Controller) RunEventsSync(workers int, stopCh <-chan struct{})
  • func (c *Controller) RunInitialSync() *SyncResult
  • func (c *Controller) Shutdown()
  • func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) error
• type EventActionType
• type EventItem
• type SyncResult

Constants

const (
	CreateAction             EventActionType = "create"
	UpdateAction             EventActionType = "update"
	DeleteAction             EventActionType = "delete"
	MaxNumRequeues           int             = 4
	MaxRawDataExamplesToSend                 = 5
)

Functions

func GetGVRFromResource

func GetGVRFromResource(discoveryMapper *restmapper.DeferredDiscoveryRESTMapper, resource string) (schema.GroupVersionResource, error)

func NewKubeConfig

func NewKubeConfig() clientcmd.ClientConfig

Types

type Client

type Client struct {
	DiscoveryClient    *discovery.DiscoveryClient
	DynamicClient      dynamic.Interface
	DiscoveryMapper    *restmapper.DeferredDiscoveryRESTMapper
	ApiExtensionClient *apiextensions.ApiextensionsV1Client
}

func NewClient

func NewClient(config *rest.Config) (*Client, error)

type Controller

type Controller struct {
	Resource port.AggregatedResource
	// contains filtered or unexported fields
}

func NewController

func NewController(resource port.AggregatedResource, informer informers.GenericInformer, integrationConfig *port.IntegrationAppConfig, applicationConfig *config.ApplicationConfiguration) *Controller

func (*Controller) RunEventsSync

func (c *Controller) RunEventsSync(workers int, stopCh <-chan struct{})

func (*Controller) RunInitialSync

func (c *Controller) RunInitialSync() *SyncResult

func (*Controller) Shutdown

func (c *Controller) Shutdown()

func (*Controller) WaitForCacheSync

func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) error

type EventActionType

type EventActionType string

type EventItem

type EventItem struct {
	Key        string
	ActionType EventActionType
}

type SyncResult

type SyncResult struct {
	EntitiesSet               map[string]interface{}
	RawDataExamples           []interface{}
	ShouldDeleteStaleEntities bool
}