Documentation ¶
Index ¶
- Constants
- func AlwaysUpdateEnvoyFilter(existingObj, desiredObj client.Object) (bool, error)
- func HasKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer KuadrantAuthorizer) (bool, error)
- func IsAuthorizationPolicyInstalled(restMapper meta.RESTMapper) (bool, error)
- func IsEnvoyFilterInstalled(restMapper meta.RESTMapper) (bool, error)
- func IsIstioInstalled(restMapper meta.RESTMapper) (bool, error)
- func IsWASMPluginInstalled(restMapper meta.RESTMapper) (bool, error)
- func LimitadorClusterPatch(limitadorSvcHost string, limitadorGRPCPort int) ([]*istioapiv1alpha3.EnvoyFilter_EnvoyConfigObjectPatch, error)
- func PolicyTargetRefFromGateway(gateway *gatewayapiv1.Gateway) *istiocommon.PolicyTargetReference
- func RegisterKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer authorizer) error
- func UnregisterKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer authorizer) error
- func WASMPluginMutator(existingObj, desiredObj client.Object) (bool, error)
- func WorkloadSelectorFromGateway(ctx context.Context, k8sClient client.Client, gateway *gatewayapiv1.Gateway) *istiocommon.WorkloadSelector
- type ConfigMapWrapper
- type ConfigWrapper
- type KuadrantAuthorizer
- type OSSMControlPlaneWrapper
- type OperatorWrapper
- type SailWrapper
Constants ¶
const (
ExtAuthorizerName = "kuadrant-authorization"
)
Variables ¶
This section is empty.
Functions ¶
func AlwaysUpdateEnvoyFilter ¶ added in v0.2.0
func HasKuadrantAuthorizer ¶ added in v0.10.0
func HasKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer KuadrantAuthorizer) (bool, error)
HasKuadrantAuthorizer returns true if the IstioOperator has the Kuadrant ExtensionProvider
func IsAuthorizationPolicyInstalled ¶ added in v0.10.0
func IsAuthorizationPolicyInstalled(restMapper meta.RESTMapper) (bool, error)
func IsEnvoyFilterInstalled ¶
func IsEnvoyFilterInstalled(restMapper meta.RESTMapper) (bool, error)
func IsIstioInstalled ¶
func IsIstioInstalled(restMapper meta.RESTMapper) (bool, error)
func IsWASMPluginInstalled ¶
func IsWASMPluginInstalled(restMapper meta.RESTMapper) (bool, error)
func LimitadorClusterPatch ¶ added in v0.2.0
func LimitadorClusterPatch(limitadorSvcHost string, limitadorGRPCPort int) ([]*istioapiv1alpha3.EnvoyFilter_EnvoyConfigObjectPatch, error)
LimitadorClusterPatch returns an EnvoyFilter patch that adds a custom cluster entry to compensate for kuadrant/limitador#53. Note: This should be removed once the mentioned issue is fixed but that will take some time.
func PolicyTargetRefFromGateway ¶ added in v0.8.0
func PolicyTargetRefFromGateway(gateway *gatewayapiv1.Gateway) *istiocommon.PolicyTargetReference
func RegisterKuadrantAuthorizer ¶ added in v0.10.0
func RegisterKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer authorizer) error
RegisterKuadrantAuthorizer adds the Kuadrant ExtensionProvider to the IstioOperator
func UnregisterKuadrantAuthorizer ¶ added in v0.10.0
func UnregisterKuadrantAuthorizer(configWrapper ConfigWrapper, authorizer authorizer) error
UnregisterKuadrantAuthorizer removes the Kuadrant ExtensionProvider from the IstioOperator
func WASMPluginMutator ¶ added in v0.10.0
func WorkloadSelectorFromGateway ¶ added in v0.7.0
func WorkloadSelectorFromGateway(ctx context.Context, k8sClient client.Client, gateway *gatewayapiv1.Gateway) *istiocommon.WorkloadSelector
Types ¶
type ConfigMapWrapper ¶ added in v0.4.0
type ConfigMapWrapper struct {
// contains filtered or unexported fields
}
ConfigMapWrapper wraps the ConfigMap holding the Istio MeshConfig
func NewConfigMapWrapper ¶ added in v0.4.0
func NewConfigMapWrapper(config *corev1.ConfigMap) *ConfigMapWrapper
NewConfigMapWrapper creates a new ConfigMapWrapper
func (*ConfigMapWrapper) GetConfigObject ¶ added in v0.4.0
func (w *ConfigMapWrapper) GetConfigObject() client.Object
GetConfigObject returns the ConfigMap
func (*ConfigMapWrapper) GetMeshConfig ¶ added in v0.4.0
func (w *ConfigMapWrapper) GetMeshConfig() (*istiomeshv1alpha1.MeshConfig, error)
GetMeshConfig returns the MeshConfig from the ConfigMap
func (*ConfigMapWrapper) SetMeshConfig ¶ added in v0.4.0
func (w *ConfigMapWrapper) SetMeshConfig(config *istiomeshv1alpha1.MeshConfig) error
SetMeshConfig sets the MeshConfig in the ConfigMap
type ConfigWrapper ¶ added in v0.10.0
type ConfigWrapper interface { GetConfigObject() client.Object GetMeshConfig() (*istiomeshv1alpha1.MeshConfig, error) SetMeshConfig(*istiomeshv1alpha1.MeshConfig) error }
type KuadrantAuthorizer ¶ added in v0.10.0
type KuadrantAuthorizer struct {
// contains filtered or unexported fields
}
func NewKuadrantAuthorizer ¶ added in v0.10.0
func NewKuadrantAuthorizer(namespace string) *KuadrantAuthorizer
NewKuadrantAuthorizer Creates a new KuadrantAuthorizer
func (*KuadrantAuthorizer) GetExtensionProvider ¶ added in v0.10.0
func (k *KuadrantAuthorizer) GetExtensionProvider() *istiomeshv1alpha1.MeshConfig_ExtensionProvider
GetExtensionProvider Returns the Istio MeshConfig ExtensionProvider for Kuadrant
type OSSMControlPlaneWrapper ¶ added in v0.4.0
type OSSMControlPlaneWrapper struct {
// contains filtered or unexported fields
}
OSSMControlPlaneWrapper wraps the OSSM ServiceMeshControlPlane
func NewOSSMControlPlaneWrapper ¶ added in v0.4.0
func NewOSSMControlPlaneWrapper(config *maistrav2.ServiceMeshControlPlane) *OSSMControlPlaneWrapper
NewOSSMControlPlaneWrapper creates a new OSSMControlPlaneWrapper
func (*OSSMControlPlaneWrapper) GetConfigObject ¶ added in v0.4.0
func (w *OSSMControlPlaneWrapper) GetConfigObject() client.Object
GetConfigObject returns the OSSM ServiceMeshControlPlane
func (*OSSMControlPlaneWrapper) GetMeshConfig ¶ added in v0.4.0
func (w *OSSMControlPlaneWrapper) GetMeshConfig() (*istiomeshv1alpha1.MeshConfig, error)
GetMeshConfig returns the MeshConfig from the OSSM ServiceMeshControlPlane
func (*OSSMControlPlaneWrapper) SetMeshConfig ¶ added in v0.4.0
func (w *OSSMControlPlaneWrapper) SetMeshConfig(config *istiomeshv1alpha1.MeshConfig) error
SetMeshConfig sets the MeshConfig in the OSSM ServiceMeshControlPlane
type OperatorWrapper ¶ added in v0.4.0
type OperatorWrapper struct {
// contains filtered or unexported fields
}
OperatorWrapper wraps the IstioOperator CRD
func NewOperatorWrapper ¶ added in v0.4.0
func NewOperatorWrapper(config *iopv1alpha1.IstioOperator) *OperatorWrapper
NewOperatorWrapper creates a new IstioOperatorWrapper
func (*OperatorWrapper) GetConfigObject ¶ added in v0.4.0
func (w *OperatorWrapper) GetConfigObject() client.Object
GetConfigObject returns the IstioOperator CRD
func (*OperatorWrapper) GetMeshConfig ¶ added in v0.4.0
func (w *OperatorWrapper) GetMeshConfig() (*istiomeshv1alpha1.MeshConfig, error)
GetMeshConfig returns the IstioOperator MeshConfig
func (*OperatorWrapper) SetMeshConfig ¶ added in v0.4.0
func (w *OperatorWrapper) SetMeshConfig(config *istiomeshv1alpha1.MeshConfig) error
SetMeshConfig sets the IstioOperator MeshConfig
type SailWrapper ¶ added in v0.6.0
type SailWrapper struct {
// contains filtered or unexported fields
}
SailWrapper wraps the IstioCR
func NewSailWrapper ¶ added in v0.6.0
func NewSailWrapper(config *istiov1alpha1.Istio) *SailWrapper
NewSailWrapper creates a new SailWrapper
func (*SailWrapper) GetConfigObject ¶ added in v0.6.0
func (w *SailWrapper) GetConfigObject() client.Object
GetConfigObject returns the IstioCR
func (*SailWrapper) GetMeshConfig ¶ added in v0.6.0
func (w *SailWrapper) GetMeshConfig() (*istiomeshv1alpha1.MeshConfig, error)
GetMeshConfig returns the Istio MeshConfig
func (*SailWrapper) SetMeshConfig ¶ added in v0.6.0
func (w *SailWrapper) SetMeshConfig(config *istiomeshv1alpha1.MeshConfig) error
SetMeshConfig sets the Istio MeshConfig