util

Documentation

Index

• func CreateServiceAccountWithToken(ctx context.Context, clientset kubernetes.Interface, ...) (*corev1.ServiceAccount, error)
• func MustMarshallJSON(v interface{}) string
• func MustUnmarshallJSON(text string, v interface{})
• func MustUnmarshallUnstructured(text string) *unstructured.Unstructured
• func MustUnmarshallWorkflow(text string) *wfv1.Workflow
• func MustUnmarshallYAML(text string, v interface{})
• type Indexer
  • func NewIndexer() *Indexer
  • func (i Indexer) Add(interface{}) error
  • func (i Indexer) AddIndexers(cache.Indexers) error
  • func (i Indexer) ByIndex(indexName, indexedValue string) ([]interface{}, error)
  • func (i Indexer) Delete(interface{}) error
  • func (i Indexer) Get(interface{}) (item interface{}, exists bool, err error)
  • func (i Indexer) GetByKey(key string) (item interface{}, exists bool, err error)
  • func (i Indexer) GetIndexers() cache.Indexers
  • func (i Indexer) Index(string, interface{}) ([]interface{}, error)
  • func (i Indexer) IndexKeys(string, string) ([]string, error)
  • func (i Indexer) List() []interface{}
  • func (i Indexer) ListIndexFuncValues(string) []string
  • func (i Indexer) ListKeys() []string
  • func (i Indexer) Replace([]interface{}, string) error
  • func (i Indexer) Resync() error
  • func (i Indexer) SetByIndex(indexName, indexedValue string, objs ...interface{})
  • func (i Indexer) SetByKey(key string, item interface{})
  • func (i Indexer) Update(interface{}) error
• type SharedIndexInformer
  • func NewSharedIndexInformer() *SharedIndexInformer
  • func (s *SharedIndexInformer) AddEventHandler(cache.ResourceEventHandler)
  • func (s *SharedIndexInformer) AddEventHandlerWithResyncPeriod(cache.ResourceEventHandler, time.Duration)
  • 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) LastSyncResourceVersion() string
  • func (s *SharedIndexInformer) Run(<-chan struct{})
  • func (s *SharedIndexInformer) SetWatchErrorHandler(handler cache.WatchErrorHandler) error

Functions

func CreateServiceAccountWithToken

func CreateServiceAccountWithToken(ctx context.Context, clientset kubernetes.Interface, namespace, name, tokenName 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 MustMarshallJSON

func MustMarshallJSON(v interface{}) string

func MustUnmarshallJSON

func MustUnmarshallJSON(text string, v interface{})

func MustUnmarshallUnstructured

func MustUnmarshallUnstructured(text string) *unstructured.Unstructured

func MustUnmarshallWorkflow

func MustUnmarshallWorkflow(text string) *wfv1.Workflow

func MustUnmarshallYAML

func MustUnmarshallYAML(text string, v interface{})

Types

type Indexer

type Indexer struct {
	// contains filtered or unexported fields
}

func NewIndexer

func NewIndexer() *Indexer

func (Indexer) Add

func (i Indexer) Add(interface{}) error

func (Indexer) AddIndexers

func (i Indexer) AddIndexers(cache.Indexers) error

func (Indexer) ByIndex

func (i Indexer) ByIndex(indexName, indexedValue string) ([]interface{}, error)

func (Indexer) Delete

func (i Indexer) Delete(interface{}) error

func (Indexer) Get

func (i Indexer) Get(interface{}) (item interface{}, exists bool, err error)

func (Indexer) GetByKey

func (i Indexer) GetByKey(key string) (item interface{}, exists bool, err error)

func (Indexer) GetIndexers

func (i Indexer) GetIndexers() cache.Indexers

func (Indexer) Index

func (i Indexer) Index(string, interface{}) ([]interface{}, error)

func (Indexer) IndexKeys

func (i Indexer) IndexKeys(string, string) ([]string, error)

func (Indexer) List

func (i Indexer) List() []interface{}

func (Indexer) ListIndexFuncValues

func (i Indexer) ListIndexFuncValues(string) []string

func (Indexer) ListKeys

func (i Indexer) ListKeys() []string

func (Indexer) Replace

func (i Indexer) Replace([]interface{}, string) error

func (Indexer) Resync

func (i Indexer) Resync() error

func (Indexer) SetByIndex

func (i Indexer) SetByIndex(indexName, indexedValue string, objs ...interface{})

func (Indexer) SetByKey

func (i Indexer) SetByKey(key string, item interface{})

func (Indexer) Update

func (i Indexer) Update(interface{}) error

type SharedIndexInformer

type SharedIndexInformer struct {
	Indexer *Indexer
}

func NewSharedIndexInformer

func NewSharedIndexInformer() *SharedIndexInformer

func (*SharedIndexInformer) AddEventHandler

func (s *SharedIndexInformer) AddEventHandler(cache.ResourceEventHandler)

func (*SharedIndexInformer) AddEventHandlerWithResyncPeriod

func (s *SharedIndexInformer) AddEventHandlerWithResyncPeriod(cache.ResourceEventHandler, time.Duration)

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) LastSyncResourceVersion

func (s *SharedIndexInformer) LastSyncResourceVersion() string

func (*SharedIndexInformer) Run

func (s *SharedIndexInformer) Run(<-chan struct{})

func (*SharedIndexInformer) SetWatchErrorHandler

func (s *SharedIndexInformer) SetWatchErrorHandler(handler cache.WatchErrorHandler) error