k8s

Documentation

Index

• Variables
• func ApplyManifestFromString(cfg *rest.Config, manifest []byte, fieldManager string) error
• func CanWatchVolume(path string) bool
• func EnsureCRD(config *rest.Config, crd []*apiextensionsv1.CustomResourceDefinition, ...) error
• func FindMountPath(path string) (string, error)
• func GetClusterDomain() (string, error)
• func LoadUnstructuredFromString(manifest []byte) ([]*unstructured.Unstructured, error)
• func ReadCRDFile(fileName string) ([]*apiextensionsv1.CustomResourceDefinition, error)
• func WaitForReadyWebhook(cfg *rest.Config, crds []*apiextensionsv1.CustomResourceDefinition) error
• type Objects
  • func (k Objects) Apply(cfg *rest.Config, fieldManager string) error
  • func (k Objects) SelectCustomResourceDefinitions() ([]*apiextensionsv1.CustomResourceDefinition, error)
• type VolumeWatcher
  • func NewVolumeWatcher(mountPath string, fn func()) (*VolumeWatcher, error)
  • func (w *VolumeWatcher) Stop()

Variables

var (
	ResolvFile = "/etc/resolv.conf"
)

Functions

func ApplyManifestFromString

func ApplyManifestFromString(cfg *rest.Config, manifest []byte, fieldManager string) error

func CanWatchVolume

func CanWatchVolume(path string) bool

func EnsureCRD

func EnsureCRD(config *rest.Config, crd []*apiextensionsv1.CustomResourceDefinition, timeout time.Duration) error

func FindMountPath

func FindMountPath(path string) (string, error)

func GetClusterDomain

func GetClusterDomain() (string, error)

func LoadUnstructuredFromString

func LoadUnstructuredFromString(manifest []byte) ([]*unstructured.Unstructured, error)

func ReadCRDFile

func ReadCRDFile(fileName string) ([]*apiextensionsv1.CustomResourceDefinition, error)

func WaitForReadyWebhook

func WaitForReadyWebhook(cfg *rest.Config, crds []*apiextensionsv1.CustomResourceDefinition) error

Types

type Objects

type Objects []*unstructured.Unstructured

func (Objects) Apply

func (k Objects) Apply(cfg *rest.Config, fieldManager string) error

func (Objects) SelectCustomResourceDefinitions

func (k Objects) SelectCustomResourceDefinitions() ([]*apiextensionsv1.CustomResourceDefinition, error)

type VolumeWatcher

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

func NewVolumeWatcher

func NewVolumeWatcher(mountPath string, fn func()) (*VolumeWatcher, error)

func (*VolumeWatcher) Stop

func (w *VolumeWatcher) Stop()