Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

extension

package module

Go to main page

Versions in this module

v0

v0.5.0

Jan 28, 2021

v0.4.0

Oct 5, 2020

Changes in this version

+ const LabelAppGUID

+ const LabelGUID

+ const LabelProcessType

+ const LabelSourceType

+ const LabelVersion

+ func AddToScheme(s *runtime.Scheme) error

+ type Config struct

+ CtxTimeOut time.Duration

+ Fs afero.Fs

+ Namespace string

+ WebhookServerHost string

+ WebhookServerPort int32

+ type DefaultExtensionManager struct

+ Context context.Context

+ Credsgen credsgen.Generator

+ Extensions []Extension

+ KubeManager manager.Manager

+ Logger *zap.SugaredLogger

+ Options ManagerOptions

+ Reconcilers []Reconciler

+ Watchers []Watcher

+ WebhookConfig *WebhookConfig

+ WebhookServer *webhook.Server

+ func (m *DefaultExtensionManager) AddExtension(v interface{}) error

+ func (m *DefaultExtensionManager) AddReconciler(r Reconciler)

+ func (m *DefaultExtensionManager) AddWatcher(w Watcher)

+ func (m *DefaultExtensionManager) GenWatcher(client corev1client.CoreV1Interface) (watch.Interface, error)

+ func (m *DefaultExtensionManager) GenWebHookServer()

+ func (m *DefaultExtensionManager) GetContext() context.Context

+ func (m *DefaultExtensionManager) GetKubeClient() (corev1client.CoreV1Interface, error)

+ func (m *DefaultExtensionManager) GetKubeConnection() (*rest.Config, error)

+ func (m *DefaultExtensionManager) GetKubeManager() manager.Manager

+ func (m *DefaultExtensionManager) GetLogger() *zap.SugaredLogger

+ func (m *DefaultExtensionManager) GetManagerOptions() ManagerOptions

+ func (m *DefaultExtensionManager) HandleEvent(e watch.Event)

+ func (m *DefaultExtensionManager) ListExtensions() []Extension

+ func (m *DefaultExtensionManager) ListReconcilers() []Reconciler

+ func (m *DefaultExtensionManager) ListWatchers() []Watcher

+ func (m *DefaultExtensionManager) LoadExtensions() error

+ func (m *DefaultExtensionManager) OperatorSetup() error

+ func (m *DefaultExtensionManager) PatchFromPod(req admission.Request, pod *corev1.Pod) admission.Response

+ func (m *DefaultExtensionManager) ReadWatcherEvent(w watch.Interface)

+ func (m *DefaultExtensionManager) RegisterExtensions() error

+ func (m *DefaultExtensionManager) SetKubeClient(c corev1client.CoreV1Interface)

+ func (m *DefaultExtensionManager) SetKubeConnection(c *rest.Config)

+ func (m *DefaultExtensionManager) SetManagerOptions(o ManagerOptions)

+ func (m *DefaultExtensionManager) Start() error

+ func (m *DefaultExtensionManager) Stop()

+ func (m *DefaultExtensionManager) Watch() error

+ type DefaultMutatingWebhook struct

+ EiriniExtension Extension

+ EiriniExtensionManager Manager

+ FailurePolicy admissionregistrationv1beta1.FailurePolicyType

+ FilterEiriniApps bool

+ Handler admission.Handler

+ Name string

+ NamespaceSelector *metav1.LabelSelector

+ Path string

+ Rules []admissionregistrationv1beta1.RuleWithOperations

+ Webhook *webhook.Admission

+ func (w *DefaultMutatingWebhook) GetFailurePolicy() admissionregistrationv1beta1.FailurePolicyType

+ func (w *DefaultMutatingWebhook) GetHandler() admission.Handler

+ func (w *DefaultMutatingWebhook) GetLabelSelector() *metav1.LabelSelector

+ func (w *DefaultMutatingWebhook) GetName() string

+ func (w *DefaultMutatingWebhook) GetNamespaceSelector() *metav1.LabelSelector

