crd

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 2, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ConfigMapStoreType = reflect.TypeOf((*ConfigMapStore)(nil)).Elem()
View Source
var DeploymentStoreType = reflect.TypeOf((*DeploymentStore)(nil)).Elem()
View Source
var PodStoreType = reflect.TypeOf((*PodStore)(nil)).Elem()
View Source
var ServiceStoreType = reflect.TypeOf((*ServiceStore)(nil)).Elem()

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL