kiali

package
v1.83.0 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BOOKINFO = "bookinfo"
	ASSETS   = "tests/integration/assets"
	TIMEOUT  = 10 * time.Second
)

Variables

This section is empty.

Functions

func AppVersionGraph 

func AppVersionGraph(graphType, name, version, namespace string) (*cytoscape.Config, int, error)

func ApplicationDetails 

func ApplicationDetails(name, namespace string) (*models.App, int, error)

func ApplicationsList 

func ApplicationsList(namespace string) (*models.ClusterApps, error)

func Clusters added in v1.79.0 

func Clusters() ([]kubernetes.Cluster, error)

func ClustersTls added in v1.81.0 

func ClustersTls(namespace string) (*[]models.MTLSStatus, int, error)

func FirstPodName 

func FirstPodName(name, namespace string) (string, error)

func Grafana 

func Grafana() (*models.GrafanaInfo, int, error)

func Graph 

func Graph(params map[string]string) (*cytoscape.Config, int, error)

func IstioApiEnabled 

func IstioApiEnabled() (bool, error)

func IstioConfigDetails 

func IstioConfigDetails(namespace, name, configType string) (*models.IstioConfigDetails, int, error)

func IstioConfigPermissions 

func IstioConfigPermissions(namespace string) (*models.IstioConfigPermissions, error)

func IstioPermissions 

func IstioPermissions() (*models.IstioConfigPermissions, int, error)

func KialiConfig 

func KialiConfig() (*handlers.PublicConfig, int, error)

func KialiStatus 

func KialiStatus() (bool, int, error)

func Mesh added in v1.82.0 

func Mesh() (*business.Mesh, error)

func MeshTls 

func MeshTls() (*models.MTLSStatus, int, error)

func NamespaceAppHealth 

func NamespaceAppHealth(namespace string, params map[string]string) (*models.NamespaceAppHealth, int, error)

func NamespaceServiceHealth 

func NamespaceServiceHealth(namespace string, params map[string]string) (*models.NamespaceServiceHealth, int, error)

func NamespaceWorkloadHealth 

func NamespaceWorkloadHealth(namespace string, params map[string]string) (*models.NamespaceWorkloadHealth, int, error)

func Namespaces 

func Namespaces() (*models.Namespaces, int, error)

func ObjectDashboard 

func ObjectDashboard(namespace, name, objectType string) (*models.MonitoringDashboard, error)

func ObjectGraph 

func ObjectGraph(objectType, graphType, name, namespace string) (*cytoscape.Config, int, error)

func ParamsAsString 

func ParamsAsString(params map[string]string) string

func PodLogs 

func PodLogs(name, namespace string, params map[string]string) (*business.PodLog, error)

func Spans 

func Spans(objectType, name, namespace string) ([]model.TracingSpan, int, error)

func TimeSince 

func TimeSince() int64

func TimeSinceSeconds 

func TimeSinceSeconds() int64

func Traces 

func Traces(objectType, name, namespace string) (*model.TracingResponse, int, error)

func Tracing added in v1.75.0 

func Tracing() (*models.TracingInfo, int, error)

Types

type AuthStrategy 

type AuthStrategy struct {
	Strategy string `json:"strategy"`
}

type Instance added in v1.79.0 

type Instance struct {

	// Name of the kiali instance. Either the name of the CR or the name of the deployment.
	Name string

	// Namespace of the kiali instance. Either the namespace of the CR or the namespace of the deployment.
	Namespace string

	// ResourceNamespace is the namespace where the Kiali resources are deployed aka spec.deployment.namespace.
	ResourceNamespace string
	// contains filtered or unexported fields
}

Instance is a single deployment of Kiali. It abstracts away the differences between Kiali deployed with the operator and Kiali deployed with helm and provides an interface for interacting with the Kiali instance for actions like updating the Kiali config.

func NewInstance added in v1.79.0 

func NewInstance(ctx context.Context, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface) (*Instance, error)

NewInstance finds the kiali instance deployed in the cluster and creates an Instance out of it. Assumes there's only a single Kiali deployed to the cluster.

func (*Instance) GetConfig added in v1.79.0 

func (in *Instance) GetConfig(ctx context.Context) (*config.Config, error)

GetConfig fetches the kiali configuration from the kiali configmap.

func (*Instance) Restart added in v1.79.0 

func (in *Instance) Restart(ctx context.Context) error

Restart will recreate the Kiali pod and wait for it to be ready.

func (*Instance) UpdateConfig added in v1.79.0 

