agent

type Agent struct {
	Context *context // Agent context data that is passed around the place
	// contains filtered or unexported fields
}

type AgentContext interface {
	Context() context2.Context
	SendData(PluginOutput)
	SendEvent(event sample.Event, entityKey entity.Key)
	Unregister(ids.PluginID)
	// Reconnecting tells the agent that this plugin must be re-executed when the agent reconnects after long time
	// disconnected (> 24 hours).
	AddReconnecting(Plugin)
	// Reconnect invokes again all the plugins that have been registered with the AddReconnecting function
	Reconnect()
	Config() *config.Config
	// EntityKey stores agent entity key (name), value may change in runtime.
	EntityKey() string
	Version() string

	// Service -> PID cache. This is used so we can translate between PIDs and service names easily.
	// The cache is populated by all plugins which produce lists of services, and used by metrics
	// which get processes and want to determine which service each process is for.
	CacheServicePids(source string, pidMap map[int]string)
	GetServiceForPid(pid int) (service string, ok bool)
	ActiveEntitiesChannel() chan string
	// HostnameResolver returns the host name resolver associated to the agent context
	HostnameResolver() hostname.Resolver
	IDLookup() host.IDLookup

	// Identity returns the entity ID of the infra agent
	Identity() entity.Identity
}

type Inventories struct {
	// contains filtered or unexported fields
}

type Killable interface {
	// Kill terminates the receiver of the function.
	Kill()
}

type MetricPost struct {
	ExternalKeys []string          `json:"ExternalKeys,omitempty"`
	EntityID     entity.ID         `json:"EntityID,omitempty"`
	IsAgent      bool              `json:"IsAgent"`
	Events       []json.RawMessage `json:"Events"`
	// Entity ID of the reporting agent, which will = EntityID when IsAgent == true.
	// The field is required in the backend for host metadata matching of the remote entities
	ReportingAgentID entity.ID `json:"ReportingAgentID,omitempty"`
}

type MetricPostBatch []*MetricPost

type MetricVortexPost struct {
	EntityID  entity.ID         `json:"EntityID"`
	EntityKey entity.Key        `json:"EntityKey"`
	IsAgent   bool              `json:"IsAgent"`
	Events    []json.RawMessage `json:"Events"`
	// Entity ID of the reporting agent, which will = EntityID when IsAgent == true.
	// The field is required in the backend for host metadata matching of the remote entities
	ReportingAgentID entity.ID `json:"ReportingAgentID"`
}

type MetricVortexPostBatch []*MetricVortexPost

type Plugin interface {
	Run()
	Id() ids.PluginID
	IsExternal() bool
	GetExternalPluginName() string
	LogInfo()
	ScheduleHealthCheck()
}

type PluginCommon struct {
	ID                 ids.PluginID // the "ID" is the path we write the json to
	Context            AgentContext // a reference to the calling agent context
	External           bool         // If the plugin is an external plugin
	ExternalPluginName string       // The external plugin name. Ex: com.newrelic.nginx
	// Returns all the information related to the plugin, including
	// runtime environment variables
	DetailedLogFields func() logrus.Fields
	LogFields         logrus.Fields // fields to include when logging about the plugin
	HealthCheckCh     chan struct{} // notifies the plugin to execute a health check
	// contains filtered or unexported fields
}

type PluginEmitter interface {
	EmitInventory(data PluginInventoryDataset, entity entity.Entity)
	EmitEvent(eventData map[string]interface{}, entityKey entity.Key)
}

type PluginInventoryDataset []Sortable // PluginInventoryDataset is a slice of sortable things

type PluginOutput struct {
	Id            ids.PluginID
	Entity        entity.Entity
	Data          PluginInventoryDataset
	NotApplicable bool
}

type ProvideIDs func(agentIdn entity.Identity, entities []identityapi.RegisterEntity) ([]identityapi.RegisterEntityResponse, error)

type Sortable interface {
	SortKey() string
}