util

Documentation

Index

• Variables
• func AddShutDownHook(stopFunc func())
• func CheckDockerDaemon() error
• func ExecuteCommand(cmd string) (stdout, stderr string, err error)
• func ExpandFilePath(path string) string
• func ExportEnvVars(envFile string)
• func GetManifests(manifests string) (files []string, err error)
• func OperateManifest(c *kubernetes.Clientset, dc dynamic.Interface, manifest string, ...) error
• func PathExist(_path string) bool
• func ReadFileContent(filename string) (string, error)
• func ResolveAbs(p string) string
• func ResolveAbsWithBase(p, baseFile string) string
• func UserHomeDir() string
• type HookScriptTemplate
• type K8sClusterInfo
  • func ConnectToK8sCluster(kubeConfigPath string) (info *K8sClusterInfo, err error)
  • func (c *K8sClusterInfo) CopyClusterToNamespace(namespace string) *K8sClusterInfo
  • func (c *K8sClusterInfo) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
  • func (c *K8sClusterInfo) ToRESTConfig() (*rest.Config, error)
  • func (c *K8sClusterInfo) ToRESTMapper() (meta.RESTMapper, error)
  • func (c *K8sClusterInfo) ToRawKubeConfigLoader() clientcmd.ClientConfig
• type ResourceLogFollower
  • func NewResourceLogFollower(ctx context.Context, basePath string) *ResourceLogFollower
  • func (l *ResourceLogFollower) BuildLogWriter(path string) (*os.File, error)
  • func (l *ResourceLogFollower) Close()
  • func (l *ResourceLogFollower) ConsumeLog(logWriter *os.File, stream io.ReadCloser) <-chan struct{}
  • func (l *ResourceLogFollower) IsFollowed(path string) bool
• type WaitSet
  • func NewWaitSet(timeout time.Duration) *WaitSet

Variables

var (
	CfgFile   string
	WorkDir   string
	LogDir    string
	BatchMode bool
)

Functions

func AddShutDownHook

func AddShutDownHook(stopFunc func())

func CheckDockerDaemon

func CheckDockerDaemon() error

CheckDockerDaemon checks if docker daemon is running.

func ExecuteCommand

func ExecuteCommand(cmd string) (stdout, stderr string, err error)

ExecuteCommand executes the given command and returns the result.

func ExpandFilePath

func ExpandFilePath(path string) string

ExpandFilePath expands the leading `~` to absolute path

func ExportEnvVars

func ExportEnvVars(envFile string)

func GetManifests

func GetManifests(manifests string) (files []string, err error)

GetManifests recursively gets all yml and yaml files from manifests string.

func OperateManifest

func OperateManifest(c *kubernetes.Clientset, dc dynamic.Interface, manifest string, operation apiv1.Operation) error

OperateManifest operates manifest in k8s cluster which kind created.

func PathExist

func PathExist(_path string) bool

PathExist checks if a file/directory is exist.

func ReadFileContent

func ReadFileContent(filename string) (string, error)

ReadFileContent reads the file content.

func ResolveAbs

func ResolveAbs(p string) string

ResolveAbs resolves the relative path (relative to CfgFile) to an absolute file path.

func ResolveAbsWithBase

func ResolveAbsWithBase(p, baseFile string) string

ResolveAbsWithBase resolves the relative path (relative to appoint file path) to an absolute file path.

func UserHomeDir

func UserHomeDir() string

UserHomeDir returns the current user's home directory absolute path, which is usually represented as `~` in most shells

Types

type HookScriptTemplate

type HookScriptTemplate struct {
	EnvFile string
}

type K8sClusterInfo

type K8sClusterInfo struct {
	Client    *kubernetes.Clientset
	Interface dynamic.Interface
	// contains filtered or unexported fields
}

K8sClusterInfo created when connect to cluster

func ConnectToK8sCluster

func ConnectToK8sCluster(kubeConfigPath string) (info *K8sClusterInfo, err error)

ConnectToK8sCluster gets clientSet and dynamic client from k8s config file.

func (*K8sClusterInfo) CopyClusterToNamespace

func (c *K8sClusterInfo) CopyClusterToNamespace(namespace string) *K8sClusterInfo

func (*K8sClusterInfo) ToDiscoveryClient

func (c *K8sClusterInfo) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

func (*K8sClusterInfo) ToRESTConfig

func (c *K8sClusterInfo) ToRESTConfig() (*rest.Config, error)

func (*K8sClusterInfo) ToRESTMapper

func (c *K8sClusterInfo) ToRESTMapper() (meta.RESTMapper, error)

func (*K8sClusterInfo) ToRawKubeConfigLoader

func (c *K8sClusterInfo) ToRawKubeConfigLoader() clientcmd.ClientConfig

type ResourceLogFollower

type ResourceLogFollower struct {
	Ctx context.Context
	// contains filtered or unexported fields
}

func NewResourceLogFollower

func NewResourceLogFollower(ctx context.Context, basePath string) *ResourceLogFollower

func (*ResourceLogFollower) BuildLogWriter

func (l *ResourceLogFollower) BuildLogWriter(path string) (*os.File, error)

func (*ResourceLogFollower) Close

func (l *ResourceLogFollower) Close()

func (*ResourceLogFollower) ConsumeLog

func (l *ResourceLogFollower) ConsumeLog(logWriter *os.File, stream io.ReadCloser) <-chan struct{}

func (*ResourceLogFollower) IsFollowed

func (l *ResourceLogFollower) IsFollowed(path string) bool

type WaitSet

type WaitSet struct {
	WaitGroup  sync.WaitGroup
	ErrChan    chan error
	FinishChan chan bool
	Timeout    time.Duration
}

func NewWaitSet

func NewWaitSet(timeout time.Duration) *WaitSet