Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogAggregator ¶
type LogAggregator struct {
// contains filtered or unexported fields
}
func GetLogAggregator ¶
func GetLogAggregator() *LogAggregator
func NewLogAggregator ¶
func NewLogAggregator(format string) *LogAggregator
GetLogAggregator returns the singleton instance of LogAggregator.
func (*LogAggregator) FailedMessage ¶
func (la *LogAggregator) FailedMessage(routineID string, msg string)
func (*LogAggregator) Flush ¶
func (la *LogAggregator) Flush()
Flush will close the log channel and wait for all messages to be processed.
func (*LogAggregator) LogMessage ¶
func (la *LogAggregator) LogMessage(routineID string, msg string)
func (*LogAggregator) SuccessMessage ¶
func (la *LogAggregator) SuccessMessage(routineID string, msg string)
type LogMessage ¶
type LogMessage struct {
// contains filtered or unexported fields
}
type ResettableOnce ¶
type ResettableOnce struct {
// contains filtered or unexported fields
}
func (*ResettableOnce) Do ¶
func (ro *ResettableOnce) Do(f func())
func (*ResettableOnce) Reset ¶
func (ro *ResettableOnce) Reset()
Source Files
Click to show internal directories.
Click to hide internal directories.