[v14] Add Posthog events for discovered Kubernetes Apps

api/proto/teleport/usageevents/v1/usageevents.proto

@@ -499,11 +499,12 @@ message UIIntegrationEnrollCompleteEvent {
 
 // ResourceCreateEvent is emitted when a resource is created.
 message ResourceCreateEvent {
-  // resource_type is the type of resource ("node", "node.openssh", "db", "k8s").
+  // resource_type is the type of resource ("node", "node.openssh", "db", "k8s", "app").
   string resource_type = 1;
-  // resource_origin is the origin of the resource ("cloud").
+  // resource_origin is the origin of the resource ("cloud", "kubernetes").
   string resource_origin = 2;
-  // cloud_provider is the cloud provider the resource came from ("AWS", "Azure", "GCP").
+  // cloud_provider is the cloud provider the resource came from ("AWS", "Azure", "GCP")
+  // if resource_origin == "cloud".
   string cloud_provider = 3;
   // database contains additional database information if resource_type == "db".
   DiscoveredDatabaseMetadata database = 4;

api/types/constants.go

@@ -677,6 +677,8 @@ const (
 	DiscoveredResourceKubernetes = "k8s"
 	// DiscoveredResourceAgentlessNode identifies a discovered agentless SSH node.
 	DiscoveredResourceAgentlessNode = "node.openssh"
+	// DiscoveredResourceApp identifies a discovered Kubernetes App.
+	DiscoveredResourceApp = "app"
 
 	// TeleportAzureMSIEndpoint is a special URL intercepted by TSH local proxy, serving Azure credentials.
 	TeleportAzureMSIEndpoint = "azure-msi." + TeleportNamespace

lib/srv/discovery/kube_services_watcher.go

@@ -23,11 +23,14 @@ import (
 
 	"github.com/gravitational/trace"
 
+	usageeventsv1 "github.com/gravitational/teleport/api/gen/proto/go/usageevents/v1"
 	"github.com/gravitational/teleport/api/types"
 	"github.com/gravitational/teleport/lib/services"
 	"github.com/gravitational/teleport/lib/srv/discovery/common"
 )
 
+const appEventPrefix = "app/"
+
 func (s *Server) startKubeAppsWatchers() error {
 	if len(s.kubeAppsFetchers) == 0 {
 		return nil
@@ -113,7 +116,20 @@ func (s *Server) onAppCreate(ctx context.Context, rwl types.ResourceWithLabels)
 	if trace.IsAlreadyExists(err) {
 		return trace.Wrap(s.onAppUpdate(ctx, rwl))
 	}
-	return trace.Wrap(err)
+	if err != nil {
+		return trace.Wrap(err)
+	}
+	err = s.emitUsageEvents(map[string]*usageeventsv1.ResourceCreateEvent{
+		appEventPrefix + app.GetName(): {
+			ResourceType:   types.DiscoveredResourceApp,
+			ResourceOrigin: types.OriginKubernetes,
+			// CloudProvider is not set for apps created from Kubernetes services
+		},
+	})
+	if err != nil {
+		s.Log.WithError(err).Debug("Error emitting usage event.")
+	}
+	return nil
 }
 
 func (s *Server) onAppUpdate(ctx context.Context, rwl types.ResourceWithLabels) error {

proto/prehog/v1alpha/teleport.proto

@@ -50,11 +50,12 @@ message SSOCreateEvent {
 
 // ResourceCreateEvent is emitted when a resource is created.
 message ResourceCreateEvent {
-  // resource_type is the type of resource ("node", "node.openssh", "db", "k8s").
+  // resource_type is the type of resource ("node", "node.openssh", "db", "k8s", "app").
   string resource_type = 1;
-  // resource_origin is the origin of the resource ("cloud").
+  // resource_origin is the origin of the resource ("cloud", "kubernetes").
   string resource_origin = 2;
-  // cloud_provider is the cloud provider the resource came from ("AWS", "Azure", "GCP").
+  // cloud_provider is the cloud provider the resource came from ("AWS", "Azure", "GCP")
+  // if resource_origin == "cloud".
   string cloud_provider = 3;
   // database contains additional database information if resource_type == "db".
   DiscoveredDatabaseMetadata database = 4;