+ func (w *DefaultMutatingWebhook) GetPath() string

+ func (w *DefaultMutatingWebhook) GetPod(req admission.Request) (*corev1.Pod, error)

+ func (w *DefaultMutatingWebhook) GetRules() []admissionregistrationv1beta1.RuleWithOperations

+ func (w *DefaultMutatingWebhook) GetWebhook() *webhook.Admission

+ func (w *DefaultMutatingWebhook) Handle(ctx context.Context, req admission.Request) admission.Response

+ func (w *DefaultMutatingWebhook) InjectClient(c client.Client) error

+ func (w *DefaultMutatingWebhook) InjectDecoder(d *admission.Decoder) error

+ func (w *DefaultMutatingWebhook) RegisterAdmissionWebHook(server *webhook.Server, opts WebhookOptions) error

+ type Extension interface

+ Handle func(context.Context, Manager, *corev1.Pod, admission.Request) admission.Response

+ type Manager interface

+ AddExtension func(v interface{}) error

+ AddReconciler func(r Reconciler)

+ AddWatcher func(w Watcher)

+ GetContext func() context.Context

+ GetKubeClient func() (corev1client.CoreV1Interface, error)

+ GetKubeConnection func() (*rest.Config, error)

+ GetKubeManager func() manager.Manager

+ GetLogger func() *zap.SugaredLogger

+ GetManagerOptions func() ManagerOptions

+ ListExtensions func() []Extension

+ ListReconcilers func() []Reconciler

+ PatchFromPod func(req admission.Request, pod *corev1.Pod) admission.Response

+ RegisterExtensions func() error

+ SetManagerOptions func(ManagerOptions)

+ Start func() error

+ Stop func()

+ Watch func() error

+ func NewManager(opts ManagerOptions) Manager

+ type ManagerOptions struct

+ Context *context.Context

+ FailurePolicy *admissionregistrationv1beta1.FailurePolicyType

+ FilterEiriniApps *bool

+ Host string

+ KubeConfig string

+ Logger *zap.SugaredLogger

+ Namespace string

+ OperatorFingerprint string

+ Port int32

+ RegisterWebHook *bool

+ ServiceName string

+ SetupCertificate *bool

+ SetupCertificateName string

+ WatcherStartRV string

+ WebhookNamespace string

+ type MutatingWebhook interface

+ GetFailurePolicy func() admissionregistrationv1beta1.FailurePolicyType

+ GetHandler func() admission.Handler

+ GetLabelSelector func() *metav1.LabelSelector

+ GetName func() string

+ GetNamespaceSelector func() *metav1.LabelSelector

+ GetPath func() string

+ GetRules func() []admissionregistrationv1beta1.RuleWithOperations

+ GetWebhook func() *webhook.Admission

+ Handle func(context.Context, admission.Request) admission.Response

+ InjectClient func(c client.Client) error

+ InjectDecoder func(d *admission.Decoder) error

+ RegisterAdmissionWebHook func(*webhook.Server, WebhookOptions) error

+ func NewWebhook(e Extension, m Manager) MutatingWebhook

+ type Reconciler interface

+ Reconcile func(request reconcile.Request) (reconcile.Result, error)

+ Register func(Manager) error

+ type Watcher interface

+ Handle func(Manager, watch.Event)

+ type WatcherChannelClosedError struct

+ func (e *WatcherChannelClosedError) Error() string

+ type WebhookConfig struct

+ CaCertificate []byte

+ CaKey []byte

+ CertDir string

+ Certificate []byte

+ ConfigName string

+ Key []byte

+ func NewWebhookConfig(c client.Client, config *Config, generator credsgen.Generator, ...) *WebhookConfig

+ func (f *WebhookConfig) GenerateAdmissionWebhook(webhooks []MutatingWebhook) []admissionregistrationv1beta1.MutatingWebhook

+ type WebhookOptions struct

+ ID string

+ Manager manager.Manager

+ ManagerOptions ManagerOptions

+ MatchLabels map[string]string

v0.0.0

May 31, 2019