package mdb

/*
type walFollower struct {
	Stop   chan struct{}
	Done   *sync.WaitGroup
	W      *cswal.Writer
	Client *Client
}

func (f *walFollower) Run() {
	go func() {
		<-f.Stop
		f.Client.Close()
	}()

	defer f.Done.Done()

	for {
		f.runOnce()
		select {
		case <-f.Stop:
			return
		default:
			time.Sleep(time.Second)
		}
	}
}

func (f *walFollower) runOnce() {
	if err := f.Client.StreamWAL(f.W); err != nil {
		log.Printf("[WAL-FOLLOWER] Recv failed: %s", err)
	}
}
*/