Add Pause/Resume #18

zeripath · 2020-04-07T19:49:53Z

zeripath commented

2020-04-07 19:49:53 +00:00

Add Pause/Resume functionality to the log.

The timeout here probably needs to change - possibly to something like 10 * time.Millisecond in order to cope with buffer filling during being paused.

// LogEvent logs an event to this MultiChannelledLog
func (m *MultiChannelledLog) LogEvent(event *Event) error {
	select {
	case m.queue <- event:
		return nil
	case <-time.After(60 * time.Second):
		// We're blocked!
		return ErrTimeout{
			Name:     m.name,
			Provider: "MultiChannelledLog",
		}
	}
}

Signed-off-by: Andrew Thornton art27@cantab.net

Add Pause/Resume functionality to the log. The timeout here probably needs to change - possibly to something like `10 * time.Millisecond` in order to cope with buffer filling during being paused. ```go // LogEvent logs an event to this MultiChannelledLog func (m *MultiChannelledLog) LogEvent(event *Event) error { select { case m.queue <- event: return nil case <-time.After(60 * time.Second): // We're blocked! return ErrTimeout{ Name: m.name, Provider: "MultiChannelledLog", } } } ``` Signed-off-by: Andrew Thornton <art27@cantab.net>

lunny commented

2020-04-08 02:13:11 +00:00

CI needs goproxy

zeripath commented

2020-04-08 08:03:35 +00:00

See #19

lunny commented

2020-04-09 01:52:14 +00:00

Why we needs to pause the logger?

This repo is archived. You cannot comment on pull requests.

No reviewers

No Milestone

No Assignees

2 Participants

Due Date

The due date is invalid or out of range. Please use the format 'yyyy-mm-dd'.

No due date set.

Dependencies

No dependencies set.

Reference: gitea/log#18