business

package
v1.73.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 8, 2024 License: Apache-2.0 Imports: 59 Imported by: 56

Documentation

Index

Constants

View Source 
const (
	IstioDefaultCASecret string = "istio-ca-secret"
	UserProvidedCASecret string = "cacerts"
	CACert               string = "ca-cert.pem"
	CAChainCert          string = "cert-chain.pem"
)
View Source 
const (
	IstiodExternalEnvKey           = "EXTERNAL_ISTIOD"
	IstiodScopeGatewayEnvKey       = "PILOT_SCOPE_GATEWAY_TO_NAMESPACE"
	IstioInjectionLabel            = "istio-injection"
	IstioRevisionLabel             = "istio.io/rev"
	IstioControlPlaneClustersLabel = "topology.istio.io/controlPlaneClusters"
)
View Source 
const (
	MTLSEnabled          = "MTLS_ENABLED"
	MTLSPartiallyEnabled = "MTLS_PARTIALLY_ENABLED"
	MTLSNotEnabled       = "MTLS_NOT_ENABLED"
	MTLSDisabled         = "MTLS_DISABLED"
)
View Source 
const (
	AllowAny = "ALLOW_ANY"
)

Variables

View Source 
var GrafanaDashboardSupplier = findDashboard
View Source 
var HealthAnnotation = []models.AnnotationKey{models.RateHealthAnnotation}

Annotation Filter for Health

View Source 
var ValidProxyLogLevels = []string{"off", "trace", "debug", "info", "warning", "error", "critical"}

ValidProxyLogLevels are the application log levels supported by the envoy admin interface.

Functions

func FakeCustomControllerRSSyncedWithPods added in v1.33.0 

func FakeCustomControllerRSSyncedWithPods() []apps_v1.ReplicaSet

func FakeDaemonSets added in v1.33.0 

func FakeDaemonSets() []apps_v1.DaemonSet

func FakeDepSyncedWithRS 

func FakeDepSyncedWithRS() []apps_v1.Deployment

func FakeDeploymentConfigs 

func FakeDeploymentConfigs() []osapps_v1.DeploymentConfig

func FakeDeployments 

func FakeDeployments(conf config.Config) []apps_v1.Deployment

func FakeDuplicatedDeployments added in v0.9.1 

func FakeDuplicatedDeployments() []apps_v1.Deployment

func FakeDuplicatedReplicaSets added in v0.9.1 

func FakeDuplicatedReplicaSets() []apps_v1.ReplicaSet

func FakeDuplicatedStatefulSets added in v0.9.1 

func FakeDuplicatedStatefulSets() []apps_v1.StatefulSet

func FakePodLogsProxy added in v1.33.0 

func FakePodLogsProxy() *kubernetes.PodLogs

func FakePodLogsSyncedWithDeployments added in v0.18.0 

func FakePodLogsSyncedWithDeployments() *kubernetes.PodLogs

func FakePodSyncedWithDeployments added in v0.18.0 

func FakePodSyncedWithDeployments() *core_v1.Pod

func FakePodsFromCustomController added in v1.33.0 

func FakePodsFromCustomController() []core_v1.Pod

func FakePodsNoController 

func FakePodsNoController() []core_v1.Pod

func FakePodsSyncedWithDeployments 

func FakePodsSyncedWithDeployments() []core_v1.Pod

func FakePodsSyncedWithDuplicated added in v0.9.1 

func FakePodsSyncedWithDuplicated() []core_v1.Pod

func FakeRSSyncedWithPods 

func FakeRSSyncedWithPods() []apps_v1.ReplicaSet

func FakeReplicaSets 

func FakeReplicaSets(conf config.Config) []apps_v1.ReplicaSet

func FakeReplicationControllers 

func FakeReplicationControllers() []core_v1.ReplicationController

func FakeServices 

func FakeServices() []core_v1.Service

func FakeStatefulSets 

func FakeStatefulSets() []apps_v1.StatefulSet

func FilterUniqueIstioReferences added in v1.42.0 

func FilterUniqueIstioReferences(refs []*models.IstioValidationKey) []*models.IstioValidationKey

func FilterWorkloadReferences added in v1.42.0 

func FilterWorkloadReferences(wSelector string, istioConfigList models.IstioConfigList) []*models.IstioValidationKey

func FindOrFail added in v1.73.0 

func FindOrFail[T any](t *testing.T, s []T, f func(T) bool) T

FindOrFail will find an element in a slice or fail the test.

func GetGrafanaInfo added in v1.29.0 

func GetGrafanaInfo(dashboardSupplier dashboardSupplier) (*models.GrafanaInfo, int, error)

GetGrafanaInfo returns the Grafana URL and other info, the HTTP status code (int) and eventually an error 

func GetGrafanaLinks(linksSpec []dashboards.MonitoringDashboardExternalLink) ([]models.ExternalLink, int, error)

GetGrafanaLinks returns the links to Grafana dashboards and other info, the HTTP status code (int) and eventually an error

func GetIstioAPI added in v0.9.1 

func GetIstioAPI(resourceType string) bool

GetIstioAPI provides the Kubernetes API that manages this Istio resource type or empty string if it's not managed

func GetIstioScaler added in v1.27.0 

