business

package
v0.10.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	VirtualServices   = "virtualservices"
	DestinationRules  = "destinationrules"
	ServiceEntries    = "serviceentries"
	Gateways          = "gateways"
	Rules             = "rules"
	QuotaSpecs        = "quotaspecs"
	QuotaSpecBindings = "quotaspecbindings"
)

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 FakeDuplicatedDeployments added in v0.9.1 

func FakeDuplicatedDeployments() []v1beta1.Deployment

func FakeDuplicatedReplicaSets added in v0.9.1 

func FakeDuplicatedReplicaSets() []v1beta2.ReplicaSet

func FakeDuplicatedStatefulSets added in v0.9.1 

func FakeDuplicatedStatefulSets() []v1beta2.StatefulSet

func FakePodsFromDaemonSet 

func FakePodsFromDaemonSet() []v1.Pod

func FakePodsNoController 

func FakePodsNoController() []v1.Pod

func FakePodsSyncedWithDeployments 

func FakePodsSyncedWithDeployments() []v1.Pod

func FakePodsSyncedWithDuplicated added in v0.9.1 

func FakePodsSyncedWithDuplicated() []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

func GetIstioAPI added in v0.9.1 

func GetIstioAPI(resourceType string) string

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

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, queryTime time.Time) (*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, queryTime time.Time) (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, queryTime time.Time) (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, queryTime time.Time) (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, queryTime time.Time) (*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, queryTime time.Time) (*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) DeleteIstioConfigDetail added in v0.9.1 

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

DeleteIstioConfigDetail deletes the given Istio resource

func (*IstioConfigService) GetIstioConfigDetails 

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

func (*IstioConfigService) GetIstioConfigList added in v0.9.1 

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

GetIstioConfigList returns a list of Istio routing objects, Mixer Rules, (etc.) per a given Namespace.

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
	// contains filtered or unexported fields
}

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 NewWithBackends added in v0.10.0 

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

NewWithBackends creates the business layer using the passed k8s and prom clients

func SetWithBackends 

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

SetWithBackends creates all services with injected clients to external APIs

func (*Layer) Stop added in v0.9.1 

func (in *Layer) Stop()

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) GetNamespace added in v0.9.1 

func (in *NamespaceService) GetNamespace(namespace string) (*models.Namespace, error)

GetNamespace returns the definition of the specified namespace.

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, queryTime time.Time) (*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
destinationrules
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.