cli

Documentation

Index

• Constants
• Variables
• func ClearRootEnv()
• func ExecuteUserEditor(original []byte, name string) (edited []byte, err error)
• func GetBinDir() string
• func GetRootDir() string
• func KubeApply(url string) error
• func KubeApplyFromBox(filename string, context string) error
• func KubeApplyReader(reader io.Reader) error
• func KubeCtl(args ...string) error
• func RunBufferedCommand(name string, args ...string) ([]byte, error)
• func RunCommandWithStd(name string, args ...string) error
• func TestSetRootTempdir() string
• type KubeProxy
  • func NewKubeProxy() *KubeProxy
  • func NewKubeProxyForService(kclient client.Client, namespace, service string, port interface{}) (kp *KubeProxy, err error)
  • func (p *KubeProxy) HostWithPort() string
  • func (p *KubeProxy) Start() error
  • func (p *KubeProxy) Stop()
  • func (p *KubeProxy) URL() string
  • func (p *KubeProxy) WaitUntilCanceled()
• type ResourceEditor
  • func NewResourceEditor(kclient client.Client, obj runtime.Object, namespace, name string) *ResourceEditor
  • func (r *ResourceEditor) EditExisting(ignoreNotFound bool) (res controllerutil.OperationResult, err error)
  • func (r *ResourceEditor) UpdateFromFile(filename string) (res controllerutil.OperationResult, err error)

Constants

const (
	ROOT_KEY = "KONSTELLATION_ROOT"
)

Variables

var KubeDisplayOutput = false

Functions

func ClearRootEnv

func ClearRootEnv()

func ExecuteUserEditor

func ExecuteUserEditor(original []byte, name string) (edited []byte, err error)

func GetBinDir

func GetBinDir() string

func GetRootDir

func GetRootDir() string

func KubeApply

func KubeApply(url string) error

func KubeApplyFromBox

func KubeApplyFromBox(filename string, context string) error

func KubeApplyReader

func KubeApplyReader(reader io.Reader) error

func KubeCtl

func KubeCtl(args ...string) error

func RunBufferedCommand

func RunBufferedCommand(name string, args ...string) ([]byte, error)

func RunCommandWithStd

func RunCommandWithStd(name string, args ...string) error

func TestSetRootTempdir

func TestSetRootTempdir() string

Types

type KubeProxy

type KubeProxy struct {
	Namespace   string
	Service     string
	ServicePort int32
	LocalPort   int32
	// contains filtered or unexported fields
}

func NewKubeProxy

func NewKubeProxy() *KubeProxy

func NewKubeProxyForService

func NewKubeProxyForService(kclient client.Client, namespace, service string, port interface{}) (kp *KubeProxy, err error)

func (*KubeProxy) HostWithPort

func (p *KubeProxy) HostWithPort() string

func (*KubeProxy) Start

func (p *KubeProxy) Start() error

func (*KubeProxy) Stop

func (p *KubeProxy) Stop()

func (*KubeProxy) URL

func (p *KubeProxy) URL() string

func (*KubeProxy) WaitUntilCanceled

func (p *KubeProxy) WaitUntilCanceled()

type ResourceEditor

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

func NewResourceEditor

func NewResourceEditor(kclient client.Client, obj runtime.Object, namespace, name string) *ResourceEditor

func (*ResourceEditor) EditExisting

func (r *ResourceEditor) EditExisting(ignoreNotFound bool) (res controllerutil.OperationResult, err error)

func (*ResourceEditor) UpdateFromFile

func (r *ResourceEditor) UpdateFromFile(filename string) (res controllerutil.OperationResult, err error)