// instead of the log message that exceeded the limit.
message += " A complete log is still being written to Keep, and will be available when the job finishes."
return true, []byte(message)
- } else {
- return arvlog.logThrottleIsOpen, line
}
+ return arvlog.logThrottleIsOpen, line
}
// load the rate limit discovery config parameters
func (fs *fileSystem) Sync() error {
if syncer, ok := fs.root.(syncer); ok {
return syncer.Sync()
- } else {
- return ErrInvalidOperation
}
+ return ErrInvalidOperation
}
func (fs *fileSystem) Flush(string, bool) error {
inodes: make(map[string]inode),
},
}, nil
- } else {
- return &filenode{
- fs: fs,
- fileinfo: fileinfo{
- name: name,
- mode: perm & ^os.ModeDir,
- modTime: modTime,
- },
- }, nil
}
+ return &filenode{
+ fs: fs,
+ fileinfo: fileinfo{
+ name: name,
+ mode: perm & ^os.ModeDir,
+ modTime: modTime,
+ },
+ }, nil
}
func (fs *collectionFileSystem) Child(name string, replace func(inode) (inode, error)) (inode, error) {
}()
if sync {
return <-errs
- } else {
- return nil
}
+ return nil
}
type flushOpts struct {
ok = !ok
if ok {
return nil
- } else {
- return errors.New("good error")
}
+ return errors.New("good error")
},
},
}
http.ResponseWriter
http.Hijacker
}{w, hijacker}
- } else {
- return w
}
+ return w
}
func Logger(req *http.Request) logrus.FieldLogger {