utils

Documentation

Index

• 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)
• func SetLogChannel(channel string)
• type Logger
  • 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)
• type ProgressEvent
  • func NewProgressEvent(eventType ProgressEventType, consumed, total int64, rwBytes int64) *ProgressEvent
• type ProgressEventType
• type ProgressListener
  • func GetProgressListener(obj interface{}) ProgressListener
• type ReaderTracker

Functions

func AssertContains

func AssertContains(t *testing.T, contains string, msgAndArgs ...string)

func AssertEqual

func AssertEqual(t *testing.T, a, b interface{})

func AssertNil

func AssertNil(t *testing.T, object interface{})

func AssertNotNil

func AssertNotNil(t *testing.T, object interface{})

func InitLogMsg

func InitLogMsg(fieldMap map[string]string)

func PublishProgress

func PublishProgress(listener ProgressListener, event *ProgressEvent)

publishProgress

func SetLogChannel

func SetLogChannel(channel string)

Types

type Logger

type Logger struct {
	*log.Logger
	// contains filtered or unexported fields
}

func NewLogger

func NewLogger(level string, channel string, out io.Writer, template string) *Logger

func (*Logger) CloseLogger

func (logger *Logger) CloseLogger()

func (*Logger) GetFormatTemplate

func (logger *Logger) GetFormatTemplate() string

func (*Logger) GetIsopen

func (logger *Logger) GetIsopen() bool

func (*Logger) GetLastLogMsg

func (logger *Logger) GetLastLogMsg() string

func (*Logger) OpenLogger

func (logger *Logger) OpenLogger()

func (*Logger) PrintLog

func (logger *Logger) PrintLog(fieldMap map[string]string, err error)

func (*Logger) SetFormatTemplate

func (logger *Logger) SetFormatTemplate(template string)

func (*Logger) SetIsopen

func (logger *Logger) SetIsopen(isopen bool)

func (*Logger) SetLastLogMsg

func (logger *Logger) SetLastLogMsg(lastLogMsg string)

type ProgressEvent

type ProgressEvent struct {
	ConsumedBytes int64
	TotalBytes    int64
	RwBytes       int64
	EventType     ProgressEventType
}

ProgressEvent defines progress event

func NewProgressEvent

func NewProgressEvent(eventType ProgressEventType, consumed, total int64, rwBytes int64) *ProgressEvent

type ProgressEventType

type ProgressEventType int

ProgressEventType defines transfer progress event type

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
)

type ProgressListener

type ProgressListener interface {
	ProgressChanged(event *ProgressEvent)
}

ProgressListener listens progress change

func GetProgressListener

func GetProgressListener(obj interface{}) ProgressListener

type ReaderTracker

type ReaderTracker struct {
	CompletedBytes int64
}