kubernetes

Documentation

Index

• func Config() *rest.Config
• func CreateOrUpdateGateway(ctx context.Context, clientset *kubernetes.Clientset, config *rest.Config, ...) error
• func DynamicKubernetesClient() (*dynamic.DynamicClient, error)
• func GetDeployment(ctx context.Context) (*model.Deployment, error)
• func GetGateways(ctx context.Context, config *rest.Config, namespace string) ([]*istionetworking.Gateway, error)
• func GetVirtualService(ctx context.Context, config *rest.Config, namespace string) ([]*istionetworking.VirtualService, error)
• func KubernetesClient() (*kubernetes.Clientset, error)

Functions

func Config

func Config() *rest.Config

func CreateOrUpdateGateway

func CreateOrUpdateGateway(ctx context.Context, clientset *kubernetes.Clientset, config *rest.Config, gateway *istionetworking.Gateway) error

func DynamicKubernetesClient

func DynamicKubernetesClient() (*dynamic.DynamicClient, error)

func GetDeployment

func GetDeployment(ctx context.Context) (*model.Deployment, error)

GetDeployment returns the deployment object from the kapeta secret in the cluster, this is the latest version deployed

func GetGateways

func GetGateways(ctx context.Context, config *rest.Config, namespace string) ([]*istionetworking.Gateway, error)

func GetVirtualService

func GetVirtualService(ctx context.Context, config *rest.Config, namespace string) ([]*istionetworking.VirtualService, error)

func KubernetesClient

func KubernetesClient() (*kubernetes.Clientset, error)

KubernetesClient returns a kubernetes client either from the cluster or from the local config if we are not running in a cluster