istio

package
v1.6.2 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 32 Imported by: 1

Documentation

Index

Constants

View Source 
const Http = "http"
View Source 
const SpecHttpNotFound = "spec.http not found"
View Source 
const Tcp = "tcp"
View Source 
const Tls = "tls"
View Source 
const Type = "Istio"

Variables

This section is empty.

Functions

func GetHttpRoutesI added in v0.9.0 

func GetHttpRoutesI(obj *unstructured.Unstructured) ([]interface{}, error)

func GetTcpRoutesI added in v1.4.0 

func GetTcpRoutesI(obj *unstructured.Unstructured) ([]interface{}, error)

func GetTlsRoutesI added in v1.1.0 

func GetTlsRoutesI(obj *unstructured.Unstructured) ([]interface{}, error)

func UnmarshalJson added in v1.0.2 

func UnmarshalJson(input []byte, result interface{}) (map[string]interface{}, error)

func ValidateHTTPRoutes added in v0.9.0 

func ValidateHTTPRoutes(r *v1alpha1.Rollout, routeNames []string, httpRoutes []VirtualServiceHTTPRoute) error

ValidateHTTPRoutes ensures that all the routes in the rollout exist

func ValidateTcpRoutes added in v1.4.0 

func ValidateTcpRoutes(r *v1alpha1.Rollout, vsvcTCPRoutes []v1alpha1.TCPRoute, tcpRoutes []VirtualServiceTCPRoute) error

ValidateTcpRoutes ensures that all the routes in the rollout exist and they only have two destinations

func ValidateTlsRoutes added in v1.1.0 

func ValidateTlsRoutes(r *v1alpha1.Rollout, vsvcTLSRoutes []v1alpha1.TLSRoute, tlsRoutes []VirtualServiceTLSRoute) error

ValidateTlsRoutes ensures that all the routes in the rollout exist and they only have two destinations

Types

type DestinationRule added in v1.0.0 

type DestinationRule struct {
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DestinationRuleSpec `json:"spec,omitempty"`
}

DestinationRule is an Istio DestinationRule containing only the fields which we care about

type DestinationRuleSpec added in v1.0.0 

type DestinationRuleSpec struct {
	Host    string   `json:"host,omitempty"`
	Subsets []Subset `json:"subsets,omitempty"`
}

type IstioController added in v1.0.0 

type IstioController struct {
	IstioControllerConfig
	VirtualServiceLister  dynamiclister.Lister
	DestinationRuleLister dynamiclister.Lister
	// contains filtered or unexported fields
}

func NewIstioController added in v1.0.0 

func NewIstioController(cfg IstioControllerConfig) *IstioController

func (*IstioController) EnqueueDestinationRule added in v1.0.0 

func (c *IstioController) EnqueueDestinationRule(obj interface{})

EnqueueDestinationRule examines a VirtualService, finds the Rollout referencing that VirtualService, and enqueues the corresponding Rollout for reconciliation

func (*IstioController) EnqueueRolloutFromIstioVirtualService added in v1.0.0 

func (c *IstioController) EnqueueRolloutFromIstioVirtualService(vsvc interface{})

EnqueueRolloutFromIstioVirtualService examines a VirtualService, finds the Rollout referencing that VirtualService, and enqueues the corresponding Rollout for reconciliation

func (*IstioController) GetReferencedVirtualServices added in v1.0.0 

func (c *IstioController) GetReferencedVirtualServices(ro *v1alpha1.Rollout) (*[]unstructured.Unstructured, error)

func (*IstioController) Run added in v1.0.0 

func (c *IstioController) Run(ctx context.Context)

Run starts the Istio informers. If Istio is not installed, will periodically check for presence of Istio, then start informers once detected. This allows Argo Rollouts to be installed in any order during cluster bootstrapping.

func (*IstioController) ShutDownWithDrain added in v1.4.0 

func (c *IstioController) ShutDownWithDrain()

type IstioControllerConfig added in v1.0.0 

type IstioControllerConfig struct {
	ArgoprojClientSet       roclientset.Interface
	DynamicClientSet        dynamic.Interface
	EnqueueRollout          func(ro interface{})
	RolloutsInformer        informers.RolloutInformer
	VirtualServiceInformer  cache.SharedIndexInformer
	DestinationRuleInformer cache.SharedIndexInformer
}

type L4MatchAttributes added in v1.4.0 

type L4MatchAttributes struct {
	DestinationSubnets []string          `json:"destinationSubnets,omitempty"`
	Port               int64             `json:"port,omitempty"`
	SourceLabels       map[string]string `json:"sourceLabels,omitempty"`
	Gateways           []string          `json:"gateways,omitempty"`
	SourceNamespace    string            `json:"sourceNamespace,omitempty"`
}

L4MatchAttributes is the route matcher for a TCP route in a VirtualService

type Percent added in v1.3.0 

type Percent struct {
	Value float64 `json:"value,omitempty"`
}

type Port added in v1.3.1 

type Port struct {
	Number uint32 `json:"number,omitempty"`
}

type Reconciler 

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

Reconciler holds required fields to reconcile Istio resources

func NewReconciler 

func NewReconciler(r *v1alpha1.Rollout, client dynamic.Interface, recorder record.EventRecorder, virtualServiceLister, destinationRuleLister dynamiclister.Lister) *Reconciler

NewReconciler returns a reconciler struct that brings the Virtual Service into the desired state

func (*Reconciler) RemoveManagedRoutes added in v1.3.0 

func (r *Reconciler) RemoveManagedRoutes() error

RemoveManagedRoutes this removes all the routes in all the istio virtual services rollouts is managing by getting two slices from the splitManagedRoutesAndNonManagedRoutes function and setting the Istio Virtual Service routes to just the ones not managed by rollouts

