clean up

libbeat/cmd/instance/beat.go

@@ -224,8 +224,6 @@ func Run(settings Settings, bt beat.Creator) error {
 
 // NewInitializedBeat creates a new beat where all information and initialization is derived from settings
 func NewInitializedBeat(settings Settings) (*Beat, error) {
-	// anderson: could we read os.Stdin here? then we could parse the version
-	// and propagate it
 	b, err := NewBeat(settings.Name, settings.IndexPrefix, settings.Version, settings.ElasticLicensed)
 	if err != nil {
 		return nil, err

libbeat/publisher/processing/default.go

@@ -118,6 +118,7 @@ func MakeDefaultSupport(
 		if fleetmode.Enabled() && !beatCfg.HasField("processors") {
 			log.Debugf("In fleet mode with no processors specified, defaulting to global processors")
 			rawProcessors = fleetDefaultProcessors
+
 		} else {
 			rawProcessors = cfg.Processors
 		}

libbeat/version/helper.go

@@ -21,9 +21,11 @@ import "time"
 
 // GetDefaultVersion returns the current libbeat version.
 // This method is in a separate file as the version.go file is auto generated
-// TODO(AndersonQ): does it need to be changed? in the agent's code there is still a GetDefaultVersion
-// with the same behaviour as this one and it's used in several place. And there
-// is another function for the package version.
+//
+// TODO(AndersonQ): does it need to be changed? in the agent's code there is
+// still a GetDefaultVersion with the same behaviour as this one and it's used
+// in several places. Also, in the agent code, there is another function for
+// getting the package version.
 func GetDefaultVersion() string {
 	if qualifier == "" {
 		return defaultBeatVersion

x-pack/libbeat/management/generate.go

@@ -11,7 +11,6 @@ import (
 	"github.com/elastic/elastic-agent-client/v7/pkg/client"
 	"github.com/elastic/elastic-agent-client/v7/pkg/proto"
 	conf "github.com/elastic/elastic-agent-libs/config"
-	"github.com/elastic/elastic-agent-libs/logp"
 	"github.com/elastic/elastic-agent-libs/mapstr"
 )
 
@@ -167,7 +166,7 @@ func CreateReloadConfigFromInputs(raw []map[string]interface{}) ([]*reload.Confi
 // config injection
 // ===========
 
-// convenience method for wrapping all the stream transformations needed by the shipper and other inputs
+// convinence method for wrapping all the stream transformations needed by the shipper and other inputs
 func createStreamRules(raw *proto.UnitExpectedConfig, streamSource map[string]interface{}, stream *proto.Stream, defaultDataStreamType string, agentInfo *client.AgentInfo, defaultProcessors ...mapstr.M) (map[string]interface{}, error) {
 
 	streamSource = injectIndexStream(defaultDataStreamType, raw, stream, streamSource)
@@ -210,9 +209,6 @@ func injectAgentInfoRule(inputs map[string]interface{}, agentInfo *client.AgentI
 	}
 	var processors []interface{}
 
-	logp.NewLogger("anderson").Infow("injectAgentInfoRule agentInfo",
-		"agent_info", *agentInfo)
-
 	processors = append(processors, generateAddFieldsProcessor(
 		mapstr.M{"id": agentInfo.ID, "snapshot": agentInfo.Snapshot, "version": agentInfo.Version},
 		"elastic_agent"))