business

Documentation

Index

• func FakeDepSyncedWithRS() []v1beta1.Deployment
• func FakeDeploymentConfigs() []osappsv1.DeploymentConfig
• func FakeDeployments() []v1beta1.Deployment
• func FakePodsFromDaemonSet() []v1.Pod
• func FakePodsNoController() []v1.Pod
• func FakePodsSyncedWithDeployments() []v1.Pod
• func FakeRSSyncedWithPods() []v1beta2.ReplicaSet
• func FakeReplicaSets() []v1beta2.ReplicaSet
• func FakeReplicationControllers() []v1.ReplicationController
• func FakeServices() []v1.Service
• func FakeStatefulSets() []v1beta2.StatefulSet
• type AppService
  • func (in *AppService) GetApp(namespace string, appName string) (models.App, error)
  • func (in *AppService) GetAppList(namespace string) (models.AppList, error)
• type HealthService
  • func (in *HealthService) GetAppHealth(namespace, app, rateInterval string) (*models.AppHealth, error)
  • func (in *HealthService) GetNamespaceAppHealth(namespace, rateInterval string) (models.NamespaceAppHealth, error)
  • func (in *HealthService) GetNamespaceServiceHealth(namespace, rateInterval string) (models.NamespaceServiceHealth, error)
  • func (in *HealthService) GetNamespaceWorkloadHealth(namespace, rateInterval string) (models.NamespaceWorkloadHealth, error)
  • func (in *HealthService) GetServiceHealth(namespace, service, rateInterval string) (*models.ServiceHealth, error)
  • func (in *HealthService) GetWorkloadHealth(namespace, workload, rateInterval string) (*models.WorkloadHealth, error)
• type IstioConfigCriteria
• type IstioConfigService
  • func (in *IstioConfigService) GetIstioConfig(criteria IstioConfigCriteria) (models.IstioConfigList, error)
  • func (in *IstioConfigService) GetIstioConfigDetails(namespace string, objectType string, object string) (models.IstioConfigDetails, error)
• type IstioValidationsService
  • func (in *IstioValidationsService) GetIstioObjectValidations(namespace string, objectType string, object string) (models.IstioValidations, error)
  • func (in *IstioValidationsService) GetNamespaceValidations(namespace string) (models.NamespaceValidations, error)
  • func (in *IstioValidationsService) GetServiceValidations(namespace, service string) (models.IstioValidations, error)
• type Layer
  • func Get() (*Layer, error)
  • func SetWithBackends(k8s kubernetes.IstioClientInterface, prom prometheus.ClientInterface) *Layer
• type NamespaceService
  • func NewNamespaceService(k8s kubernetes.IstioClientInterface) NamespaceService
  • func (in *NamespaceService) GetNamespaces() ([]models.Namespace, error)
• type ObjectChecker
• type SvcService
  • func (in *SvcService) GetService(namespace, service, interval string) (*models.ServiceDetails, error)
  • func (in *SvcService) GetServiceList(namespace string) (*models.ServiceList, error)
• type WorkloadService
  • func (in *WorkloadService) GetPods(namespace string, labelSelector string) (models.Pods, error)
  • func (in *WorkloadService) GetWorkload(namespace string, workloadName string, includeServices bool) (*models.Workload, error)
  • func (in *WorkloadService) GetWorkloadList(namespace string) (models.WorkloadList, error)

Functions

func FakeDepSyncedWithRS

func FakeDepSyncedWithRS() []v1beta1.Deployment

func FakeDeploymentConfigs

func FakeDeploymentConfigs() []osappsv1.DeploymentConfig

func FakeDeployments

func FakeDeployments() []v1beta1.Deployment

func FakePodsFromDaemonSet

func FakePodsFromDaemonSet() []v1.Pod

func FakePodsNoController

func FakePodsNoController() []v1.Pod

func FakePodsSyncedWithDeployments

func FakePodsSyncedWithDeployments() []v1.Pod

func FakeRSSyncedWithPods

