func AssertContains(t *testing.T, contains string, msgAndArgs ...string)
func AssertEqual(t *testing.T, a, b interface{})
func AssertNil(t *testing.T, object interface{})
func AssertNotNil(t *testing.T, object interface{})
func InitLogMsg(fieldMap map[string]string)
func PublishProgress(listener ProgressListener, event *ProgressEvent)
publishProgress
func SetLogChannel(channel string)
type Logger struct {
*log.Logger
// contains filtered or unexported fields
}
func NewLogger(level string, channel string, out io.Writer, template string) *Logger
func (logger *Logger) CloseLogger()
func (logger *Logger) GetFormatTemplate() string
func (logger *Logger) GetIsopen() bool
func (logger *Logger) GetLastLogMsg() string
func (logger *Logger) OpenLogger()
func (logger *Logger) PrintLog(fieldMap map[string]string, err error)
func (logger *Logger) SetFormatTemplate(template string)
func (logger *Logger) SetIsopen(isopen bool)
func (logger *Logger) SetLastLogMsg(lastLogMsg string)
ProgressEvent defines progress event
type ProgressEvent struct {
ConsumedBytes int64
TotalBytes int64
RwBytes int64
EventType ProgressEventType
}
func NewProgressEvent(eventType ProgressEventType, consumed, total int64, rwBytes int64) *ProgressEvent
ProgressEventType defines transfer progress event type
type ProgressEventType int
const (
// TransferStartedEvent transfer started, set TotalBytes
TransferStartedEvent ProgressEventType = 1 + iota
// TransferDataEvent transfer data, set ConsumedBytes anmd TotalBytes
TransferDataEvent
// TransferCompletedEvent transfer completed
TransferCompletedEvent
// TransferFailedEvent transfer encounters an error
TransferFailedEvent
)
ProgressListener listens progress change
type ProgressListener interface {
ProgressChanged(event *ProgressEvent)
}
func GetProgressListener(obj interface{}) ProgressListener
type ReaderTracker struct {
CompletedBytes int64
}