k8s

func CreateOrUpdateCRD ¶

func CreateOrUpdateCRD(
	clientset apiextensionsclient.Interface,
	crd *apiextensionsv1beta1.CustomResourceDefinition,
) error

func InClusterConfig ¶

func InClusterConfig() (*rest.Config, error)

func IsKubernetesResourceAlreadyExistError ¶

func IsKubernetesResourceAlreadyExistError(err error) bool

func IsKubernetesResourceNotFoundError ¶

func IsKubernetesResourceNotFoundError(err error) bool

func MarshalToYaml ¶

func MarshalToYaml(obj runtime.Object, gv schema.GroupVersion) ([]byte, error)

MarshalToYaml marshals an object into yaml.

func MarshalToYamlForCodecs ¶

func MarshalToYamlForCodecs(obj runtime.Object, gv schema.GroupVersion, codecs serializer.CodecFactory) ([]byte, error)

MarshalToYamlForCodecs marshals an object into yaml using the specified codec

func MustNewKubeExtClient ¶

func MustNewKubeExtClient() apiextensionsclient.Interface

func UnmarshalFromYaml ¶

func UnmarshalFromYaml(buffer []byte, gv schema.GroupVersion) (runtime.Object, error)

UnmarshalFromYaml unmarshals yaml into an object.

func UnmarshalFromYamlForCodecs ¶

func UnmarshalFromYamlForCodecs(buffer []byte, gv schema.GroupVersion, codecs serializer.CodecFactory) (runtime.Object, error)

UnmarshalFromYamlForCodecs unmarshals yaml into an object using the specified codec TODO: Is specifying the gv really needed here? TODO: Can we support json out of the box easily here?

func WaitCRDReady ¶

func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error