kubectl

Documentation

Index

• Constants
• func ResourceKubectlManifestApply(ctx context.Context, yaml string, waitForRolout bool, ...) (string, error)
• func ResourceKubectlManifestDelete(ctx context.Context, yaml string, wait bool, kubeProvider *KubeProvider) error
• func ResourceKubectlManifestRead(ctx context.Context, yaml string, meta interface{}) (bool, error)
• type KubeProvider
  • func (p *KubeProvider) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
  • func (p *KubeProvider) ToRESTConfig() (*rest.Config, error)
  • func (p *KubeProvider) ToRESTMapper() (meta.RESTMapper, error)
  • func (p *KubeProvider) ToRawKubeConfigLoader() clientcmd.ClientConfig
• type RestClientResult
  • func RestClientResultFromErr(err error) *RestClientResult
  • func RestClientResultFromInvalidTypeErr(err error) *RestClientResult
  • func RestClientResultSuccess(resourceInterface dynamic.ResourceInterface) *RestClientResult
• type RestClientStatus
• type UnstructuredManifest
  • func (m *UnstructuredManifest) String() string

Constants

const (
	RestClientOk = iota
	RestClientGenericError
	RestClientInvalidTypeError
)

const (
	// https://github.com/kubernetes/kubernetes/blob/master/pkg/controller/deployment/util/deployment_util.go#L93
	TimedOutReason = "ProgressDeadlineExceeded"
)

Functions

func ResourceKubectlManifestApply

func ResourceKubectlManifestApply(ctx context.Context, yaml string, waitForRolout bool, kubeProvider *KubeProvider) (string, error)

func ResourceKubectlManifestDelete

func ResourceKubectlManifestDelete(ctx context.Context, yaml string, wait bool, kubeProvider *KubeProvider) error

func ResourceKubectlManifestRead

func ResourceKubectlManifestRead(ctx context.Context, yaml string, meta interface{}) (bool, error)

Types

type KubeProvider

type KubeProvider struct {
	MainClientset       *kubernetes.Clientset
	RestConfig          rest.Config
	AggregatorClientset *aggregator.Clientset
}

func (*KubeProvider) ToDiscoveryClient

func (p *KubeProvider) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

func (*KubeProvider) ToRESTConfig

func (p *KubeProvider) ToRESTConfig() (*rest.Config, error)

func (*KubeProvider) ToRESTMapper

func (p *KubeProvider) ToRESTMapper() (meta.RESTMapper, error)

func (*KubeProvider) ToRawKubeConfigLoader

func (p *KubeProvider) ToRawKubeConfigLoader() clientcmd.ClientConfig

type RestClientResult

type RestClientResult struct {
	ResourceInterface dynamic.ResourceInterface
	Error             error
	Status            RestClientStatus
}

func RestClientResultFromErr

func RestClientResultFromErr(err error) *RestClientResult

func RestClientResultFromInvalidTypeErr

func RestClientResultFromInvalidTypeErr(err error) *RestClientResult

func RestClientResultSuccess

func RestClientResultSuccess(resourceInterface dynamic.ResourceInterface) *RestClientResult

type RestClientStatus

type RestClientStatus int

type UnstructuredManifest

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

func (*UnstructuredManifest) String

func (m *UnstructuredManifest) String() string