func GetIstioScaler() func(name string) float64

func GetWorkloadStatus added in v1.33.0 

func GetWorkloadStatus(wl models.Workload) string

func IsAccessibleError added in v1.10.0 

func IsAccessibleError(err error) bool

func IsNamespaceCached added in v1.23.0 

func IsNamespaceCached(namespace string) bool

func IsValidProxyLogLevel added in v1.41.0 

func IsValidProxyLogLevel(level string) bool

IsValidLogLevel determines if the provided string is a valid proxy log level. This can be called before calling SetLogLevel.

func IstioConfigMapName added in v1.73.4 

func IstioConfigMapName(conf config.Config, revision string) string

IstioConfigMapName guesses the istio configmap name.

func NewTestingCache added in v1.66.0 

func NewTestingCache(t *testing.T, k8s kubernetes.ClientInterface, conf config.Config) cache.KialiCache

NewTestingCache will create a cache for you from the kube client and will cleanup the cache when the test ends.

func NewTestingCacheWithFactory added in v1.69.0 

func NewTestingCacheWithFactory(t *testing.T, cf kubernetes.ClientFactory, conf config.Config) cache.KialiCache

NewTestingCacheWithFactory allows you to pass in a custom client factory. Good for testing multicluster.

func SetWithBackends 

func SetWithBackends(cf kubernetes.ClientFactory, prom prometheus.ClientInterface)

SetWithBackends allows for specifying the ClientFactory and Prometheus clients to be used. Mock friendly. Used only with tests.

func SetupBusinessLayer added in v1.66.0 

func SetupBusinessLayer(t *testing.T, k8s kubernetes.ClientInterface, config config.Config) cache.KialiCache

SetupBusinessLayer mocks out some global variables in the business package such as the kiali cache and the prometheus client.

func Start added in v1.46.0 

func Start() error

Start initializes the Kiali Cache and sets the globals necessary for the business layer.

func Stop added in v1.9.0 

func Stop()

func WithKialiCache added in v1.66.0 

func WithKialiCache(cache cache.KialiCache)

WithKialiCache is a testing func that lets you replace the global cache var.

func WithProm added in v1.66.0 

func WithProm(prom prometheus.ClientInterface)

WithProm is a testing func that lets you replace the global prom client var.

Types

type AccessLogEntry added in v1.33.0 

type AccessLogEntry struct {
	Timestamp     string `json:"timestamp,omitempty"`
	TimestampUnix int64  `json:"timestampUnix,omitempty"`
}

AccessLogEntry provides parsed info from a single proxy access log entry

type AccessibleNamespaceError added in v1.10.0 

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

func (*AccessibleNamespaceError) Error added in v1.10.0 

func (in *AccessibleNamespaceError) Error() string

type AccessibleTokenReviewError added in v1.29.0 

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

func (*AccessibleTokenReviewError) Error added in v1.29.0 

func (in *AccessibleTokenReviewError) Error() string

type AppCriteria added in v1.48.0 

type AppCriteria struct {
	Namespace             string
	Cluster               string
	AppName               string
	IncludeIstioResources bool
	IncludeHealth         bool
	RateInterval          string
	QueryTime             time.Time
}

type AppService 

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

AppService deals with fetching Workloads group by "app" label, which will be identified as an "application"

func (*AppService) GetAppDetails added in v1.48.0 

func (in *AppService) GetAppDetails(ctx context.Context, criteria AppCriteria) (models.App, error)

GetApp is the API handler to fetch the details for a given namespace and app name

func (*AppService) GetAppList 

func (in *AppService) GetAppList(ctx context.Context, criteria AppCriteria) (models.AppList, error)

GetAppList is the API handler to fetch the list of applications in a given namespace

type ControlPlane added in v1.73.0 

type ControlPlane struct {
	// Cluster the kube cluster that the controlplane is running on.
	Cluster *kubernetes.Cluster

	// ManagedClusters are the clusters that this controlplane manages.
	// This could include the cluster that the controlplane is running on.
	ManagedClusters []*kubernetes.Cluster

	// Revision is the revision of the controlplane.
	// Can be empty when it's the default revision.
	Revision string

	// ManagesExternal indicates if the controlplane manages an external cluster.
	// It could also manage the cluster that it is running on.
	ManagesExternal bool

	// Config
	Config ControlPlaneConfiguration
}

ControlPlane manages the dataplane for one or more kube clusters. It's expected to manage the cluster that it is deployed in. It has configuration for all the clusters/namespaces associated with it.

type ControlPlaneConfiguration added in v1.73.0 

type ControlPlaneConfiguration struct {
	// IsGatewayToNamespace specifies the PILOT_SCOPE_GATEWAY_TO_NAMESPACE environment variable in Control Plane
	// This is not currently used by the frontend so excluding it from the API response.
	IsGatewayToNamespace bool `json:"-"`

	// OutboundTrafficPolicy is the outbound traffic policy for the controlplane.
	OutboundTrafficPolicy models.OutboundPolicy

	// Network is the name of the network that the controlplane is using.
	Network string

	// IstioMeshConfig comes from the istio configmap.
	kubernetes.IstioMeshConfig
}

