kubernetes

Documentation

Index

• type Infra
  • func NewInfra(cli client.Client, cfg *config.Server) *Infra
  • func (i *Infra) CreateOrUpdateProxyInfra(ctx context.Context, infra *ir.Infra) error
  • func (i *Infra) CreateOrUpdateRateLimitInfra(ctx context.Context) error
  • func (i *Infra) DeleteProxyInfra(ctx context.Context, infra *ir.Infra) error
  • func (i *Infra) DeleteRateLimitInfra(ctx context.Context) error
• type InfraClient
  • func New(cli client.Client) *InfraClient
  • func (cli *InfraClient) Delete(ctx context.Context, object client.Object) error
  • func (cli *InfraClient) GetUID(ctx context.Context, key client.ObjectKey, current client.Object) (types.UID, error)
  • func (cli *InfraClient) ServerSideApply(ctx context.Context, obj client.Object) error
• type ResourceRender

Types

type Infra

type Infra struct {
	// Namespace is the Namespace used for managed infra.
	Namespace string

	// EnvoyGateway is the configuration used to startup Envoy Gateway.
	EnvoyGateway *egv1a1.EnvoyGateway

	// Client wrap k8s client.
	Client *InfraClient
}

Infra manages the creation and deletion of Kubernetes infrastructure based on Infra IR resources.

func NewInfra

func NewInfra(cli client.Client, cfg *config.Server) *Infra

NewInfra returns a new Infra.

func (*Infra) CreateOrUpdateProxyInfra

func (i *Infra) CreateOrUpdateProxyInfra(ctx context.Context, infra *ir.Infra) error

CreateOrUpdateProxyInfra creates the managed kube infra, if it doesn't exist.

func (*Infra) CreateOrUpdateRateLimitInfra

func (i *Infra) CreateOrUpdateRateLimitInfra(ctx context.Context) error

CreateOrUpdateRateLimitInfra creates the managed kube rate limit infra, if it doesn't exist.

func (*Infra) DeleteProxyInfra

func (i *Infra) DeleteProxyInfra(ctx context.Context, infra *ir.Infra) error

DeleteProxyInfra removes the managed kube infra, if it doesn't exist.

func (*Infra) DeleteRateLimitInfra

func (i *Infra) DeleteRateLimitInfra(ctx context.Context) error

DeleteRateLimitInfra removes the managed kube infra, if it doesn't exist.

type InfraClient

type InfraClient struct {
	client.Client
}

func New

func New(cli client.Client) *InfraClient

func (*InfraClient) Delete

func (cli *InfraClient) Delete(ctx context.Context, object client.Object) error

func (*InfraClient) GetUID

func (cli *InfraClient) GetUID(ctx context.Context, key client.ObjectKey, current client.Object) (types.UID, error)

GetUID retrieves the uid of one resource.

func (*InfraClient) ServerSideApply

func (cli *InfraClient) ServerSideApply(ctx context.Context, obj client.Object) error

type ResourceRender

type ResourceRender interface {
	Name() string
	LabelSelector() labels.Selector
	ServiceAccount() (*corev1.ServiceAccount, error)
	Service() (*corev1.Service, error)
	ConfigMap() (*corev1.ConfigMap, error)
	Deployment() (*appsv1.Deployment, error)
	DeploymentSpec() (*egv1a1.KubernetesDeploymentSpec, error)
	DaemonSet() (*appsv1.DaemonSet, error)
	DaemonSetSpec() (*egv1a1.KubernetesDaemonSetSpec, error)
	HorizontalPodAutoscaler() (*autoscalingv2.HorizontalPodAutoscaler, error)
	HorizontalPodAutoscalerSpec() (*egv1a1.KubernetesHorizontalPodAutoscalerSpec, error)
	PodDisruptionBudget() (*policyv1.PodDisruptionBudget, error)
	PodDisruptionBudgetSpec() (*egv1a1.KubernetesPodDisruptionBudgetSpec, error)
}

ResourceRender renders Kubernetes infrastructure resources based on Infra IR resources.