func NewLogReporter(stopper restart.Stopper, sourceName, sourceType, runPath string, endpoints *config.Endpoints, context *client.DestinationsContext) (Reporter, error) {
	health := health.RegisterLiveness(sourceType)

	// setup the auditor
	auditor := auditor.New(runPath, sourceType+"-registry.json", coreconfig.DefaultAuditorTTL, health)
	auditor.Start()
	stopper.Add(auditor)

	// setup the pipeline provider that provides pairs of processor and sender
	pipelineProvider := pipeline.NewProvider(config.NumberOfPipelines, auditor, &diagnostic.NoopMessageReceiver{}, nil, endpoints, context)
	pipelineProvider.Start()
	stopper.Add(pipelineProvider)

	logSource := config.NewLogSource(
		sourceName,
		&config.LogsConfig{
			Type:    sourceType,
			Service: sourceName,
			Source:  sourceName,
		},
	)

	return NewReporter(logSource, pipelineProvider.NextPipelineChan()), nil
}
// NewLogReporter instantiates a new log reporter
NewLogReporter instantiates a new log reporter
// NewLogReporter instantiates a new log reporter
func NewLogReporter(stopper restart.Stopper, sourceName, sourceType, runPath string, endpoints *config.Endpoints, context *client.DestinationsContext) (Reporter, error) {
	health := health.RegisterLiveness(sourceType)
	auditor := auditor.New(runPath, sourceType+"-registry.json", coreconfig.DefaultAuditorTTL, health)
	auditor.Start()
	stopper.Add(auditor)
	pipelineProvider := pipeline.NewProvider(config.NumberOfPipelines, auditor, &diagnostic.NoopMessageReceiver{}, nil, endpoints, context)
	pipelineProvider.Start()
	stopper.Add(pipelineProvider)
	logSource := config.NewLogSource(
		sourceName,
		&config.LogsConfig{
			Type:    sourceType,
			Service: sourceName,
			Source:  sourceName,
		},
	)
	return NewReporter(logSource, pipelineProvider.NextPipelineChan()), nil
}
func NewLogReporter ( stopper restart . Stopper , sourceName , sourceType , runPath string , endpoints * config . Endpoints , context * client . DestinationsContext ) ( Reporter , error ) { health := health . RegisterLiveness ( sourceType ) auditor := auditor . New ( runPath , sourceType + " " , coreconfig . DefaultAuditorTTL , health ) auditor . Start ( ) stopper . Add ( auditor ) pipelineProvider := pipeline . NewProvider ( config . NumberOfPipelines , auditor , & diagnostic . NoopMessageReceiver { } , nil , endpoints , context ) pipelineProvider . Start ( ) stopper . Add ( pipelineProvider ) logSource := config . NewLogSource ( sourceName , & config . LogsConfig { Type : sourceType , Service : sourceName , Source : sourceName , } , ) return NewReporter ( logSource , pipelineProvider . NextPipelineChan ( ) ) , nil }
NewLogReporter instantiates a new log reporter
NewLogReporter instantiates a new log reporter
// setup the auditor // setup the pipeline provider that provides pairs of processor and sender