ControlPlaneConfiguration is the configuration for the controlplane and any associated dataplanes.

type DashboardsService added in v0.12.0 

type DashboardsService struct {
	CustomEnabled bool
	// contains filtered or unexported fields
}

DashboardsService deals with fetching dashboards from config

func NewDashboardsService added in v0.12.0 

func NewDashboardsService(namespace *models.Namespace, workload *models.Workload) *DashboardsService

NewDashboardsService initializes this business service

func (*DashboardsService) BuildIstioDashboard added in v1.27.0 

func (in *DashboardsService) BuildIstioDashboard(metrics models.MetricsMap, direction string) *models.MonitoringDashboard

BuildIstioDashboard returns Istio dashboard filled-in with metrics

func (*DashboardsService) GetCustomDashboardRefs added in v0.17.0 

func (in *DashboardsService) GetCustomDashboardRefs(namespace, app, version string, pods []*models.Pod) []models.Runtime

GetCustomDashboardRefs finds all dashboard IDs and Titles associated to this app and add them to the model

func (*DashboardsService) GetDashboard added in v0.12.0 

func (in *DashboardsService) GetDashboard(authInfo *api.AuthInfo, params models.DashboardQuery, template string) (*models.MonitoringDashboard, error)

GetDashboard returns a dashboard filled-in with target data

func (*DashboardsService) SearchExplicitDashboards added in v1.27.0 

func (in *DashboardsService) SearchExplicitDashboards(pods []models.Pod) []models.Runtime

SearchExplicitDashboards will check annotations of all supplied pods to extract a unique list of dashboards Accepted annotations are "kiali.io/runtimes" and "kiali.io/dashboards"

type HealthService 

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

HealthService deals with fetching health from various sources and convert to kiali model

func (*HealthService) GetAppHealth 

func (in *HealthService) GetAppHealth(ctx context.Context, namespace, cluster, app, rateInterval string, queryTime time.Time, appD *appDetails) (models.AppHealth, error)

GetAppHealth returns an app health from just Namespace and app name (thus, it fetches data from K8S and Prometheus)

func (*HealthService) GetNamespaceAppHealth 

func (in *HealthService) GetNamespaceAppHealth(ctx context.Context, criteria NamespaceHealthCriteria) (models.NamespaceAppHealth, error)

GetNamespaceAppHealth returns a health for all apps in given Namespace (thus, it fetches data from K8S and Prometheus)

func (*HealthService) GetNamespaceServiceHealth 

func (in *HealthService) GetNamespaceServiceHealth(ctx context.Context, criteria NamespaceHealthCriteria) (models.NamespaceServiceHealth, error)

GetNamespaceServiceHealth returns a health for all services in given Namespace (thus, it fetches data from K8S and Prometheus)

func (*HealthService) GetNamespaceWorkloadHealth 

func (in *HealthService) GetNamespaceWorkloadHealth(ctx context.Context, criteria NamespaceHealthCriteria) (models.NamespaceWorkloadHealth, error)

GetNamespaceWorkloadHealth returns a health for all workloads in given Namespace (thus, it fetches data from K8S and Prometheus)

func (*HealthService) GetServiceHealth 

func (in *HealthService) GetServiceHealth(ctx context.Context, namespace, cluster, service, rateInterval string, queryTime time.Time, svc *models.Service) (models.ServiceHealth, error)

GetServiceHealth returns a service health (service request error rate)

func (*HealthService) GetWorkloadHealth 

func (in *HealthService) GetWorkloadHealth(ctx context.Context, namespace, cluster, workload, rateInterval string, queryTime time.Time, w *models.Workload) (models.WorkloadHealth, error)

GetWorkloadHealth returns a workload health from just Namespace and workload (thus, it fetches data from K8S and Prometheus)

type IstioCertsService added in v1.40.0 

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

func (*IstioCertsService) GetCertsInfo added in v1.40.0 

func (ics *IstioCertsService) GetCertsInfo() ([]models.CertInfo, error)

func (*IstioCertsService) GetTlsMinVersion added in v1.59.0 

func (ics *IstioCertsService) GetTlsMinVersion() (string, error)

type IstioConfigCriteria 

type IstioConfigCriteria struct {
	// When AllNamespaces is true the IstioConfigService will use the Istio registry to return the configuration
	// from all namespaces directly from the Istio registry instead of the individual API
	// This usecase should be reserved for validations use cases only where cross-namespace validation may create a
	// penalty
	AllNamespaces                 bool
	Namespace                     string
	Cluster                       string
	IncludeGateways               bool
	IncludeK8sGateways            bool
	IncludeK8sHTTPRoutes          bool
	IncludeVirtualServices        bool
	IncludeDestinationRules       bool
	IncludeServiceEntries         bool
	IncludeSidecars               bool
	IncludeAuthorizationPolicies  bool
	IncludePeerAuthentications    bool
	IncludeWorkloadEntries        bool
	IncludeWorkloadGroups         bool
	IncludeRequestAuthentications bool
	IncludeEnvoyFilters           bool
	IncludeWasmPlugins            bool
	IncludeTelemetry              bool
	LabelSelector                 string
	WorkloadSelector              string
}

func ParseIstioConfigCriteria added in v1.20.0 

