func (t *simpleQueue) Output(ctx context.Context, event logevent.LogEvent) (err error) {
	// see if output has requested pause and if so just queue the event instead of trying
	if atomic.LoadUint32(&t.isInPause) == StatusPaused {
		select {
		case t.queue <- event:
			return nil
		case <-ctx.Done():
			return ErrContextCancelled.New(nil)
		case <-t.ctx.Done():
			return ErrContextCancelled.New(nil)
		}
	}
	// If we are not in pause mode then call the sender method
	return t.output.OutputEvent(ctx, event)
}
// Output satisfies TypeOutputConfig and is handling incoming events
Output satisfies TypeOutputConfig and is handling incoming events
// Output satisfies TypeOutputConfig and is handling incoming events
func (t *simpleQueue) Output(ctx context.Context, event logevent.LogEvent) (err error) {
	if atomic.LoadUint32(&t.isInPause) == StatusPaused {
		select {
		case t.queue <- event:
			return nil
		case <-ctx.Done():
			return ErrContextCancelled.New(nil)
		case <-t.ctx.Done():
			return ErrContextCancelled.New(nil)
		}
	}
	return t.output.OutputEvent(ctx, event)
}
func ( t * simpleQueue ) Output ( ctx context . Context , event logevent . LogEvent ) ( err error ) { if atomic . LoadUint32 ( & t . isInPause ) == StatusPaused { select { case t . queue <- event : return nil case <- ctx . Done ( ) : return ErrContextCancelled . New ( nil ) case <- t . ctx . Done ( ) : return ErrContextCancelled . New ( nil ) } } return t . output . OutputEvent ( ctx , event ) }
Output satisfies TypeOutputConfig and is handling incoming events
Output satisfies TypeOutputConfig and is handling incoming events
// see if output has requested pause and if so just queue the event instead of trying // If we are not in pause mode then call the sender method