k8s

Documentation

Index

• Constants
• func Apply(path, namespace string) error
• func Copy(path, namespace, destination string, source bool) error
• func GetK8SClientFlavor() string
• func IsJarPresent(podName string) bool
• type Client
  • func GetClient() *Client
  • func (c *Client) ExecCMDInContainer(podName string, cmd []string, stdout io.Writer, stderr io.Writer, ...) error
  • func (c *Client) ExecCommand(podName string, cmd []string, statusMsg string) error
  • func (c *Client) WaitForComponent(name string, desiredPhase string, waitMessage string) (*v1beta1.Component, error)

Constants

const (
	JarPathInContainer             = "/deployments/"
	SourcePathInContainer          = "/usr/src/component.tar"
	ExtractedSourcePathInContainer = "/usr/src"
)

Functions

func Apply

func Apply(path, namespace string) error

func Copy

func Copy(path, namespace, destination string, source bool) error

func GetK8SClientFlavor

func GetK8SClientFlavor() string

func IsJarPresent

func IsJarPresent(podName string) bool

Types

type Client

type Client struct {
	KubeClient                  kubernetes.Interface
	HalkyonComponentClient      *component.HalkyonV1beta1Client
	HalkyonCapabilityClient     *capability.HalkyonV1beta1Client
	HalkyonCapabilityInfoClient *capInfo.HalkyonV1beta1Client
	HalkyonRuntimeClient        *hruntime.HalkyonV1beta1Client
	KubeConfig                  clientcmd.ClientConfig
	Namespace                   string
}

func GetClient

func GetClient() *Client

GetClient retrieves a client

func (*Client) ExecCMDInContainer

func (c *Client) ExecCMDInContainer(podName string, cmd []string, stdout io.Writer, stderr io.Writer, stdin io.Reader, tty bool) error

ExecCMDInContainer execute command in first container of a pod

func (*Client) ExecCommand

func (c *Client) ExecCommand(podName string, cmd []string, statusMsg string) error

func (*Client) WaitForComponent

func (c *Client) WaitForComponent(name string, desiredPhase string, waitMessage string) (*v1beta1.Component, error)