func FakeRSSyncedWithPods() []v1beta2.ReplicaSet

func FakeReplicaSets

func FakeReplicaSets() []v1beta2.ReplicaSet

func FakeReplicationControllers

func FakeReplicationControllers() []v1.ReplicationController

func FakeServices

func FakeServices() []v1.Service

func FakeStatefulSets

func FakeStatefulSets() []v1beta2.StatefulSet

Types

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) GetApp

func (in *AppService) GetApp(namespace string, appName string) (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(namespace string) (models.AppList, error)

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

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(namespace, app, rateInterval string) (*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(namespace, rateInterval string) (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(namespace, rateInterval string) (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(namespace, rateInterval string) (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(namespace, service, rateInterval string) (*models.ServiceHealth, error)

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

func (*HealthService) GetWorkloadHealth

func (in *HealthService) GetWorkloadHealth(namespace, workload, rateInterval string) (*models.WorkloadHealth, error)

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

type IstioConfigCriteria

type IstioConfigCriteria struct {
	Namespace                string
	IncludeGateways          bool
	IncludeVirtualServices   bool
	IncludeDestinationRules  bool
	IncludeServiceEntries    bool
	IncludeRules             bool
	IncludeQuotaSpecs        bool
	IncludeQuotaSpecBindings bool
}

type IstioConfigService

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

func (*IstioConfigService) GetIstioConfig

func (in *IstioConfigService) GetIstioConfig(criteria IstioConfigCriteria) (models.IstioConfigList, error)

GetIstioConfig returns a list of Istio routing objects and Mixer Rules per a given Namespace.

func (*IstioConfigService) GetIstioConfigDetails

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

type IstioValidationsService

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

func (*IstioValidationsService) GetIstioObjectValidations

func (in *IstioValidationsService) GetIstioObjectValidations(namespace string, objectType string, object string) (models.IstioValidations, error)

func (*IstioValidationsService) GetNamespaceValidations

func (in *IstioValidationsService) GetNamespaceValidations(namespace string) (models.NamespaceValidations, error)

func (*IstioValidationsService) GetServiceValidations

func (in *IstioValidationsService) GetServiceValidations(namespace, service string) (models.IstioValidations, error)

GetServiceValidations returns an IstioValidations object with all the checks found when running all the enabled checkers.

type Layer

type Layer struct {
	Svc         SvcService
	Health      HealthService
	Validations IstioValidationsService
	IstioConfig IstioConfigService
	Workload    WorkloadService
	App         AppService
	Namespace   NamespaceService
}

Layer is a container for fast access to inner services

func Get

func Get() (*Layer, error)

Get the business.Layer, create it if necessary

func SetWithBackends

func SetWithBackends(k8s kubernetes.IstioClientInterface, prom prometheus.ClientInterface) *Layer

SetWithBackends creates all services with injected clients to external APIs

type NamespaceService

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

Namespace deals with fetching k8s namespaces / OpenShift projects and convert to kiali model

func NewNamespaceService

func NewNamespaceService(k8s kubernetes.IstioClientInterface) NamespaceService

func (*NamespaceService) GetNamespaces

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

Returns a list of the given namespaces / projects

type ObjectChecker

type ObjectChecker interface {
	Check() models.IstioValidations
}

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(namespace, service, interval string) (*models.ServiceDetails, error)

GetService returns a single service

func (*SvcService) GetServiceList

func (in *SvcService) GetServiceList(namespace string) (*models.ServiceList, error)

GetServiceList returns a list of all services for a given Namespace

type WorkloadService

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

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

func (*WorkloadService) GetPods

func (in *WorkloadService) GetPods(namespace string, labelSelector string) (models.Pods, error)

func (*WorkloadService) GetWorkload

func (in *WorkloadService) GetWorkload(namespace string, workloadName string, includeServices bool) (*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) GetWorkloadList

func (in *WorkloadService) GetWorkloadList(namespace string) (models.WorkloadList, error)

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