func (in *Instance) UpdateConfig(ctx context.Context, conf *config.Config) error

UpdateConfig will update the Kiali instance with the new config. It will ensure that the underlying configmap is actually updated before returning.

type IstioConfigListJson 

type IstioConfigListJson struct {
	models.IstioConfigList
	// TODO merge with IstioConfigList and have IstioValidations instead
	IstioValidations ObjectValidations `json:"validations"`
}

func IstioConfigs 

func IstioConfigs() (*IstioConfigListJson, error)

func IstioConfigsList 

func IstioConfigsList(namespace string) (*IstioConfigListJson, error)

type IstioConfigMapJson 

type IstioConfigMapJson map[string]*IstioConfigListJson

type KialiClient 

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

func NewKialiClient 

func NewKialiClient() (c *KialiClient)

func (*KialiClient) GetAuth 

func (c *KialiClient) GetAuth() *config.Auth

func (*KialiClient) GetCookies 

func (c *KialiClient) GetCookies() (bool, []*http.Cookie)

func (*KialiClient) KialiAuthStrategy 

func (c *KialiClient) KialiAuthStrategy() (string, error)

type MetricJson 

type MetricJson struct {
	Labels     map[string]string `json:"labels"`
	Datapoints []interface{}     `json:"datapoints"`
	Stat       string            `json:"stat,omitempty"`
	Name       string            `json:"name"`
}

type MetricsJson 

type MetricsJson struct {
	GrpcReceived          []MetricJson `json:"grpc_received,omitempty"`
	GrpcSent              []MetricJson `json:"grpc_sent,omitempty"`
	RequestCount          []MetricJson `json:"request_count,omitempty"`
	RequestErrorCount     []MetricJson `json:"request_error_count,omitempty"`
	RequestDurationMillis []MetricJson `json:"request_duration_millis,omitempty"`
	RequestThroughput     []MetricJson `json:"request_throughput,omitempty"`
	ResponseThroughput    []MetricJson `json:"response_throughput,omitempty"`
	RequestSize           []MetricJson `json:"request_size,omitempty"`
	ResponseSize          []MetricJson `json:"response_size,omitempty"`
	TcpReceived           []MetricJson `json:"tcp_received,omitempty"`
	TcpSent               []MetricJson `json:"tcp_sent,omitempty"`
	TcpOpened             []MetricJson `json:"tcp_opened,omitempty"`
	TcpClosed             []MetricJson `json:"tcp_closed,omitempty"`
}

MetricsJson contains all simple metrics and histograms data for standard timeseries queries

func NamespaceMetrics 

func NamespaceMetrics(namespace string, params map[string]string) (*MetricsJson, error)

func ObjectMetrics 

func ObjectMetrics(namespace, service, objectType string, params map[string]string) (*MetricsJson, error)

type MetricsJsonMap added in v1.81.0 

type MetricsJsonMap map[string]*MetricsJson

MetricsJsonMap contains map to namespace and MetricsJson

func ClustersMetrics added in v1.81.0 

func ClustersMetrics(namespace string, params map[string]string) (*MetricsJsonMap, error)

type ObjectValidations 

type ObjectValidations map[string]map[string]*models.IstioValidation

ObjectValidations represents a set of IstioValidation grouped by Object type and name.

type ServiceDetailsJson 

type ServiceDetailsJson struct {
	models.ServiceDetails
	// TODO merge with ServiceDetails and have IstioValidations instead
	Validations ObjectValidations `json:"validations"`
}

func ServiceDetails 

func ServiceDetails(name, namespace string) (*ServiceDetailsJson, int, error)

type ServiceListJson 

type ServiceListJson struct {
	models.ServiceList
	// TODO merge with ServiceList and have IstioValidations instead
	Validations ObjectValidations `json:"validations"`
}

func ServicesList 

func ServicesList(namespace string) (*ServiceListJson, error)

type WorkloadJson 

type WorkloadJson struct {
	models.Workload
	// TODO merge with Workload and have IstioValidations instead
	Validations ObjectValidations `json:"validations"`
}

func WorkloadDetails 

func WorkloadDetails(name, namespace string) (*WorkloadJson, int, error)

type WorkloadListJson 

type WorkloadListJson struct {
	models.WorkloadList
	// TODO merge with WorkloadList and have IstioValidations instead
	Validations ObjectValidations `json:"validations"`
}

func WorkloadsList 

func WorkloadsList(namespace string) (*WorkloadListJson, error)

Source Files

View all Source files

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.