utils

Documentation

Index

• func AllDependenciesSatisfied(taskData interface{}, taskStatus map[string]bool) bool
• func ConvertStringListToIntList(strList []string) ([]int, error)
• func CopyDir(src, dst, taskName string) error
• func CopyFile(src, dst string) error
• func CopyInputFiles(inputs []string, hostHiveTaskInputDir string) error
• func CopyMountFiles(mounts []string, hostHiveTaskInputDir, defaultHive string) error
• func DownloadFile(source, destination string) error
• func EnsurePathExists(path string) error
• func FindLineNumber(input, pattern string) int
• func GenerateIntegerList(start, end int) []int
• func GetDirectorywithkeyword(input string) ([]string, error)
• func GetDockerClient() *client.Client
• func GetHostHiveTaskDirectory(taskName, defaultHive string) (string, error)
• func GetInputOutput(source string) (in, out string)
• func GetInputOutputDocker(source string) (in, out string)
• func GetInterfaceVal(taskData interface{}, value string) interface{}
• func GetLogPaths(stdoutDir, stderrDir, taskName string) (stdoutFile, stderrFile string)
• func GetTimeout(taskData interface{}) time.Duration
• func GeterrorLogPath(source string) (stdout, stderr string)
• func ImageExists(cli *client.Client, imageName string) (bool, error)
• func InspectImageEntrypoint(cli *client.Client, imageName, defaultCmd string) ([]string, error)
• func IsFolder(path string) bool
• func IsFolderExists(path string) (bool, error)
• func IsURL(str string) bool
• func ParseDockerLogs(reader io.Reader) (stdoutLogs, stderrLogs []byte, err error)
• func PullDockerImage(cli *client.Client, imageName string) error
• func RandomString(length int) string
• func ReadDynamicRangeFromFile(dynamicRange string) string
• func ReadLinesFromFile(filePath string) ([]string, error)
• func ReplaceDockerplaceholders(...) string
• func ReplacePlaceholders(configuration *config.Config)
• func ReplacePlaceholdersInString(input string, vars map[string]string) string
• func ReplaceTaskPlaceholders(command, hive, mode string) string
• func SanitizeTaskName(taskName string) string
• func UpdateConfigStruct(configStruct *config.Config, keyValueList []string) error
• func WriteLogs(stdoutFile, stderrFile string, stdoutLogs, stderrLogs []byte) error
• func WriteLogsToFile(logs []byte, filePath string) error
• type Args
  • func ParseArgs() *Args

Functions

func AllDependenciesSatisfied

func AllDependenciesSatisfied(taskData interface{}, taskStatus map[string]bool) bool

func ConvertStringListToIntList

func ConvertStringListToIntList(strList []string) ([]int, error)

func CopyDir

func CopyDir(src, dst, taskName string) error

func CopyFile

func CopyFile(src, dst string) error

func CopyInputFiles

func CopyInputFiles(inputs []string, hostHiveTaskInputDir string) error

func CopyMountFiles

func CopyMountFiles(mounts []string, hostHiveTaskInputDir, defaultHive string) error

func DownloadFile

func DownloadFile(source, destination string) error

func EnsurePathExists

func EnsurePathExists(path string) error

func FindLineNumber

func FindLineNumber(input, pattern string) int

func GenerateIntegerList

func GenerateIntegerList(start, end int) []int

func GetDirectorywithkeyword

func GetDirectorywithkeyword(input string) ([]string, error)

func GetDockerClient

func GetDockerClient() *client.Client

func GetHostHiveTaskDirectory

func GetHostHiveTaskDirectory(taskName, defaultHive string) (string, error)

func GetInputOutput

func GetInputOutput(source string) (in, out string)

func GetInputOutputDocker

func GetInputOutputDocker(source string) (in, out string)

func GetInterfaceVal

func GetInterfaceVal(taskData interface{}, value string) interface{}

func GetLogPaths

func GetLogPaths(stdoutDir, stderrDir, taskName string) (stdoutFile, stderrFile string)

func GetTimeout

func GetTimeout(taskData interface{}) time.Duration

func GeterrorLogPath

func GeterrorLogPath(source string) (stdout, stderr string)

func ImageExists

func ImageExists(cli *client.Client, imageName string) (bool, error)

func InspectImageEntrypoint

func InspectImageEntrypoint(cli *client.Client, imageName, defaultCmd string) ([]string, error)

func IsFolder

func IsFolder(path string) bool

func IsFolderExists

func IsFolderExists(path string) (bool, error)

func IsURL

func IsURL(str string) bool

func ParseDockerLogs

func ParseDockerLogs(reader io.Reader) (stdoutLogs, stderrLogs []byte, err error)

func PullDockerImage

func PullDockerImage(cli *client.Client, imageName string) error

func RandomString

func RandomString(length int) string

func ReadDynamicRangeFromFile

func ReadDynamicRangeFromFile(dynamicRange string) string

func ReadLinesFromFile

func ReadLinesFromFile(filePath string) ([]string, error)

func ReplaceDockerplaceholders

func ReplaceDockerplaceholders(command, dockerHive, dockerHiveTaskDir, hostHiveTaskDir, hostHiveTaskOutputDir, hostHiveTaskInputDir string) string

func ReplacePlaceholders

func ReplacePlaceholders(configuration *config.Config)

func ReplacePlaceholdersInString

func ReplacePlaceholdersInString(input string, vars map[string]string) string

Function to replace placeholders in a string

func ReplaceTaskPlaceholders

func ReplaceTaskPlaceholders(command, hive, mode string) string

func SanitizeTaskName

func SanitizeTaskName(taskName string) string

func UpdateConfigStruct

func UpdateConfigStruct(configStruct *config.Config, keyValueList []string) error

func WriteLogs

func WriteLogs(stdoutFile, stderrFile string, stdoutLogs, stderrLogs []byte) error

func WriteLogsToFile

func WriteLogsToFile(logs []byte, filePath string) error

Types

type Args

type Args struct {
	Workflow string
	YamlVars goflags.StringSlice
	Json     bool
	NoBanner bool
	Detailed bool
}

func ParseArgs

func ParseArgs() *Args