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 v1beta1.ComponentPhase, 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
	HalkyonLinkClient       *link.HalkyonV1beta1Client
	HalkyonCapabilityClient *capability.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 v1beta1.ComponentPhase, waitMessage string) (*v1beta1.Component, error)