utils

Documentation

Index

• Constants
• Variables
• func ErrHttpEmptyResponse() error
• func ErrMissingFlowAttrs() error
• func ErrNullRepo() error
• func GetBuffer() []byte
• func GetOrCreateCondaEnvWithSpec(spec string) (string, error)
• func GetOrCreateDefaultCondaEnv(name string) (string, error)
• func IsErrHttpEmptyResponse(err error) bool
• func IsErrNullRepo(err error) bool
• func IsPathEmpty(path string) bool
• func ListFiles(path string) error
• func MkDirAll(path string, perm os.FileMode) error
• func Open(path string) (*os.File, error)
• func PathExists(path string) bool
• func PrintHeader(title string)
• func PutBuffer(buf []byte)
• func RandomStr(size int) string
• func WriteFile(path string, data []byte, perm os.FileMode) error
• type LogHandler
  • func NewLogHandler(logpath string, bufflen int) *LogHandler
  • func (lh *LogHandler) Close()
  • func (lh *LogHandler) GetLogPath() string
  • func (lh *LogHandler) Listen()
  • func (lh *LogHandler) Record(m []byte) error
  • func (lh *LogHandler) Write(m []byte) (_ int, retErr error)
• type TaskLogger
  • func (l *TaskLogger) Close()
  • func (l *TaskLogger) GetLogFile() *os.File
  • func (l *TaskLogger) GetLogPath() string
  • func (l *TaskLogger) Write(p []byte) (_ int, retErr error)
• type TaskLoggerInterface
  • func NewTaskLogger(home string, taskId string) TaskLoggerInterface

Constants

const (
	HttpEmptyRespError = "Empty Response from Server"
	NullRepo           = "Repo Not found"
	MissingFlowAttrs   = "Missing Flow attributes"
)

const (
	LOG_DIRECTORY = "log"
)

const (
	LOG_PERM os.FileMode = 0755
)

Variables

var (
	MaxMsgSize = 20 * 1024 * 1024
)

Functions

func ErrHttpEmptyResponse

func ErrHttpEmptyResponse() error

func ErrMissingFlowAttrs

func ErrMissingFlowAttrs() error

func ErrNullRepo

func ErrNullRepo() error

func GetBuffer

func GetBuffer() []byte

func GetOrCreateCondaEnvWithSpec

func GetOrCreateCondaEnvWithSpec(spec string) (string, error)

func GetOrCreateDefaultCondaEnv

func GetOrCreateDefaultCondaEnv(name string) (string, error)

func IsErrHttpEmptyResponse

func IsErrHttpEmptyResponse(err error) bool

func IsErrNullRepo

func IsErrNullRepo(err error) bool

func IsPathEmpty

func IsPathEmpty(path string) bool

func ListFiles

func ListFiles(path string) error

func MkDirAll

func MkDirAll(path string, perm os.FileMode) error

func Open

func Open(path string) (*os.File, error)

func PathExists

func PathExists(path string) bool

func PrintHeader

func PrintHeader(title string)

func PutBuffer

func PutBuffer(buf []byte)

func RandomStr

func RandomStr(size int) string

func WriteFile

func WriteFile(path string, data []byte, perm os.FileMode) error

Types

type LogHandler

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

func NewLogHandler

func NewLogHandler(logpath string, bufflen int) *LogHandler

func (*LogHandler) Close

func (lh *LogHandler) Close()

func (*LogHandler) GetLogPath

func (lh *LogHandler) GetLogPath() string

func (*LogHandler) Listen

func (lh *LogHandler) Listen()

func (*LogHandler) Record

func (lh *LogHandler) Record(m []byte) error

func (*LogHandler) Write

func (lh *LogHandler) Write(m []byte) (_ int, retErr error)

type TaskLogger

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

func (*TaskLogger) Close

func (l *TaskLogger) Close()

func (*TaskLogger) GetLogFile

func (l *TaskLogger) GetLogFile() *os.File

func (*TaskLogger) GetLogPath

func (l *TaskLogger) GetLogPath() string

func (*TaskLogger) Write

func (l *TaskLogger) Write(p []byte) (_ int, retErr error)

type TaskLoggerInterface

type TaskLoggerInterface interface {
	Write(p []byte) (int, error)
	GetLogPath() string
	GetLogFile() *os.File
	Close()
}

func NewTaskLogger

func NewTaskLogger(home string, taskId string) TaskLoggerInterface