services

Documentation

Index

• type ClusterService
• type IstioService
• type MeshClusterService
• type MonitorService

Types

type ClusterService

type ClusterService interface {
	// Get cluster
	Get(ctx context.Context, clusterName string) (*platformv1.Cluster, error)
	// List cluster
	List(ctx context.Context) ([]platformv1.Cluster, error)
	// ListNamespaces list cluster's namespaces
	ListNamespaces(ctx context.Context, clusterName string) ([]corev1.Namespace, error)
	// ListServices
	ListServices(ctx context.Context, clusterName, namespace string, selector labels.Selector) ([]corev1.Service, error)
	// Proxy proxy to Kubernetes api server
	Proxy(ctx context.Context, clusterName string) (transport http.RoundTripper, host string, err error)
}

ClusterService cluster service interface

type IstioService

type IstioService interface {
	ListAllResources(
		ctx context.Context, clusterName, namespace, kind string, selector labels.Selector,
	) (map[string][]unstructured.Unstructured, *errors.MultiError)

	ListGateways(ctx context.Context, clusterName, namespace string) ([]istionetworking.Gateway, error)
	ListVirtualServices(ctx context.Context, clusterName, namespace string) ([]istionetworking.VirtualService, error)
	ListDestinationRules(ctx context.Context, clusterName, namespace string) ([]istionetworking.DestinationRule, error)
	ListServiceEntries(ctx context.Context, clusterName, namespace string) ([]istionetworking.ServiceEntry, error)

	ListResources(ctx context.Context, clusterName string, obj runtime.Object, opt ...ctrlclient.ListOption) error
	GetResource(ctx context.Context, clusterName string, obj runtime.Object) error
	CreateResource(ctx context.Context, clusterName string, obj runtime.Object) (bool, error)
	UpdateResource(ctx context.Context, clusterName string, obj runtime.Object) (bool, error)
	DeleteResource(ctx context.Context, clusterName string, obj runtime.Object) (bool, error)

	CreateNorthTrafficGateway(ctx context.Context, clusterName string, obj *models.IstioNetworkingConfig) (bool, error)
	UpdateNorthTrafficGateway(ctx context.Context, clusterName string, obj *models.IstioNetworkingConfig) (bool, error)
	DeleteNorthTrafficGateway(ctx context.Context, clusterName string, gateway *istionetworking.Gateway) (bool, error)
	GetNorthTrafficGateway(
		ctx context.Context, clusterName string, gateway *istionetworking.Gateway,
	) (*models.IstioNetworkingConfig, error)
}

IstioService istio resource service interface

type MeshClusterService

type MeshClusterService interface {
	// ListMicroServices
	//  if namespace empty, list all namespaces services
	//  if serviceName empty, list all services
	ListMicroServices(
		ctx context.Context, meshName, namespace, serviceName string, selector labels.Selector,
	) ([]rest.MicroService, *errors.MultiError)

	// CreateMeshResource create istio resource to all mesh's main clusters
	CreateMeshResource(ctx context.Context, meshName string, obj *unstructured.Unstructured) error
}

MeshClusterService

type MonitorService

type MonitorService interface {
	GetTracingMetricsData(ctx context.Context, query rest.MetricQuery) (*rest.MetricData, error)
	GetMonitorMetricsData(ctx context.Context, query *rest.MetricQuery) (*rest.MetricData, error)
	GetMonitorTopologyData(ctx context.Context, query *rest.TopoQuery) (*rest.TopoData, error)
}

MonitorService