func (a *LogAgent) Stop() (err error) {
	a.stopOnce.Do(func() {
		err = a.pipeline.Stop()
		if err != nil {
			return
		}
	})
	return
}
Stop will stop the log monitoring process
package agent
import (
	"sync"
	"go.uber.org/zap"
	"github.com/open-telemetry/opentelemetry-log-collection/operator"
	"github.com/open-telemetry/opentelemetry-log-collection/pipeline"
)
type LogAgent struct {
	pipeline pipeline.Pipeline
	*zap.SugaredLogger
	startOnce sync.Once
	stopOnce  sync.Once
}
func (a *LogAgent) Start(persister operator.Persister) (err error) {
	a.startOnce.Do(func() {
		err = a.pipeline.Start(persister)
		if err != nil {
			return
		}
	})
	return
}