sidecarinjector

Documentation

Index

• Constants
• func NewCertificates(serviceName, namespace string) ([]byte, []byte, error)
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, ownclientset clientset.Interface, ...) *Controller
  • func (c *Controller) GetOwnerDeployment(ctx context.Context, ns, name string) (*appsv1.Deployment, error)
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
• type DynamicClient
  • func NewDynamicClient(restConfig *rest.Config, clientset kubernetes.Interface) (*DynamicClient, error)
  • func (d *DynamicClient) Apply(ctx context.Context, client dynamic.ResourceInterface, ...) (*unstructured.Unstructured, error)
  • func (d *DynamicClient) Create(ctx context.Context, client dynamic.ResourceInterface, ...) (*unstructured.Unstructured, error)
  • func (d *DynamicClient) Get(ctx context.Context, client dynamic.ResourceInterface, ...) (*unstructured.Unstructured, error)
  • func (d *DynamicClient) ResourceClient(data []byte, obj *unstructured.Unstructured) (dynamic.ResourceInterface, error)

Constants

const (
	WebhookServerLabelKey   = "sidecarinjectors.operator.h3poteto.dev"
	WebhookServerLabelValue = "webhook-pod"
)

const MutatingNamePrefix = "sidecar-injector-webhook-"

Functions

func NewCertificates

func NewCertificates(serviceName, namespace string) ([]byte, []byte, error)

Types

type Controller

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

func NewController

func NewController(
	kubeclientset kubernetes.Interface,
	ownclientset clientset.Interface,
	dynamicClient *DynamicClient,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	ownInformerFactory informers.SharedInformerFactory,
	useCertManager bool,
) *Controller

func (*Controller) GetOwnerDeployment

func (c *Controller) GetOwnerDeployment(ctx context.Context, ns, name string) (*appsv1.Deployment, error)

GetOwnerDeployment gets a deployment which owns the pod.

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

type DynamicClient

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

func NewDynamicClient

func NewDynamicClient(restConfig *rest.Config, clientset kubernetes.Interface) (*DynamicClient, error)

func (*DynamicClient) Apply

func (d *DynamicClient) Apply(ctx context.Context, client dynamic.ResourceInterface, obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

func (*DynamicClient) Create

func (d *DynamicClient) Create(ctx context.Context, client dynamic.ResourceInterface, obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

func (*DynamicClient) Get

func (d *DynamicClient) Get(ctx context.Context, client dynamic.ResourceInterface, obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

func (*DynamicClient) ResourceClient

func (d *DynamicClient) ResourceClient(data []byte, obj *unstructured.Unstructured) (dynamic.ResourceInterface, error)