Documentation ¶
Index ¶
- Constants
- func ApplyResourceManagers(ctx context.Context, client *kube.Client, ...) error
- func CreateResourceManagers(client *kube.Client, odigosNs string, odigosTier common.OdigosTier, ...) []resourcemanager.ResourceManager
- func DeleteOldOdigosSystemObjects(ctx context.Context, client *kube.Client, ns string, ...) error
- func GetCurrentConfig(ctx context.Context, client *kube.Client, ns string) (*v1alpha1.OdigosConfiguration, error)
- func GetOdigosNamespace(client *kube.Client, ctx context.Context) (string, error)
- func IsErrNoOdigosNamespaceFound(err error) bool
- func NewAutoScalerResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
- func NewAutoscalerClusterRole() *rbacv1.ClusterRole
- func NewAutoscalerClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewAutoscalerDeployment(ns string, version string, imagePrefix string, imageName string) *appsv1.Deployment
- func NewAutoscalerLeaderElectionRoleBinding(ns string) *rbacv1.RoleBinding
- func NewAutoscalerRole(ns string) *rbacv1.Role
- func NewAutoscalerRoleBinding(ns string) *rbacv1.RoleBinding
- func NewAutoscalerServiceAccount(ns string) *corev1.ServiceAccount
- func NewDataCollectionClusterRole(psp bool) *rbacv1.ClusterRole
- func NewDataCollectionClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewDataCollectionResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
- func NewDataCollectionServiceAccount(ns string) *corev1.ServiceAccount
- func NewInstrumentorClusterRole() *rbacv1.ClusterRole
- func NewInstrumentorClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewInstrumentorDeployment(ns string, version string, telemetryEnabled bool, imagePrefix string, ...) *appsv1.Deployment
- func NewInstrumentorResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
- func NewInstrumentorRoleBinding(ns string) *rbacv1.RoleBinding
- func NewInstrumentorServiceAccount(ns string) *corev1.ServiceAccount
- func NewKeyvalProxyClusterRole() *rbacv1.ClusterRole
- func NewKeyvalProxyClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewKeyvalProxyDeployment(version string, ns string, imagePrefix string) *appsv1.Deployment
- func NewKeyvalProxyResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
- func NewKeyvalProxyRole(ns string) *rbacv1.Role
- func NewKeyvalProxyRoleBinding(ns string) *rbacv1.RoleBinding
- func NewKeyvalProxyServiceAccount(ns string) *corev1.ServiceAccount
- func NewLeaderElectionRole(ns string) *rbacv1.Role
- func NewNamespace(name string) *v1.Namespace
- func NewOdigletClusterRole(psp bool) *rbacv1.ClusterRole
- func NewOdigletClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewOdigletDaemonSet(ns string, version string, imagePrefix string, imageName string, ...) *appsv1.DaemonSet
- func NewOdigletResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, ...) resourcemanager.ResourceManager
- func NewOdigletServiceAccount(ns string) *corev1.ServiceAccount
- func NewOdigosConfigResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, ...) resourcemanager.ResourceManager
- func NewOdigosConfiguration(ns string, config *odigosv1.OdigosConfigurationSpec) *odigosv1.OdigosConfiguration
- func NewOdigosDeploymentConfigMap(ns string, odigosVersion string) *corev1.ConfigMap
- func NewOdigosDeploymentResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, ...) resourcemanager.ResourceManager
- func NewOwnTelemetryCollectorConfigMap(ns string) *corev1.ConfigMap
- func NewOwnTelemetryCollectorDeployment(ns string) *appsv1.Deployment
- func NewOwnTelemetryCollectorService(ns string) *corev1.Service
- func NewOwnTelemetryConfigMapDisabled(ns string) *corev1.ConfigMap
- func NewOwnTelemetryConfigMapOtlpGrpc(ns string, odigosVersion string) *corev1.ConfigMap
- func NewOwnTelemetryResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, ...) resourcemanager.ResourceManager
- func NewSchedulerClusterRole() *rbacv1.ClusterRole
- func NewSchedulerClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
- func NewSchedulerDeployment(ns string, version string, imagePrefix string) *appsv1.Deployment
- func NewSchedulerResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
- func NewSchedulerRoleBinding(ns string) *rbacv1.RoleBinding
- func NewSchedulerServiceAccount(ns string) *corev1.ServiceAccount
Constants ¶
View Source
const ( AutoScalerServiceAccountName = "odigos-autoscaler" AutoScalerServiceName = "auto-scaler" AutoScalerDeploymentName = "odigos-autoscaler" AutoScalerAppLabelValue = "odigos-autoscaler" AutoScalerContainerName = "manager" )
View Source
const ( InstrumentorServiceName = "instrumentor" InstrumentorDeploymentName = "odigos-instrumentor" InstrumentorAppLabelValue = "odigos-instrumentor" InstrumentorContainerName = "manager" )
View Source
const ( OdigletServiceName = "odiglet" OdigletDaemonSetName = "odiglet" OdigletAppLabelValue = "odiglet" OdigletContainerName = "odiglet" OdigletImageName = "keyval/odigos-odiglet" OdigletEnterpriseImageName = "keyval/odigos-enterprise-odiglet" )
View Source
const ( SchedulerImage = "keyval/odigos-scheduler" SchedulerServiceName = "scheduler" SchedulerDeploymentName = "odigos-scheduler" SchedulerAppLabelValue = "odigos-scheduler" SchedulerContainerName = "manager" )
View Source
const (
KeyvalProxyDeploymentName = "odigos-cloud-proxy"
)
View Source
const (
OdigosConfigName = "odigos-config"
)
View Source
const (
OdigosDeploymentConfigMapName = "odigos-deployment"
)
View Source
const (
OwnTelemetryCollectorDeploymentName = "own-telemetry-collector"
)
Variables ¶
This section is empty.
Functions ¶
func ApplyResourceManagers ¶
func ApplyResourceManagers(ctx context.Context, client *kube.Client, resourceManagers []resourcemanager.ResourceManager, prefixForLogging string) error
func CreateResourceManagers ¶
func CreateResourceManagers(client *kube.Client, odigosNs string, odigosTier common.OdigosTier, proTierToken *string, config *odigosv1.OdigosConfigurationSpec) []resourcemanager.ResourceManager
set apiKey to nil for no-op. set to empty string for "no api key" (non odigos cloud mode). set to a valid api key for odigos cloud mode.
func GetCurrentConfig ¶
func GetOdigosNamespace ¶
func NewAutoScalerResourceManager ¶
func NewAutoScalerResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
func NewAutoscalerClusterRole ¶
func NewAutoscalerClusterRole() *rbacv1.ClusterRole
func NewAutoscalerClusterRoleBinding ¶
func NewAutoscalerClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewAutoscalerDeployment ¶
func NewAutoscalerLeaderElectionRoleBinding ¶
func NewAutoscalerLeaderElectionRoleBinding(ns string) *rbacv1.RoleBinding
func NewAutoscalerRole ¶
func NewAutoscalerRoleBinding ¶
func NewAutoscalerRoleBinding(ns string) *rbacv1.RoleBinding
func NewAutoscalerServiceAccount ¶
func NewAutoscalerServiceAccount(ns string) *corev1.ServiceAccount
func NewDataCollectionClusterRole ¶
func NewDataCollectionClusterRole(psp bool) *rbacv1.ClusterRole
func NewDataCollectionClusterRoleBinding ¶
func NewDataCollectionClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewDataCollectionResourceManager ¶
func NewDataCollectionResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
func NewDataCollectionServiceAccount ¶
func NewDataCollectionServiceAccount(ns string) *corev1.ServiceAccount
func NewInstrumentorClusterRole ¶
func NewInstrumentorClusterRole() *rbacv1.ClusterRole
func NewInstrumentorClusterRoleBinding ¶
func NewInstrumentorClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewInstrumentorResourceManager ¶
func NewInstrumentorResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
func NewInstrumentorRoleBinding ¶
func NewInstrumentorRoleBinding(ns string) *rbacv1.RoleBinding
func NewInstrumentorServiceAccount ¶
func NewInstrumentorServiceAccount(ns string) *corev1.ServiceAccount
func NewKeyvalProxyClusterRole ¶
func NewKeyvalProxyClusterRole() *rbacv1.ClusterRole
func NewKeyvalProxyClusterRoleBinding ¶
func NewKeyvalProxyClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewKeyvalProxyDeployment ¶
func NewKeyvalProxyDeployment(version string, ns string, imagePrefix string) *appsv1.Deployment
func NewKeyvalProxyResourceManager ¶
func NewKeyvalProxyResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
func NewKeyvalProxyRole ¶
func NewKeyvalProxyRoleBinding ¶
func NewKeyvalProxyRoleBinding(ns string) *rbacv1.RoleBinding
func NewKeyvalProxyServiceAccount ¶
func NewKeyvalProxyServiceAccount(ns string) *corev1.ServiceAccount
func NewLeaderElectionRole ¶
func NewNamespace ¶
func NewOdigletClusterRole ¶
func NewOdigletClusterRole(psp bool) *rbacv1.ClusterRole
func NewOdigletClusterRoleBinding ¶
func NewOdigletClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewOdigletDaemonSet ¶
func NewOdigletResourceManager ¶
func NewOdigletResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, odigosTier common.OdigosTier) resourcemanager.ResourceManager
func NewOdigletServiceAccount ¶
func NewOdigletServiceAccount(ns string) *corev1.ServiceAccount
func NewOdigosConfigResourceManager ¶
func NewOdigosConfigResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, odigosTier common.OdigosTier) resourcemanager.ResourceManager
func NewOdigosConfiguration ¶
func NewOdigosConfiguration(ns string, config *odigosv1.OdigosConfigurationSpec) *odigosv1.OdigosConfiguration
func NewOdigosDeploymentResourceManager ¶
func NewOdigosDeploymentResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, odigosTier common.OdigosTier) resourcemanager.ResourceManager
func NewOwnTelemetryCollectorDeployment ¶
func NewOwnTelemetryCollectorDeployment(ns string) *appsv1.Deployment
func NewOwnTelemetryConfigMapDisabled ¶
used for odigos opensource which does not collect own telemetry
func NewOwnTelemetryConfigMapOtlpGrpc ¶
for odigos cloud which process own telemetry
func NewOwnTelemetryResourceManager ¶
func NewOwnTelemetryResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec, odigosTier common.OdigosTier) resourcemanager.ResourceManager
func NewSchedulerClusterRole ¶
func NewSchedulerClusterRole() *rbacv1.ClusterRole
func NewSchedulerClusterRoleBinding ¶
func NewSchedulerClusterRoleBinding(ns string) *rbacv1.ClusterRoleBinding
func NewSchedulerDeployment ¶
func NewSchedulerDeployment(ns string, version string, imagePrefix string) *appsv1.Deployment
func NewSchedulerResourceManager ¶
func NewSchedulerResourceManager(client *kube.Client, ns string, config *odigosv1.OdigosConfigurationSpec) resourcemanager.ResourceManager
func NewSchedulerRoleBinding ¶
func NewSchedulerRoleBinding(ns string) *rbacv1.RoleBinding
func NewSchedulerServiceAccount ¶
func NewSchedulerServiceAccount(ns string) *corev1.ServiceAccount
Types ¶
This section is empty.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.