kube

Documentation

Index

• type DestinationRuleReconciler
  • func NewDestinationRuleReconciler(client kube.Client, cf *istio.ConfigFactory) *DestinationRuleReconciler
  • func (r *DestinationRuleReconciler) GetTypeUrl() string
  • func (r *DestinationRuleReconciler) Reconcile(ctx context.Context) error
• type EnvoyFilterReconciler
  • func NewEnvoyFilterReconciler(client kube.Client, cf *istio.ConfigFactory) *EnvoyFilterReconciler
  • func (r *EnvoyFilterReconciler) GetTypeUrl() string
  • func (r *EnvoyFilterReconciler) Reconcile(ctx context.Context) error
• type GatewayResourceReconciler
  • func NewGatewayResourceReconciler(client kube.Client, cf *istio.ConfigFactory) *GatewayResourceReconciler
  • func (r *GatewayResourceReconciler) GetTypeUrl() string
  • func (r *GatewayResourceReconciler) Reconcile(ctx context.Context) error
• type PeerAuthResourceReconciler
  • func NewPeerAuthResourceReconciler(client kube.Client, namespace string) *PeerAuthResourceReconciler
  • func (r *PeerAuthResourceReconciler) GetTypeUrl() string
  • func (r *PeerAuthResourceReconciler) Reconcile(ctx context.Context) error
• type Reconciler
• type ReconcilerManager
  • func NewReconcilerManager(pushRequests <-chan xds.PushRequest, reconcilers ...Reconciler) *ReconcilerManager
  • func (rm *ReconcilerManager) ReconcileAll(ctx context.Context) error
  • func (rm *ReconcilerManager) Start(ctx context.Context)
• type RouteReconciler
  • func NewRouteReconciler(client versioned.Interface, cf *openshift.ConfigFactory) *RouteReconciler
  • func (r *RouteReconciler) GetTypeUrl() string
  • func (r *RouteReconciler) Reconcile(ctx context.Context) error
• type ServiceEntryReconciler
  • func NewServiceEntryReconciler(client kube.Client, cf *istio.ConfigFactory) *ServiceEntryReconciler
  • func (r *ServiceEntryReconciler) GetTypeUrl() string
  • func (r *ServiceEntryReconciler) Reconcile(ctx context.Context) error
• type WorkloadEntryReconciler
  • func NewWorkloadEntryReconciler(client kube.Client, cf *istio.ConfigFactory) *WorkloadEntryReconciler
  • func (r *WorkloadEntryReconciler) GetTypeUrl() string
  • func (r *WorkloadEntryReconciler) Reconcile(ctx context.Context) error

Types

type DestinationRuleReconciler

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

func NewDestinationRuleReconciler

func NewDestinationRuleReconciler(client kube.Client, cf *istio.ConfigFactory) *DestinationRuleReconciler

func (*DestinationRuleReconciler) GetTypeUrl

func (r *DestinationRuleReconciler) GetTypeUrl() string

func (*DestinationRuleReconciler) Reconcile

func (r *DestinationRuleReconciler) Reconcile(ctx context.Context) error

type EnvoyFilterReconciler

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

func NewEnvoyFilterReconciler

func NewEnvoyFilterReconciler(client kube.Client, cf *istio.ConfigFactory) *EnvoyFilterReconciler

func (*EnvoyFilterReconciler) GetTypeUrl

func (r *EnvoyFilterReconciler) GetTypeUrl() string

func (*EnvoyFilterReconciler) Reconcile

func (r *EnvoyFilterReconciler) Reconcile(ctx context.Context) error

type GatewayResourceReconciler

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

func NewGatewayResourceReconciler

func NewGatewayResourceReconciler(client kube.Client, cf *istio.ConfigFactory) *GatewayResourceReconciler

func (*GatewayResourceReconciler) GetTypeUrl

func (r *GatewayResourceReconciler) GetTypeUrl() string

func (*GatewayResourceReconciler) Reconcile

func (r *GatewayResourceReconciler) Reconcile(ctx context.Context) error

type PeerAuthResourceReconciler

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

func NewPeerAuthResourceReconciler

func NewPeerAuthResourceReconciler(client kube.Client, namespace string) *PeerAuthResourceReconciler

func (*PeerAuthResourceReconciler) GetTypeUrl

func (r *PeerAuthResourceReconciler) GetTypeUrl() string

func (*PeerAuthResourceReconciler) Reconcile

func (r *PeerAuthResourceReconciler) Reconcile(ctx context.Context) error

type Reconciler

type Reconciler interface {
	// GetTypeUrl returns the K8s API URL for the supported resource type.
	// An implementation can support only one resource type.
	GetTypeUrl() string

	// Reconcile all resources of the K8s resource type.
	Reconcile(ctx context.Context) error
}

Reconciler handles reconciliation of all resources of a K8s kind.

type ReconcilerManager

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

func NewReconcilerManager

func NewReconcilerManager(pushRequests <-chan xds.PushRequest, reconcilers ...Reconciler) *ReconcilerManager

func (*ReconcilerManager) ReconcileAll

func (rm *ReconcilerManager) ReconcileAll(ctx context.Context) error

func (*ReconcilerManager) Start

func (rm *ReconcilerManager) Start(ctx context.Context)

type RouteReconciler

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

func NewRouteReconciler

func NewRouteReconciler(client versioned.Interface, cf *openshift.ConfigFactory) *RouteReconciler

func (*RouteReconciler) GetTypeUrl

func (r *RouteReconciler) GetTypeUrl() string

func (*RouteReconciler) Reconcile

func (r *RouteReconciler) Reconcile(ctx context.Context) error

type ServiceEntryReconciler

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

func NewServiceEntryReconciler

func NewServiceEntryReconciler(client kube.Client, cf *istio.ConfigFactory) *ServiceEntryReconciler

func (*ServiceEntryReconciler) GetTypeUrl

func (r *ServiceEntryReconciler) GetTypeUrl() string

func (*ServiceEntryReconciler) Reconcile

func (r *ServiceEntryReconciler) Reconcile(ctx context.Context) error

type WorkloadEntryReconciler

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

func NewWorkloadEntryReconciler

func NewWorkloadEntryReconciler(client kube.Client, cf *istio.ConfigFactory) *WorkloadEntryReconciler

func (*WorkloadEntryReconciler) GetTypeUrl

func (r *WorkloadEntryReconciler) GetTypeUrl() string

func (*WorkloadEntryReconciler) Reconcile

func (r *WorkloadEntryReconciler) Reconcile(ctx context.Context) error