func ParseIstioConfigCriteria(cluster, namespace, objects, labelSelector, workloadSelector string, allNamespaces bool) IstioConfigCriteria

func (IstioConfigCriteria) Include added in v1.24.0 

func (icc IstioConfigCriteria) Include(resource string) bool

type IstioConfigService 

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

func (*IstioConfigService) CreateIstioConfigDetail added in v0.14.0 

func (in *IstioConfigService) CreateIstioConfigDetail(cluster, namespace, resourceType string, body []byte) (models.IstioConfigDetails, error)

func (*IstioConfigService) DeleteIstioConfigDetail added in v0.9.1 

func (in *IstioConfigService) DeleteIstioConfigDetail(cluster, namespace, resourceType, name string) error

DeleteIstioConfigDetail deletes the given Istio resource

func (*IstioConfigService) GetIstioConfigDetails 

func (in *IstioConfigService) GetIstioConfigDetails(ctx context.Context, cluster, namespace, objectType, object string) (models.IstioConfigDetails, error)

GetIstioConfigDetails returns a specific Istio configuration object. It uses following parameters: - "namespace": namespace where configuration is stored - "objectType": type of the configuration - "object": name of the configuration

func (*IstioConfigService) GetIstioConfigDetailsFromRegistry added in v1.55.0 

func (in *IstioConfigService) GetIstioConfigDetailsFromRegistry(ctx context.Context, cluster, namespace, objectType, object string) (models.IstioConfigDetails, error)

GetIstioConfigDetailsFromRegistry returns a specific Istio configuration object from Istio Registry. The returned object is Read only. It uses following parameters: - "namespace": namespace where configuration is stored - "objectType": type of the configuration - "object": name of the configuration

func (*IstioConfigService) GetIstioConfigList added in v0.9.1 

func (in *IstioConfigService) GetIstioConfigList(ctx context.Context, criteria IstioConfigCriteria) (models.IstioConfigList, error)

GetIstioConfigList returns a list of Istio routing objects, Mixer Rules, (etc.) per a given Namespace. @TODO this method should be replaced by GetIstioConfigMap

func (*IstioConfigService) GetIstioConfigMap added in v1.69.0 

func (in *IstioConfigService) GetIstioConfigMap(ctx context.Context, criteria IstioConfigCriteria) (models.IstioConfigMap, error)

GetIstioConfigMap returns a map of Istio config objects list per cluster @TODO this method should replace GetIstioConfigList

func (*IstioConfigService) GetIstioConfigPermissions added in v1.29.0 

func (in *IstioConfigService) GetIstioConfigPermissions(ctx context.Context, namespaces []string, cluster string) models.IstioConfigPermissions

func (*IstioConfigService) IsAmbientEnabled added in v1.67.0 

func (in *IstioConfigService) IsAmbientEnabled() bool

Check if istio Ambient profile was enabled ATM it is defined in the istio-cni-config configmap

func (*IstioConfigService) IsGatewayAPI added in v1.58.0 

func (in *IstioConfigService) IsGatewayAPI(cluster string) bool

func (*IstioConfigService) UpdateIstioConfigDetail added in v0.12.0 

func (in *IstioConfigService) UpdateIstioConfigDetail(cluster, namespace, resourceType, name, jsonPatch string) (models.IstioConfigDetails, error)

type IstioStatusService added in v1.18.0 

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

SvcService deals with fetching istio/kubernetes services related content and convert to kiali model

func (*IstioStatusService) GetStatus added in v1.18.0 

func (iss *IstioStatusService) GetStatus(ctx context.Context, cluster string) (kubernetes.IstioComponentStatus, error)

type IstioValidationsService 

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

func (*IstioValidationsService) GetIstioObjectValidations 

func (in *IstioValidationsService) GetIstioObjectValidations(ctx context.Context, cluster, namespace string, objectType string, object string) (models.IstioValidations, models.IstioReferencesMap, error)

GetIstioObjectValidations validates a single Istio object of the given type with the given name found in the given namespace.

func (*IstioValidationsService) GetValidations added in v0.14.0 

func (in *IstioValidationsService) GetValidations(ctx context.Context, cluster, namespace, service, workload string) (models.IstioValidations, error)

GetValidations returns an IstioValidations object with all the checks found when running all the enabled checkers. If service is "" then the whole namespace is validated. If service is not empty string, then all of its associated Istio objects are validated.

type JaegerLoader added in v1.11.0 

type JaegerLoader = func() (jaeger.ClientInterface, error)

type JaegerService added in v1.11.0 

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

func (*JaegerService) GetAppSpans added in v1.24.0 

func (in *JaegerService) GetAppSpans(ns, app string, query models.TracingQuery) ([]jaeger.JaegerSpan, error)

func (*JaegerService) GetAppTraces added in v1.24.0 

func (in *JaegerService) GetAppTraces(ns, app string, query models.TracingQuery) (*jaeger.JaegerResponse, error)

func (*JaegerService) GetErrorTraces added in v1.11.0 

func (in *JaegerService) GetErrorTraces(ns, app string, duration time.Duration) (errorTraces int, err error)

func (*JaegerService) GetJaegerTraceDetail added in v1.11.0 

