Documentation
¶
Index ¶
- func CreateServiceAccountWithToken(ctx context.Context, clientset kubernetes.Interface, namespace, name string) (*corev1.ServiceAccount, error)
- func MustUnmarshalUnstructured(text string) *unstructured.Unstructured
- func MustUnmarshalWorkflow(text string) *wfv1.Workflow
- type Indexer
- func (i Indexer) Add(any) error
- func (i Indexer) AddIndexers(cache.Indexers) error
- func (i Indexer) ByIndex(indexName, indexedValue string) ([]any, error)
- func (i Indexer) Delete(any) error
- func (i Indexer) Get(any) (item any, exists bool, err error)
- func (i Indexer) GetByKey(key string) (item any, exists bool, err error)
- func (i Indexer) GetIndexers() cache.Indexers
- func (i Indexer) Index(string, any) ([]any, error)
- func (i Indexer) IndexKeys(string, string) ([]string, error)
- func (i Indexer) List() []any
- func (i Indexer) ListIndexFuncValues(string) []string
- func (i Indexer) ListKeys() []string
- func (i Indexer) Replace([]any, string) error
- func (i Indexer) Resync() error
- func (i Indexer) SetByIndex(indexName, indexedValue string, objs ...any)
- func (i Indexer) SetByKey(key string, item any)
- func (i Indexer) Update(any) error
- type SharedIndexInformer
- func (s *SharedIndexInformer) AddEventHandler(cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error)
- func (s *SharedIndexInformer) AddEventHandlerWithOptions(handler cache.ResourceEventHandler, options cache.HandlerOptions) (cache.ResourceEventHandlerRegistration, error)
- func (s *SharedIndexInformer) AddEventHandlerWithResyncPeriod(cache.ResourceEventHandler, time.Duration) (cache.ResourceEventHandlerRegistration, error)
- func (s *SharedIndexInformer) AddIndexers(cache.Indexers) error
- func (s *SharedIndexInformer) GetController() cache.Controller
- func (s *SharedIndexInformer) GetIndexer() cache.Indexer
- func (s *SharedIndexInformer) GetStore() cache.Store
- func (s *SharedIndexInformer) HasSynced() bool
- func (s *SharedIndexInformer) IsStopped() bool
- func (s *SharedIndexInformer) LastSyncResourceVersion() string
- func (s *SharedIndexInformer) RemoveEventHandler(cache.ResourceEventHandlerRegistration) error
- func (s *SharedIndexInformer) Run(<-chan struct{})
- func (s *SharedIndexInformer) RunWithContext(ctx context.Context)
- func (s *SharedIndexInformer) SetTransform(handler cache.TransformFunc) error
- func (s *SharedIndexInformer) SetWatchErrorHandler(handler cache.WatchErrorHandler) error
- func (s *SharedIndexInformer) SetWatchErrorHandlerWithContext(handler cache.WatchErrorHandlerWithContext) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateServiceAccountWithToken ¶
func CreateServiceAccountWithToken(ctx context.Context, clientset kubernetes.Interface, namespace, name string) (*corev1.ServiceAccount, error)
CreateServiceAccountWithToken creates a service account with a given name with a service account token. Need to use this function to simulate the actual behavior of Kubernetes API server with the fake client.
func MustUnmarshalUnstructured ¶
func MustUnmarshalUnstructured(text string) *unstructured.Unstructured
func MustUnmarshalWorkflow ¶
Types ¶
type Indexer ¶
type Indexer struct {
// contains filtered or unexported fields
}
func NewIndexer ¶
func NewIndexer() *Indexer
func (Indexer) GetIndexers ¶
func (Indexer) ListIndexFuncValues ¶
func (Indexer) SetByIndex ¶
type SharedIndexInformer ¶
type SharedIndexInformer struct {
}
func NewSharedIndexInformer ¶
func NewSharedIndexInformer() *SharedIndexInformer
func (*SharedIndexInformer) AddEventHandler ¶
func (s *SharedIndexInformer) AddEventHandler(cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error)
func (*SharedIndexInformer) AddEventHandlerWithOptions ¶
func (s *SharedIndexInformer) AddEventHandlerWithOptions(handler cache.ResourceEventHandler, options cache.HandlerOptions) (cache.ResourceEventHandlerRegistration, error)
func (*SharedIndexInformer) AddEventHandlerWithResyncPeriod ¶
func (s *SharedIndexInformer) AddEventHandlerWithResyncPeriod(cache.ResourceEventHandler, time.Duration) (cache.ResourceEventHandlerRegistration, error)
func (*SharedIndexInformer) AddIndexers ¶
func (s *SharedIndexInformer) AddIndexers(cache.Indexers) error
func (*SharedIndexInformer) GetController ¶
func (s *SharedIndexInformer) GetController() cache.Controller
func (*SharedIndexInformer) GetIndexer ¶
func (s *SharedIndexInformer) GetIndexer() cache.Indexer
func (*SharedIndexInformer) GetStore ¶
func (s *SharedIndexInformer) GetStore() cache.Store
func (*SharedIndexInformer) HasSynced ¶
func (s *SharedIndexInformer) HasSynced() bool
func (*SharedIndexInformer) IsStopped ¶
func (s *SharedIndexInformer) IsStopped() bool
func (*SharedIndexInformer) LastSyncResourceVersion ¶
func (s *SharedIndexInformer) LastSyncResourceVersion() string
func (*SharedIndexInformer) RemoveEventHandler ¶
func (s *SharedIndexInformer) RemoveEventHandler(cache.ResourceEventHandlerRegistration) error
func (*SharedIndexInformer) Run ¶
func (s *SharedIndexInformer) Run(<-chan struct{})
func (*SharedIndexInformer) RunWithContext ¶
func (s *SharedIndexInformer) RunWithContext(ctx context.Context)
func (*SharedIndexInformer) SetTransform ¶
func (s *SharedIndexInformer) SetTransform(handler cache.TransformFunc) error
func (*SharedIndexInformer) SetWatchErrorHandler ¶
func (s *SharedIndexInformer) SetWatchErrorHandler(handler cache.WatchErrorHandler) error
func (*SharedIndexInformer) SetWatchErrorHandlerWithContext ¶
func (s *SharedIndexInformer) SetWatchErrorHandlerWithContext(handler cache.WatchErrorHandlerWithContext) error
Source Files
Click to show internal directories.
Click to hide internal directories.