şunun yansıması https://git.mills.io/prologic/msgbus.git
Add some logging
Bu işleme şunda yer alıyor:
ebeveyn
1f484d20c7
işleme
e2e95bebac
|
@ -329,6 +329,8 @@ func NewMessageBus(opts ...Option) (*MessageBus, error) {
|
|||
}
|
||||
|
||||
func (mb *MessageBus) readLog(f fs.FileInfo) error {
|
||||
log.Debugf("reading log %s", f.Name())
|
||||
|
||||
l, err := wal.Open(f.Name(), nil)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error opening log %s: %w", f, err)
|
||||
|
@ -369,6 +371,8 @@ func (mb *MessageBus) readLogs() error {
|
|||
mb.Lock()
|
||||
defer mb.Unlock()
|
||||
|
||||
log.Debug("reading logs...")
|
||||
|
||||
dirs, err := os.ReadDir(mb.options.LogPath)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error listing logs: %w", err)
|
||||
|
|
Yükleniyor…
Yeni konuda referans