func (in *JaegerService) GetJaegerTraceDetail(traceID string) (trace *jaeger.JaegerSingleTrace, err error)

func (*JaegerService) GetServiceSpans added in v1.24.0 

func (in *JaegerService) GetServiceSpans(ctx context.Context, ns, service string, query models.TracingQuery) ([]jaeger.JaegerSpan, error)

func (*JaegerService) GetServiceTraces added in v1.24.0 

func (in *JaegerService) GetServiceTraces(ctx context.Context, ns, service string, query models.TracingQuery) (*jaeger.JaegerResponse, error)

GetServiceTraces returns traces involving the requested service. Note that because the tracing API pulls traces by "App", only a subset of the traces may actually involve the requested service. Callers may need to upwardly adjust TracingQuery.Limit to get back the number of desired traces. It depends on the number of services backing the app. For example, if there are 2 services for the app, if evenly distributed, a query limit of 20 may return only 10 traces. The ratio is typically not as bad as it is with GetWorkloadTraces.

func (*JaegerService) GetStatus added in v1.38.1 

func (in *JaegerService) GetStatus() (accessible bool, err error)

func (*JaegerService) GetWorkloadSpans added in v1.24.0 

func (in *JaegerService) GetWorkloadSpans(ctx context.Context, ns, workload string, query models.TracingQuery) ([]jaeger.JaegerSpan, error)

func (*JaegerService) GetWorkloadTraces added in v1.24.0 

func (in *JaegerService) GetWorkloadTraces(ctx context.Context, ns, workload string, query models.TracingQuery) (*jaeger.JaegerResponse, error)

GetWorkloadTraces returns traces involving the requested workload. Note that because the tracing API pulls traces by "App", only a subset of the traces may actually involve the requested workload. Callers may need to upwardly adjust TracingQuery.Limit to get back the number of desired traces. It depends on the number of workloads backing the app. For example, if there are 5 workloads for the app, if evenly distributed, a query limit of 25 may return only 5 traces.

type Layer 

type Layer struct {
	App              AppService
	Health           HealthService
	IstioConfig      IstioConfigService
	IstioStatus      IstioStatusService
	IstioCerts       IstioCertsService
	Jaeger           JaegerService
	Mesh             MeshService
	Namespace        NamespaceService
	OpenshiftOAuth   OpenshiftOAuthService
	ProxyLogging     ProxyLoggingService
	ProxyStatus      ProxyStatusService
	RegistryStatus   RegistryStatusService
	RegistryStatuses map[string]RegistryStatusService // Key is the cluster name
	Svc              SvcService
	TLS              TLSService
	TokenReview      TokenReviewService
	Validations      IstioValidationsService
	Workload         WorkloadService
}

Layer is a container for fast access to inner services. A business layer is created per token/user. Any data that needs to be saved across layers is saved in the Kiali Cache.

func Get 

func Get(authInfo *api.AuthInfo) (*Layer, error)

Get the business.Layer

func NewWithBackends added in v0.10.0 

func NewWithBackends(userClients map[string]kubernetes.ClientInterface, kialiSAClients map[string]kubernetes.ClientInterface, prom prometheus.ClientInterface, jaegerClient JaegerLoader) *Layer

NewWithBackends creates the business layer using the passed k8sClients and prom clients. Note that the client passed here should *not* be the Kiali ServiceAccount client. It should be the user client based on the logged in user's token.

type LogEntry added in v1.25.0 

type LogEntry struct {
	Message       string            `json:"message,omitempty"`
	Severity      string            `json:"severity,omitempty"`
	OriginalTime  time.Time         `json:"-"`
	Timestamp     string            `json:"timestamp,omitempty"`
	TimestampUnix int64             `json:"timestampUnix,omitempty"`
	AccessLog     *parser.AccessLog `json:"accessLog,omitempty"`
}

LogEntry holds a single log entry

type LogOptions added in v1.26.0 

type LogOptions struct {
	Duration *time.Duration
	IsProxy  bool // fetching logs for Istio Proxy (Envoy access log)
	MaxLines *int
	core_v1.PodLogOptions
}

LogOptions holds query parameter values

type Mesh added in v1.73.0 

type Mesh struct {
	// ControlPlanes that share the same mesh ID.
	ControlPlanes []ControlPlane

	// ID is the ID of the mesh.
	ID *string
}

Mesh is one or more controlplanes (primaries) managing a dataplane across one or more clusters. There can be multiple primaries on a single cluster when istio revisions are used. A single primary can also manage multiple clusters (primary-remote deployment).

type MeshService added in v1.29.0 

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

MeshService is a support service for retrieving data about the mesh environment when Istio is installed with multi-cluster enabled. Prefer initializing this type via the NewMeshService function.

func NewMeshService added in v1.29.0 

func NewMeshService(kialiSAClients map[string]kubernetes.ClientInterface, cache cache.KialiCache, namespaceService NamespaceService, conf config.Config) MeshService

NewMeshService initializes a new MeshService structure with the given k8s clients.

func (*MeshService) CanaryUpgradeStatus added in v1.60.0 

func (in *MeshService) CanaryUpgradeStatus() (*models.CanaryUpgradeStatus, error)

func (*MeshService) GetClusters added in v1.29.0 

