crd

Documentation

Index

• Variables
• type ConfigMapStore
• type Controller
  • func NewController[T any](cfg config.Config, restClient rest.Interface, ...) *Controller[T]
  • func (s *Controller[T]) AddEventHandler(addFunc func(obj interface{}), updateFunc func(oldObj, newObj interface{}), ...) *Controller[T]
  • func (s *Controller[T]) InjectStores(sync time.Duration, options ...informers.SharedInformerOption) *ControllerWithStores[T]
  • func (s *Controller[T]) MockDiObj()
  • func (s *Controller[T]) Run()
  • func (s *Controller[T]) Stop()
• type ControllerWithStores
  • func (s *ControllerWithStores[T]) AddEventHandler(addFunc func(obj interface{}, stores *T), ...) *Controller[T]
• type CrdController
• type DeployAndServiceStore
• type DeploymentStore
• type MockStore
  • func (s *MockStore) Add(obj interface{}) error
  • func (s *MockStore) Delete(obj interface{}) error
  • func (s *MockStore) Get(obj interface{}) (item interface{}, exists bool, err error)
  • func (s *MockStore) GetByKey(key string) (item interface{}, exists bool, err error)
  • func (s *MockStore) List() []interface{}
  • func (s *MockStore) ListKeys() []string
  • func (s *MockStore) Replace([]interface{}, string) error
  • func (s *MockStore) Resync() error
  • func (s *MockStore) Update(obj interface{}) error
• type PodStore
• type ServiceStore

Variables

var ConfigMapStoreType = reflect.TypeOf((*ConfigMapStore)(nil)).Elem()

var DeploymentStoreType = reflect.TypeOf((*DeploymentStore)(nil)).Elem()

var PodStoreType = reflect.TypeOf((*PodStore)(nil)).Elem()

var ServiceStoreType = reflect.TypeOf((*ServiceStore)(nil)).Elem()

Types

type ConfigMapStore

type ConfigMapStore cache.Store

type Controller

type Controller[T any] struct {
	CrdController
	// contains filtered or unexported fields
}

func NewController

func NewController[T any](cfg config.Config, restClient rest.Interface, informer cache.SharedIndexInformer) *Controller[T]

func (*Controller[T]) AddEventHandler

func (s *Controller[T]) AddEventHandler(
	addFunc func(obj interface{}),
	updateFunc func(oldObj, newObj interface{}),
	deleteFunc func(obj interface{}),
) *Controller[T]

func (*Controller[T]) InjectStores

func (s *Controller[T]) InjectStores(sync time.Duration, options ...informers.SharedInformerOption) *ControllerWithStores[T]

func (*Controller[T]) MockDiObj

func (s *Controller[T]) MockDiObj()

func (*Controller[T]) Run

func (s *Controller[T]) Run()

func (*Controller[T]) Stop

func (s *Controller[T]) Stop()

type ControllerWithStores

type ControllerWithStores[T any] struct {
	// contains filtered or unexported fields
}

func (*ControllerWithStores[T]) AddEventHandler

func (s *ControllerWithStores[T]) AddEventHandler(
	addFunc func(obj interface{}, stores *T),
	updateFunc func(oldObj, newObj interface{}, stores *T),
	deleteFunc func(obj interface{}, stores *T),
) *Controller[T]

type CrdController

type CrdController interface {
}

type DeployAndServiceStore

type DeployAndServiceStore struct {
	DeployStore  DeploymentStore
	ServiceStore ServiceStore
}

type DeploymentStore

type DeploymentStore cache.Store

type MockStore

type MockStore struct {
	cache.Store
}

func (*MockStore) Add

func (s *MockStore) Add(obj interface{}) error

func (*MockStore) Delete

func (s *MockStore) Delete(obj interface{}) error

func (*MockStore) Get

func (s *MockStore) Get(obj interface{}) (item interface{}, exists bool, err error)

func (*MockStore) GetByKey

func (s *MockStore) GetByKey(key string) (item interface{}, exists bool, err error)

func (*MockStore) List

func (s *MockStore) List() []interface{}

func (*MockStore) ListKeys

func (s *MockStore) ListKeys() []string

func (*MockStore) Replace

func (s *MockStore) Replace([]interface{}, string) error

func (*MockStore) Resync

func (s *MockStore) Resync() error

func (*MockStore) Update

func (s *MockStore) Update(obj interface{}) error

type PodStore

type PodStore cache.Store

type ServiceStore

type ServiceStore cache.Store