business

package
v0.9.0-snapshot.1 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2018 License: Apache-2.0 Imports: 19 Imported by: 56

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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, app 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.

Source Files

View all Source files

Directories

Path Synopsis
destination_rules
virtual_services

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.