func (*Reconciler) SetHeaderRoute added in v1.3.0 

func (r *Reconciler) SetHeaderRoute(headerRouting *v1alpha1.SetHeaderRoute) error

func (*Reconciler) SetMirrorRoute added in v1.3.0 

func (r *Reconciler) SetMirrorRoute(setMirrorRoute *v1alpha1.SetMirrorRoute) error

func (*Reconciler) SetWeight added in v1.0.0 

func (r *Reconciler) SetWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) error

SetWeight modifies Istio resources to reach desired state

func (*Reconciler) Type 

func (r *Reconciler) Type() string

Type indicates this reconciler is an Istio reconciler

func (*Reconciler) UpdateHash added in v1.0.0 

func (r *Reconciler) UpdateHash(canaryHash, stableHash string, additionalDestinations ...v1alpha1.WeightDestination) error

func (*Reconciler) VerifyWeight added in v1.0.0 

func (r *Reconciler) VerifyWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) (*bool, error)

type RouteMatch added in v1.3.0 

type RouteMatch struct {
	// Method What http methods should be mirrored
	// +optional
	Method *v1alpha1.StringMatch `json:"method,omitempty" protobuf:"bytes,1,opt,name=method"`
	// Uri What url paths should be mirrored
	// +optional
	Uri *v1alpha1.StringMatch `json:"uri,omitempty" protobuf:"bytes,2,opt,name=uri"`
	// Headers What request with matching headers should be mirrored
	// +optional
	Headers map[string]v1alpha1.StringMatch `json:"headers,omitempty" protobuf:"bytes,3,opt,name=headers"`
}

type Subset added in v1.0.0 

type Subset struct {
	Name   string            `json:"name,omitempty"`
	Labels map[string]string `json:"labels,omitempty"`
	// TrafficPolicy *json.RawMessage  `json:"trafficPolicy,omitempty"`
	Extra map[string]interface{} `json:",omitempty"`
}

type TLSMatchAttributes added in v1.1.0 

type TLSMatchAttributes struct {
	SNI                []string          `json:"sniHosts,omitempty"`
	DestinationSubnets []string          `json:"destinationSubnets,omitempty"`
	Port               int64             `json:"port,omitempty"`
	SourceLabels       map[string]string `json:"sourceLabels,omitempty"`
	Gateways           []string          `json:"gateways,omitempty"`
	SourceNamespace    string            `json:"sourceNamespace,omitempty"`
}

TLSMatchAttributes is the route matcher for a TLS route in a VirtualService

type VirtualService added in v1.0.0 

type VirtualService struct {
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              VirtualServiceSpec `json:"spec,omitempty"`
}

VirtualService is an Istio VirtualService containing only the fields which we care about

type VirtualServiceDestination added in v1.0.0 

type VirtualServiceDestination struct {
	Host   string `json:"host,omitempty"`
	Subset string `json:"subset,omitempty"`
	Port   *Port  `json:"port,omitempty"`
}

Destination fields within the VirtualServiceDestination struct of the Virtual Service that the controller modifies

type VirtualServiceHTTPRoute added in v1.0.0 

type VirtualServiceHTTPRoute struct {
	Name             string                           `json:"name,omitempty"`
	Match            []RouteMatch                     `json:"match,omitempty"`
	Route            []VirtualServiceRouteDestination `json:"route,omitempty"`
	Mirror           *VirtualServiceDestination       `json:"mirror,omitempty"`
	MirrorPercentage *Percent                         `json:"mirrorPercentage,omitempty"`
}

VirtualServiceHTTPRoute is a HTTP route in a VirtualService

func GetHttpRoutes added in v0.9.0 

func GetHttpRoutes(httpRoutesI []interface{}) ([]VirtualServiceHTTPRoute, error)

type VirtualServiceRouteDestination added in v1.1.0 

type VirtualServiceRouteDestination struct {
	// Destination holds the destination struct of the virtual service
	Destination VirtualServiceDestination `json:"destination,omitempty"`
	// Weight holds the destination struct of the virtual service
	Weight int64 `json:"weight,omitempty"`
}

VirtualServiceRouteDestination is a destination within { VirtualServiceHTTPRoute, VirtualServiceTLSRoute }

type VirtualServiceSpec added in v1.0.0 

type VirtualServiceSpec struct {
	HTTP []VirtualServiceHTTPRoute `json:"http,omitempty"`
	TLS  []VirtualServiceTLSRoute  `json:"tls,omitempty"`
	TCP  []VirtualServiceTCPRoute  `json:"tcp,omitempty"`
}

type VirtualServiceTCPRoute added in v1.4.0 

type VirtualServiceTCPRoute struct {
	Match []L4MatchAttributes              `json:"match,omitempty"`
	Route []VirtualServiceRouteDestination `json:"route,omitempty"`
}

VirtualServiceTCPRoute is a TLS route in a VirtualService

func GetTcpRoutes added in v1.4.0 

func GetTcpRoutes(obj *unstructured.Unstructured, tcpRoutesI []interface{}) ([]VirtualServiceTCPRoute, error)

type VirtualServiceTLSRoute added in v1.1.0 

type VirtualServiceTLSRoute struct {
	Match []TLSMatchAttributes             `json:"match,omitempty"`
	Route []VirtualServiceRouteDestination `json:"route,omitempty"`
}

VirtualServiceTLSRoute is a TLS route in a VirtualService

func GetTlsRoutes added in v1.1.0 

func GetTlsRoutes(obj *unstructured.Unstructured, tlsRoutesI []interface{}) ([]VirtualServiceTLSRoute, 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.