util

Documentation

Index

• Constants
• func GetBlockSizeForParallelTransfer(dataObjectLength int64) int64
• func GetCorrectIRODSPath(p string) string
• func GetIRODSDateTime(timestring string) (time.Time, error)
• func GetIRODSPathDirname(p string) string
• func GetIRODSPathFileName(p string) string
• func GetIRODSZone(p string) (string, error)
• func GetLogLevel() int
• func GetNumTasksForParallelTransfer(dataObjectLength int64) int
• func IsLogLevelDebug() bool
• func IsLogLevelError() bool
• func IsLogLevelInfo() bool
• func IsLogLevelWarn() bool
• func LogDebug(message interface{})
• func LogDebugf(format string, v ...interface{})
• func LogError(message interface{})
• func LogErrorf(format string, v ...interface{})
• func LogInfo(message interface{})
• func LogInfof(format string, v ...interface{})
• func LogWarn(message interface{})
• func LogWarningf(format string, v ...interface{})
• func MakeIRODSPath(collectionPath string, dataobjectName string) string
• func ReadBytes(socket net.Conn, buffer []byte, size int) (int, error)
• func Scramble(in, key string) string
• func SetLogLevel(level int)
• func SplitIRODSPath(p string) (string, string)
• func WriteBytes(socket net.Conn, buffer []byte, size int) error

Constants

const (
	// TransferTaskMinLength is a minimum data length of a task for parallel data transfer
	TransferTaskMinLength int64 = 4 * 1024 * 1024 // 4MB
	// TransferTaskMaxNum is a maximum number of tasks for parallel data transfer
	TransferTaskMaxNum int = 4
	// TransferBlockSize is a block size of a task
	TransferBlockSize int64 = 1024 * 1024 // 1MB
)

Functions

func GetBlockSizeForParallelTransfer

func GetBlockSizeForParallelTransfer(dataObjectLength int64) int64

GetBlockSizeForParallelTransfer returns the block size

func GetCorrectIRODSPath

func GetCorrectIRODSPath(p string) string

GetCorrectIRODSPath corrects the path

func GetIRODSDateTime

func GetIRODSDateTime(timestring string) (time.Time, error)

GetIRODSDateTime returns time struct from string IRODS time

func GetIRODSPathDirname

func GetIRODSPathDirname(p string) string

GetIRODSPathDirname returns the dir of the path

func GetIRODSPathFileName

func GetIRODSPathFileName(p string) string

GetIRODSPathFileName returns the filename of the path

func GetIRODSZone

func GetIRODSZone(p string) (string, error)

GetIRODSZone returns the zone of the path

func GetLogLevel

func GetLogLevel() int

GetLogLevel returns current log level

func GetNumTasksForParallelTransfer

func GetNumTasksForParallelTransfer(dataObjectLength int64) int

GetNumTasksForParallelTransfer returns the number transfer tasks to be used

func IsLogLevelDebug

func IsLogLevelDebug() bool

IsLogLevelDebug checks if current log level is debug

func IsLogLevelError

func IsLogLevelError() bool

IsLogLevelError checks if current log level is error

func IsLogLevelInfo

func IsLogLevelInfo() bool

IsLogLevelInfo checks if current log level is info

func IsLogLevelWarn

func IsLogLevelWarn() bool

IsLogLevelWarn checks if current log level is warn

func LogDebug

func LogDebug(message interface{})

LogDebug logs debug level message

func LogDebugf

func LogDebugf(format string, v ...interface{})

LogDebugf logs debug level message

func LogError

func LogError(message interface{})

LogError logs error level message

func LogErrorf

func LogErrorf(format string, v ...interface{})

LogErrorf logs error level message

func LogInfo

func LogInfo(message interface{})

LogInfo logs info level message

func LogInfof

func LogInfof(format string, v ...interface{})

LogInfof logs info level message

func LogWarn

func LogWarn(message interface{})

LogWarn logs warn level message

func LogWarningf

func LogWarningf(format string, v ...interface{})

LogWarningf logs warning level message

func MakeIRODSPath

func MakeIRODSPath(collectionPath string, dataobjectName string) string

MakeIRODSPath makes the path from collection and data object

func ReadBytes

func ReadBytes(socket net.Conn, buffer []byte, size int) (int, error)

ReadBytes reads data from socket in a particular size

func Scramble

func Scramble(in, key string) string

Scramble implements the obfEncodeByKey irods cpp function.

func SetLogLevel

func SetLogLevel(level int)

SetLogLevel sets log level

func SplitIRODSPath

func SplitIRODSPath(p string) (string, string)

SplitIRODSPath splits the path into dir and file

func WriteBytes

func WriteBytes(socket net.Conn, buffer []byte, size int) error

WriteBytes writes data to socket