extension

package module

Go to main page

Versions in this module

v0

v0.3.0

Aug 7, 2020

Changes in this version

+ const LabelAppGUID

+ const LabelProcessType

+ const LabelVersion

+ type Config struct

+ CtxTimeOut time.Duration

+ Fs afero.Fs

+ Namespace string

+ WebhookServerHost string

+ WebhookServerPort int32

type DefaultExtensionManager

+ func (m *DefaultExtensionManager) GetManagerOptions() ManagerOptions

+ func (m *DefaultExtensionManager) LoadExtensions() error

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

type Manager

+ GetManagerOptions func() ManagerOptions

+ SetManagerOptions func(ManagerOptions)

+ Stop func()

type ManagerOptions

+ WatcherStartRV string

+ type WatcherChannelClosedError struct

+ func (e *WatcherChannelClosedError) Error() string

v0.2.0

Nov 12, 2019

Changes in this version

+ const LabelGUID

+ const LabelSourceType

+ func AddToScheme(s *runtime.Scheme) error

+ type DefaultExtensionManager struct

+ Context context.Context

+ Credsgen credsgen.Generator

+ Extensions []Extension

+ KubeManager manager.Manager

+ Logger *zap.SugaredLogger

+ Options ManagerOptions

+ Watchers []Watcher

+ WebhookConfig *WebhookConfig

+ WebhookServer *webhook.Server

+ func (m *DefaultExtensionManager) AddExtension(e Extension)

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

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

+ func (m *DefaultExtensionManager) GenWebHookServer()

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

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

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

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

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

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

+ 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) 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) 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(e Extension)

+ AddWatcher func(w Watcher)

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

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

+ GetLogger func() *zap.SugaredLogger

+ ListExtensions func() []Extension

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

+ RegisterExtensions func() error

+ Start func() error

+ Watch func() error

+ func NewManager(opts ManagerOptions) Manager

+ type ManagerOptions struct

+ 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

+ WebhookNamespace string

+ type MutatingWebhook interface

+ GetFailurePolicy func() admissionregistrationv1beta1.FailurePolicyType

+ GetHandler func() admission.Handler

+ 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 Watcher interface

+ Handle func(Manager, watch.Event)

+ type WebhookConfig struct

+ CaCertificate []byte

+ CaKey []byte

+ CertDir string

+ Certificate []byte

+ ConfigName string

+ Key []byte

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

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

+ type WebhookOptions struct

+ ID string

+ Manager manager.Manager

+ ManagerOptions ManagerOptions

+ MatchLabels map[string]string

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