admission

Documentation

Index

• Constants
• type Event
• type EventHandlerFn
• type IWebhookConfig
• type Metadata
• type MutatingWebhookConfig
  • func (c *MutatingWebhookConfig) GetMeta() Metadata
  • func (c *MutatingWebhookConfig) SetClientConfig(cc v1.WebhookClientConfig)
  • func (c *MutatingWebhookConfig) SetMeta(m Metadata)
  • func (c *MutatingWebhookConfig) UpdateIds(confID, webhookID string)
• type MutatingWebhookResource
  • func NewMutatingWebhookResource(opts WebhookResourceOptions) *MutatingWebhookResource
  • func (w *MutatingWebhookResource) Get(id string) *MutatingWebhookConfig
  • func (w *MutatingWebhookResource) Register() error
  • func (w *MutatingWebhookResource) Set(whc *MutatingWebhookConfig)
  • func (w *MutatingWebhookResource) Unregister() error
• type Response
  • func FromReader(r io.Reader) (*Response, error)
  • func ResponseFromBytes(data []byte) (*Response, error)
  • func ResponseFromFile(filePath string) (*Response, error)
  • func (r *Response) Dump() string
• type ValidatingWebhookConfig
  • func (c *ValidatingWebhookConfig) GetMeta() Metadata
  • func (c *ValidatingWebhookConfig) SetClientConfig(cc v1.WebhookClientConfig)
  • func (c *ValidatingWebhookConfig) SetMeta(m Metadata)
  • func (c *ValidatingWebhookConfig) UpdateIds(confID, webhookID string)
• type ValidatingWebhookResource
  • func NewValidatingWebhookResource(opts WebhookResourceOptions) *ValidatingWebhookResource
  • func (w *ValidatingWebhookResource) Get(id string) *ValidatingWebhookConfig
  • func (w *ValidatingWebhookResource) Register() error
  • func (w *ValidatingWebhookResource) Set(whc *ValidatingWebhookConfig)
  • func (w *ValidatingWebhookResource) Unregister() error
• type WebhookHandler
  • func NewWebhookHandler() *WebhookHandler
• type WebhookManager
  • func NewWebhookManager(kubeClient *klient.Client) *WebhookManager
  • func (m *WebhookManager) AddMutatingWebhook(config *MutatingWebhookConfig)
  • func (m *WebhookManager) AddValidatingWebhook(config *ValidatingWebhookConfig)
  • func (m *WebhookManager) Init() error
  • func (m *WebhookManager) Start() error
  • func (m *WebhookManager) WithAdmissionEventHandler(handler EventHandlerFn)
• type WebhookResourceOptions
• type WebhookSettings

Constants

const DefaultConfigurationId = "hooks"

DefaultConfigurationId is a ConfigurationId for ValidatingWebhookConfiguration/MutatingWebhookConfiguration without suffix.

Types

type Event

type Event struct {
	WebhookId       string
	ConfigurationId string
	Request         *v1.AdmissionRequest
}

type EventHandlerFn

type EventHandlerFn func(event Event) (*Response, error)

type IWebhookConfig

type IWebhookConfig interface {
	GetMeta() Metadata
	SetMeta(Metadata)
	SetClientConfig(v1.WebhookClientConfig)
	UpdateIds(string, string)
}

type Metadata

type Metadata struct {
	Name            string
	WebhookId       string
	ConfigurationId string // A suffix to create different ValidatingWebhookConfiguration/MutatingWebhookConfiguration resources.
	DebugName       string
	LogLabels       map[string]string
	MetricLabels    map[string]string
}

type MutatingWebhookConfig

type MutatingWebhookConfig struct {
	*v1.MutatingWebhook
	Metadata
}

func (*MutatingWebhookConfig) GetMeta

func (c *MutatingWebhookConfig) GetMeta() Metadata

func (*MutatingWebhookConfig) SetClientConfig

func (c *MutatingWebhookConfig) SetClientConfig(cc v1.WebhookClientConfig)

func (*MutatingWebhookConfig) SetMeta

func (c *MutatingWebhookConfig) SetMeta(m Metadata)

func (*MutatingWebhookConfig) UpdateIds

func (c *MutatingWebhookConfig) UpdateIds(confID, webhookID string)

type MutatingWebhookResource

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

func NewMutatingWebhookResource

func NewMutatingWebhookResource(opts WebhookResourceOptions) *MutatingWebhookResource