func (in *MeshService) GetClusters(r *http.Request) ([]kubernetes.Cluster, error)

GetClusters resolves the Kubernetes clusters that are hosting the mesh. Resolution is done as best-effort using the resources that are present in the cluster.

func (*MeshService) GetMesh added in v1.73.0 

func (in *MeshService) GetMesh(ctx context.Context) (*Mesh, error)

GetMesh gathers information about the mesh and controlplanes running in the mesh from various sources e.g. istio configmap, istiod deployment envvars, etc.

func (*MeshService) IsValidCluster added in v1.68.0 

func (in *MeshService) IsValidCluster(cluster string) bool

Checks if a cluster exist

func (*MeshService) IstiodResourceThresholds added in v1.57.0 

func (in *MeshService) IstiodResourceThresholds() (*models.IstiodThresholds, error)

func (*MeshService) OutboundTrafficPolicy added in v1.53.0 

func (in *MeshService) OutboundTrafficPolicy() (*models.OutboundPolicy, error)

type MetricsLabelsBuilder added in v1.27.0 

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

func NewMetricsLabelsBuilder added in v1.27.0 

func NewMetricsLabelsBuilder(direction string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Add added in v1.27.0 

func (lb *MetricsLabelsBuilder) Add(key, value string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Aggregate added in v1.27.0 

func (lb *MetricsLabelsBuilder) Aggregate(key, value string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) App added in v1.27.0 

func (lb *MetricsLabelsBuilder) App(name, namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Build added in v1.27.0 

func (lb *MetricsLabelsBuilder) Build() string

func (*MetricsLabelsBuilder) BuildForErrors added in v1.27.0 

func (lb *MetricsLabelsBuilder) BuildForErrors() []string

func (*MetricsLabelsBuilder) Cluster added in v1.68.0 

func (lb *MetricsLabelsBuilder) Cluster(cluster string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Namespace added in v1.27.0 

func (lb *MetricsLabelsBuilder) Namespace(namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) PeerApp added in v1.27.0 

func (lb *MetricsLabelsBuilder) PeerApp(name, namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) PeerNamespace added in v1.27.0 

func (lb *MetricsLabelsBuilder) PeerNamespace(namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) PeerService added in v1.27.0 

func (lb *MetricsLabelsBuilder) PeerService(name, namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) PeerWorkload added in v1.27.0 

func (lb *MetricsLabelsBuilder) PeerWorkload(name, namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Protocol added in v1.27.0 

func (lb *MetricsLabelsBuilder) Protocol(name string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) QueryScope added in v1.48.0 

func (lb *MetricsLabelsBuilder) QueryScope() *MetricsLabelsBuilder

QueryScope adds scope labels, if configured

func (*MetricsLabelsBuilder) Reporter added in v1.27.0 

func (lb *MetricsLabelsBuilder) Reporter(name string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) SelfReporter added in v1.27.0 

func (lb *MetricsLabelsBuilder) SelfReporter() *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Service added in v1.27.0 

func (lb *MetricsLabelsBuilder) Service(name, namespace string) *MetricsLabelsBuilder

func (*MetricsLabelsBuilder) Workload added in v1.27.0 

func (lb *MetricsLabelsBuilder) Workload(name, namespace string) *MetricsLabelsBuilder

type MetricsService added in v1.27.0 

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

MetricsService deals with fetching metrics from prometheus

func NewMetricsService added in v1.27.0 

func NewMetricsService(prom prometheus.ClientInterface) *MetricsService

NewMetricsService initializes this business service

func (*MetricsService) GetControlPlaneMetrics added in v1.57.0 

func (in *MetricsService) GetControlPlaneMetrics(q models.IstioMetricsQuery, scaler func(n string) float64) (models.MetricsMap, error)

func (*MetricsService) GetMetrics added in v1.27.0 

func (in *MetricsService) GetMetrics(q models.IstioMetricsQuery, scaler func(n string) float64) (models.MetricsMap, error)

func (*MetricsService) GetStats added in v1.27.0 

func (in *MetricsService) GetStats(queries []models.MetricsStatsQuery) (map[string]models.MetricsStats, error)

GetStats computes metrics stats, currently response times, for a set of queries

type NamespaceHealthCriteria added in v1.56.0 

type NamespaceHealthCriteria struct {
	IncludeMetrics bool
	Namespace      string
	Cluster        string
	QueryTime      time.Time
	RateInterval   string
}

type NamespaceService 

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

NamespaceService deals with fetching k8sClients namespaces / OpenShift projects and convert to kiali model

func NewNamespaceService 

func NewNamespaceService(userClients map[string]kubernetes.ClientInterface, kialiSAClients map[string]kubernetes.ClientInterface, cache cache.KialiCache, conf config.Config) NamespaceService

func (*NamespaceService) GetClusterList added in v1.72.0 

func (in *NamespaceService) GetClusterList() []string

GetClusterList Returns a list of cluster names based on the user clients

func (*NamespaceService) GetClusterNamespace added in v1.72.0 

func (in *NamespaceService) GetClusterNamespace(ctx context.Context, namespace string, cluster string) (*models.Namespace, error)

GetClusterNamespace returns the definition of the specified namespace.

func (*NamespaceService) GetClusterNamespaces added in v1.72.0 

func (in *NamespaceService) GetClusterNamespaces(ctx context.Context, cluster string) ([]models.Namespace, error)

GetClusterNamespaces is just a convenience routine that filters GetNamespaces for a particular cluster

func (*NamespaceService) GetNamespaceClusters added in v1.71.0 

func (in *NamespaceService) GetNamespaceClusters(ctx context.Context, namespace string) ([]models.Namespace, error)

GetNamespaceClusters is a convenience routine that filters GetNamespaces for a particular namespace

func (*NamespaceService) GetNamespaces 

func (in *NamespaceService) GetNamespaces(ctx context.Context) ([]models.Namespace, error)

Returns a list of the given namespaces / projects

func (*NamespaceService) UpdateNamespace added in v1.22.1 

func (in *NamespaceService) UpdateNamespace(ctx context.Context, namespace string, jsonPatch string, cluster string) (*models.Namespace, error)

type OAuthAuthorizationServer added in v0.16.0 

type OAuthAuthorizationServer struct {
	AuthorizationEndpoint string `json:"authorization_endpoint"`
	Issuer                string `json:"issuer"`
}

Structure that's returned by the openshift oauth authorization server. It defaults to following the snake_case format, so we parse it to something more usable on our side.

type OAuthMetadata added in v0.16.0 

type OAuthMetadata struct {
	AuthorizationEndpoint string `json:"authorizationEndpoint"`
	LogoutEndpoint        string `json:"logoutEndpoint"`
	LogoutRedirect        string `json:"logoutRedirect"`
}

type OAuthRoute added in v0.16.0 

type OAuthRoute struct {
	Spec OAuthRouteSpec `json:"spec"`
}

type OAuthRouteSpec added in v0.16.0 

type OAuthRouteSpec struct {
	Host string             `json:"host"`
	TLS  *OAuthRouteTLSSpec `json:"tls,omitempty"`
}

type OAuthRouteTLSSpec added in v0.16.0 

type OAuthRouteTLSSpec struct {
	Termination string `json:"termination"`
}

type OAuthUser added in v0.16.0 

type OAuthUser struct {
	Metadata OAuthUserMetadata `json:"metadata"`
}

type OAuthUserMetadata added in v0.16.0 

type OAuthUserMetadata struct {
	Name string `json:"name"`
}

type ObjectChecker 

type ObjectChecker interface {
	Check() models.IstioValidations
}

type OpenshiftOAuthService added in v0.16.0 

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

func (*OpenshiftOAuthService) GetUserInfo added in v0.16.0 

func (in *OpenshiftOAuthService) GetUserInfo(token string) (*OAuthUser, error)

func (*OpenshiftOAuthService) Logout added in v0.20.0 

func (in *OpenshiftOAuthService) Logout(token string) error

func (*OpenshiftOAuthService) Metadata added in v0.16.0 

func (in *OpenshiftOAuthService) Metadata(r *http.Request) (metadata *OAuthMetadata, err error)

type PodLog added in v1.25.0 

type PodLog struct {
	Entries        []LogEntry `json:"entries,omitempty"`
	LinesTruncated bool       `json:"linesTruncated,omitempty"`
}

PodLog reports log entries

type ProxyLoggingService added in v1.41.0 

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

ProxyLoggingService is a thin layer over the kube interface for proxy logging functions.

func (*ProxyLoggingService) SetLogLevel added in v1.41.0 

func (in *ProxyLoggingService) SetLogLevel(cluster, namespace, pod, level string) error

SetLogLevel sets the pod's proxy log level.

type ProxyStatusService added in v1.35.0 

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

func (*ProxyStatusService) GetConfigDump added in v1.35.0 

func (in *ProxyStatusService) GetConfigDump(cluster, namespace, pod string) (models.EnvoyProxyDump, error)

func (*ProxyStatusService) GetConfigDumpResourceEntries added in v1.35.0 

func (in *ProxyStatusService) GetConfigDumpResourceEntries(cluster, namespace, pod, resource string) (*models.EnvoyProxyDump, error)

func (*ProxyStatusService) GetPodProxyStatus added in v1.35.0 

func (in *ProxyStatusService) GetPodProxyStatus(cluster, ns, pod string) *models.ProxyStatus

type ReferenceChecker added in v1.47.0 

type ReferenceChecker interface {
	References() models.IstioReferencesMap
}

type RegistryCriteria added in v1.44.0 

type RegistryCriteria struct {
	// When AllNamespaces is true Namespace criteria is ignored
	// Note this flag is only supported in Registry queries
	AllNamespaces   bool
	Namespace       string
	ServiceName     string
	ServiceSelector string
}

type RegistryStatusService added in v1.35.0 

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

func (*RegistryStatusService) GetRegistryConfiguration added in v1.44.0 

func (in *RegistryStatusService) GetRegistryConfiguration(criteria RegistryCriteria) (*kubernetes.RegistryConfiguration, error)

func (*RegistryStatusService) GetRegistryServices added in v1.44.0 

func (in *RegistryStatusService) GetRegistryServices(criteria RegistryCriteria) ([]*kubernetes.RegistryService, error)

type ServiceCriteria added in v1.43.0 

type ServiceCriteria struct {
	Cluster                string
	Namespace              string
	IncludeHealth          bool
	IncludeIstioResources  bool
	IncludeOnlyDefinitions bool
	ServiceSelector        string
	RateInterval           string
	QueryTime              time.Time
}

type SpanFilter added in v1.24.0 

type SpanFilter = func(span *jaegerModels.Span) bool

type SvcService 

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

SvcService deals with fetching istio/kubernetes services related content and convert to kiali model

func (*SvcService) GetService 

func (in *SvcService) GetService(ctx context.Context, cluster, namespace, service string) (models.Service, error)

func (*SvcService) GetServiceAppName added in v1.24.0 

func (in *SvcService) GetServiceAppName(ctx context.Context, cluster, namespace, service string) (string, error)

GetServiceAppName returns the "Application" name (app label) that relates to a service This label is taken from the service selector, which means it is assumed that pods are selected using that label

func (*SvcService) GetServiceDetails added in v1.43.0 

func (in *SvcService) GetServiceDetails(ctx context.Context, cluster, namespace, service, interval string, queryTime time.Time) (*models.ServiceDetails, error)

GetService returns a single service and associated data using the interval and queryTime

func (*SvcService) GetServiceList 

func (in *SvcService) GetServiceList(ctx context.Context, criteria ServiceCriteria) (*models.ServiceList, error)

GetServiceList returns a list of all services for a given criteria

func (*SvcService) UpdateService added in v1.30.0 

func (in *SvcService) UpdateService(ctx context.Context, cluster, namespace, service string, interval string, queryTime time.Time, jsonPatch string, patchType string) (*models.ServiceDetails, error)

type TLSService added in v0.16.0 

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

func (*TLSService) MeshWidemTLSStatus added in v0.16.0 

func (in *TLSService) MeshWidemTLSStatus(ctx context.Context, namespaces []string, cluster string) (models.MTLSStatus, error)

func (*TLSService) NamespaceWidemTLSStatus added in v0.16.0 

func (in *TLSService) NamespaceWidemTLSStatus(ctx context.Context, namespace, cluster string) (models.MTLSStatus, error)

type TokenReviewService added in v1.29.0 

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

func NewTokenReview added in v1.29.0 

func NewTokenReview(k8s kubernetes.ClientInterface) TokenReviewService

func (*TokenReviewService) GetTokenSubject added in v1.29.0 

func (in *TokenReviewService) GetTokenSubject(authInfo *api.AuthInfo) (string, error)

type WorkloadCriteria added in v1.43.0 

type WorkloadCriteria struct {
	Cluster               string
	Namespace             string
	WorkloadName          string
	WorkloadType          string
	IncludeIstioResources bool
	IncludeServices       bool
	IncludeHealth         bool
	RateInterval          string
	QueryTime             time.Time
}

type WorkloadService 

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

WorkloadService deals with fetching istio/kubernetes workloads related content and convert to kiali model

func NewWorkloadService added in v1.62.0 

func NewWorkloadService(userClients map[string]kubernetes.ClientInterface, prom prometheus.ClientInterface, cache cache.KialiCache, layer *Layer, config *config.Config) *WorkloadService

func (*WorkloadService) BuildLogOptionsCriteria added in v1.27.0 

func (in *WorkloadService) BuildLogOptionsCriteria(container, duration, isProxy, sinceTime, maxLines string) (*LogOptions, error)

func (*WorkloadService) GetPod added in v0.18.0 

func (in *WorkloadService) GetPod(cluster, namespace, name string) (*models.Pod, error)

func (*WorkloadService) GetWorkload 

func (in *WorkloadService) GetWorkload(ctx context.Context, criteria WorkloadCriteria) (*models.Workload, error)

GetWorkload is the API handler to fetch details of a specific workload. If includeServices is set true, the Workload will fetch all services related

func (*WorkloadService) GetWorkloadAppName added in v1.24.0 

func (in *WorkloadService) GetWorkloadAppName(ctx context.Context, cluster, namespace, workload string) (string, error)

GetWorkloadAppName returns the "Application" name (app label) that relates to a workload

func (*WorkloadService) GetWorkloadList 

func (in *WorkloadService) GetWorkloadList(ctx context.Context, criteria WorkloadCriteria) (models.WorkloadList, error)

GetWorkloadList is the API handler to fetch the list of workloads in a given namespace.

func (*WorkloadService) StreamPodLogs added in v1.53.0 

func (in *WorkloadService) StreamPodLogs(cluster, namespace, name string, opts *LogOptions, w http.ResponseWriter) error

StreamPodLogs streams pod logs to an HTTP Response given the provided options

func (*WorkloadService) UpdateWorkload added in v1.22.0 

func (in *WorkloadService) UpdateWorkload(ctx context.Context, cluster string, namespace string, workloadName string, workloadType string, includeServices bool, jsonPatch string, patchType string) (*models.Workload, error)

Source Files

View all Source files

Directories

Path Synopsis
authorization
common
destinationrules
gateways
k8sgateways
k8shttproutes
peerauthentications
serviceentries
services
sidecars
virtualservices
workloads

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.