func (*MutatingWebhookResource) Get

func (w *MutatingWebhookResource) Get(id string) *MutatingWebhookConfig

func (*MutatingWebhookResource) Register

func (w *MutatingWebhookResource) Register() error

func (*MutatingWebhookResource) Set

func (w *MutatingWebhookResource) Set(whc *MutatingWebhookConfig)

func (*MutatingWebhookResource) Unregister

func (w *MutatingWebhookResource) Unregister() error

type Response

type Response struct {
	Allowed  bool     `json:"allowed"`
	Message  string   `json:"message,omitempty"`
	Warnings []string `json:"warnings,omitempty"`
	Patch    []byte   `json:"patch,omitempty"`
}

func FromReader

func FromReader(r io.Reader) (*Response, error)

func ResponseFromBytes

func ResponseFromBytes(data []byte) (*Response, error)

func ResponseFromFile

func ResponseFromFile(filePath string) (*Response, error)

func (*Response) Dump

func (r *Response) Dump() string

type ValidatingWebhookConfig

type ValidatingWebhookConfig struct {
	*v1.ValidatingWebhook
	Metadata
}

func (*ValidatingWebhookConfig) GetMeta

func (c *ValidatingWebhookConfig) GetMeta() Metadata

func (*ValidatingWebhookConfig) SetClientConfig

func (c *ValidatingWebhookConfig) SetClientConfig(cc v1.WebhookClientConfig)

func (*ValidatingWebhookConfig) SetMeta

func (c *ValidatingWebhookConfig) SetMeta(m Metadata)

func (*ValidatingWebhookConfig) UpdateIds

func (c *ValidatingWebhookConfig) UpdateIds(confID, webhookID string)

UpdateIds use confId and webhookId to set a ConfigurationId prefix and a WebhookId.

type ValidatingWebhookResource

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

func NewValidatingWebhookResource

func NewValidatingWebhookResource(opts WebhookResourceOptions) *ValidatingWebhookResource

func (*ValidatingWebhookResource) Get

func (w *ValidatingWebhookResource) Get(id string) *ValidatingWebhookConfig

func (*ValidatingWebhookResource) Register

func (w *ValidatingWebhookResource) Register() error

func (*ValidatingWebhookResource) Set

func (w *ValidatingWebhookResource) Set(whc *ValidatingWebhookConfig)

func (*ValidatingWebhookResource) Unregister

func (w *ValidatingWebhookResource) Unregister() error

type WebhookHandler

type WebhookHandler struct {
	Router  chi.Router
	Handler EventHandlerFn
}

func NewWebhookHandler

func NewWebhookHandler() *WebhookHandler

type WebhookManager

type WebhookManager struct {
	KubeClient *klient.Client

	Settings  *WebhookSettings
	Namespace string

	DefaultConfigurationId string

	Server              *server.WebhookServer
	ValidatingResources map[string]*ValidatingWebhookResource
	MutatingResources   map[string]*MutatingWebhookResource
	Handler             *WebhookHandler
}

WebhookManager is a public interface to be used from operator.go.

No dynamic configuration for now. The steps are:

• Init manager
• Call AddWebhook for every binding in hooks
• Start() to run server and create ValidatingWebhookConfiguration/MutatingWebhookConfiguration

func NewWebhookManager

func NewWebhookManager(kubeClient *klient.Client) *WebhookManager

func (*WebhookManager) AddMutatingWebhook

func (m *WebhookManager) AddMutatingWebhook(config *MutatingWebhookConfig)

func (*WebhookManager) AddValidatingWebhook

func (m *WebhookManager) AddValidatingWebhook(config *ValidatingWebhookConfig)

func (*WebhookManager) Init

func (m *WebhookManager) Init() error

Init creates dependencies

func (*WebhookManager) Start

func (m *WebhookManager) Start() error

func (*WebhookManager) WithAdmissionEventHandler

func (m *WebhookManager) WithAdmissionEventHandler(handler EventHandlerFn)

type WebhookResourceOptions

type WebhookResourceOptions struct {
	KubeClient        *klient.Client
	Namespace         string
	ConfigurationName string
	ServiceName       string
	CABundle          []byte
}

type WebhookSettings

type WebhookSettings struct {
	server.Settings
	CAPath               string
	CABundle             []byte
	ConfigurationName    string
	DefaultFailurePolicy string
}