v2beta1

package
v0.0.0-...-df11253 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package v2beta1 contains API Schema definitions for the otterize v2beta1 API group +kubebuilder:object:generate=true +groupName=k8s.otterize.com

Index

Constants

View Source 
const (
	OtterizeAccessLabelPrefix                  = "intents.otterize.com/access"
	OtterizeServiceAccessLabelPrefix           = "intents.otterize.com/svc-access"
	OtterizeAccessLabelKey                     = "intents.otterize.com/access-%s"
	OtterizeSvcAccessLabelKey                  = "intents.otterize.com/svc-access-%s"
	OtterizeClientLabelKey                     = "intents.otterize.com/client"
	OtterizeServiceLabelKey                    = "intents.otterize.com/service"
	OtterizeOwnerKindLabelKey                  = "intents.otterize.com/owner-kind"
	OtterizeServerLabelKeyDeprecated           = "intents.otterize.com/server"
	OtterizeKubernetesServiceLabelKeyPrefix    = "intents.otterize.com/k8s-svc"
	OtterizeKubernetesServiceLabelKey          = "intents.otterize.com/k8s-svc-%s"
	KubernetesStandardNamespaceNameLabelKey    = "kubernetes.io/metadata.name"
	AllIntentsRemovedAnnotation                = "intents.otterize.com/all-intents-removed"
	OtterizeCreatedForServiceAnnotation        = "intents.otterize.com/created-for-service"
	OtterizeCreatedForIngressAnnotation        = "intents.otterize.com/created-for-ingress"
	OtterizeSingleNetworkPolicyNameTemplate    = "%s-access"
	OtterizeLinkerdMeshTLSAnnotationKey        = "intents.otterize.com/linkerd-authenticates"
	OtterizeLinkerdServerAnnotationKey         = "intents.otterize.com/linkerd-server"
	OtterizeNetworkPolicyIngressNameTemplate   = "%s-ingress"
	OtterizeNetworkPolicyEgressNameTemplate    = "%s-egress"
	OtterizeNetworkPolicy                      = "intents.otterize.com/network-policy"
	OtterizeSvcNetworkPolicy                   = "intents.otterize.com/svc-network-policy"
	OtterizeNetworkPolicyServiceDefaultDeny    = "intents.otterize.com/network-policy-service-default-deny"
	OtterizeNetworkPolicyExternalTraffic       = "intents.otterize.com/network-policy-external-traffic"
	ClientIntentsFinalizerName                 = "intents.otterize.com/client-intents-finalizer"
	ProtectedServicesFinalizerName             = "intents.otterize.com/protected-services-finalizer"
	OtterizeIstioClientAnnotationKeyDeprecated = "intents.otterize.com/istio-client"
	OtterizeIstioClientWithKindLabelKey        = "intents.otterize.com/istio-client-with-kind"
	OtterizeClientServiceAccountAnnotation     = "intents.otterize.com/client-intents-service-account"
	OtterizeSharedServiceAccountAnnotation     = "intents.otterize.com/shared-service-account"
	OtterizeMissingSidecarAnnotation           = "intents.otterize.com/service-missing-sidecar"
	OtterizeServersWithoutSidecarAnnotation    = "intents.otterize.com/servers-without-sidecar"
	OtterizeTargetServerIndexField             = "spec.service.calls.server"
	OtterizeKafkaServerConfigServiceNameField  = "spec.service.name"
	OtterizeProtectedServiceNameIndexField     = "spec.name"
	OtterizeFormattedTargetServerIndexField    = "formattedTargetServer"
	OtterizePodByOwnerKindAndNameIndexField    = "podByOwnerKindAndName"
	EndpointsPodNamesIndexField                = "endpointsPodNames"
	IngressServiceNamesIndexField              = "ingressServiceNames"
	MaxOtterizeNameLength                      = 20
	MaxNamespaceLength                         = 20
	OtterizeSvcEgressNetworkPolicy             = "intents.otterize.com/svc-egress-network-policy"
	OtterizeEgressNetworkPolicy                = "intents.otterize.com/egress-network-policy"
	OtterizeInternetNetworkPolicy              = "intents.otterize.com/egress-internet-network-policy"
	OtterizeInternetTargetName                 = "internet"
	KubernetesAPIServerName                    = "kubernetes"
	KubernetesAPIServerNamespace               = "default"
)
View Source 
const (
	ResourcePatternTypeLiteral = "literal"
	ResourcePatternTypePrefix  = "prefix"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "k8s.otterize.com", Version: "v2beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func CleanupOtterizeKubernetesServiceLabels 

func CleanupOtterizeKubernetesServiceLabels(pod *v1.Pod) *v1.Pod

func GetOtterizeLabelsFromPod 

func GetOtterizeLabelsFromPod(pod *v1.Pod) map[string]string

func HasOtterizeDeprecatedServerLabel 

func HasOtterizeDeprecatedServerLabel(pod *v1.Pod) bool

func HasOtterizeOwnerKindLabel 

func HasOtterizeOwnerKindLabel(pod *v1.Pod, labelValue string) bool

func HasOtterizeServiceLabel 

func HasOtterizeServiceLabel(pod *v1.Pod, labelValue string) bool

func IsMissingOtterizeAccessLabels 

func IsMissingOtterizeAccessLabels(pod *v1.Pod, otterizeAccessLabels map[string]string) bool

IsMissingOtterizeAccessLabels checks if a pod's labels need updating

func ServiceIdentityToLabelsForWorkloadSelection 

func ServiceIdentityToLabelsForWorkloadSelection(ctx context.Context, k8sClient client.Client, identity serviceidentity.ServiceIdentity) (map[string]string, bool, error)

func UpdateOtterizeAccessLabels 

func UpdateOtterizeAccessLabels(pod *v1.Pod, serviceIdentity serviceidentity.ServiceIdentity, otterizeAccessLabels map[string]string) *v1.Pod

UpdateOtterizeAccessLabels updates a pod's labels with Otterize labels representing their intents The pod is also labeled with "otterize-client=<hashed-client-name>" to mark it as having intents or being the client-side of an egress netpol

Types

type AWSTarget 

type AWSTarget struct {
	ARN string `json:"arn,omitempty" yaml:"arn,omitempty"`
	//+optional
	Actions []string `json:"actions,omitempty" yaml:"actions,omitempty"`
}

func (*AWSTarget) DeepCopy 

func (in *AWSTarget) DeepCopy() *AWSTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AWSTarget.

func (*AWSTarget) DeepCopyInto 

func (in *AWSTarget) DeepCopyInto(out *AWSTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureAction 

type AzureAction string

type AzureDataAction 

type AzureDataAction string

type AzureKeyVaultCertificatePermission 

type AzureKeyVaultCertificatePermission string

+kubebuilder:validation:Enum=all;backup;create;delete;deleteissuers;get;getissuers;import;list;listissuers;managecontacts;manageissuers;purge;recover;restore;setissuers;update 

const (
	AzureKeyVaultCertificatePermissionAll            AzureKeyVaultCertificatePermission = "all"
	AzureKeyVaultCertificatePermissionBackup         AzureKeyVaultCertificatePermission = "backup"
	AzureKeyVaultCertificatePermissionCreate         AzureKeyVaultCertificatePermission = "create"
	AzureKeyVaultCertificatePermissionDelete         AzureKeyVaultCertificatePermission = "delete"
	AzureKeyVaultCertificatePermissionDeleteIssuers  AzureKeyVaultCertificatePermission = "deleteissuers"
	AzureKeyVaultCertificatePermissionGet            AzureKeyVaultCertificatePermission = "get"
	AzureKeyVaultCertificatePermissionGetIssuers     AzureKeyVaultCertificatePermission = "getissuers"
	AzureKeyVaultCertificatePermissionImport         AzureKeyVaultCertificatePermission = "import"
	AzureKeyVaultCertificatePermissionList           AzureKeyVaultCertificatePermission = "list"
	AzureKeyVaultCertificatePermissionListIssuers    AzureKeyVaultCertificatePermission = "listissuers"
	AzureKeyVaultCertificatePermissionManageContacts AzureKeyVaultCertificatePermission = "managecontacts"
	AzureKeyVaultCertificatePermissionManageIssuers  AzureKeyVaultCertificatePermission = "manageissuers"
	AzureKeyVaultCertificatePermissionPurge          AzureKeyVaultCertificatePermission = "purge"
	AzureKeyVaultCertificatePermissionRecover        AzureKeyVaultCertificatePermission = "recover"
	AzureKeyVaultCertificatePermissionRestore        AzureKeyVaultCertificatePermission = "restore"
	AzureKeyVaultCertificatePermissionSetIssuers     AzureKeyVaultCertificatePermission = "setissuers"
	AzureKeyVaultCertificatePermissionUpdate         AzureKeyVaultCertificatePermission = "update"
)

type AzureKeyVaultKeyPermission 

type AzureKeyVaultKeyPermission string

+kubebuilder:validation:Enum=all;backup;create;decrypt;delete;encrypt;get;getrotationpolicy;import;list;purge;recover;release;restore;rotate;setrotationpolicy;sign;unwrapkey;update;verify;wrapkey 

const (
	AzureKeyVaultKeyPermissionAll               AzureKeyVaultKeyPermission = "all"
	AzureKeyVaultKeyPermissionBackup            AzureKeyVaultKeyPermission = "backup"
	AzureKeyVaultKeyPermissionCreate            AzureKeyVaultKeyPermission = "create"
	AzureKeyVaultKeyPermissionDecrypt           AzureKeyVaultKeyPermission = "decrypt"
	AzureKeyVaultKeyPermissionDelete            AzureKeyVaultKeyPermission = "delete"
	AzureKeyVaultKeyPermissionEncrypt           AzureKeyVaultKeyPermission = "encrypt"
	AzureKeyVaultKeyPermissionGet               AzureKeyVaultKeyPermission = "get"
	AzureKeyVaultKeyPermissionGetRotationPolicy AzureKeyVaultKeyPermission = "getrotationpolicy"
	AzureKeyVaultKeyPermissionImport            AzureKeyVaultKeyPermission = "import"
	AzureKeyVaultKeyPermissionList              AzureKeyVaultKeyPermission = "list"
	AzureKeyVaultKeyPermissionPurge             AzureKeyVaultKeyPermission = "purge"
	AzureKeyVaultKeyPermissionRecover           AzureKeyVaultKeyPermission = "recover"
	AzureKeyVaultKeyPermissionRelease           AzureKeyVaultKeyPermission = "release"
	AzureKeyVaultKeyPermissionRestore           AzureKeyVaultKeyPermission = "restore"
	AzureKeyVaultKeyPermissionRotate            AzureKeyVaultKeyPermission = "rotate"
	AzureKeyVaultKeyPermissionSetRotationPolicy AzureKeyVaultKeyPermission = "setrotationpolicy"
	AzureKeyVaultKeyPermissionSign              AzureKeyVaultKeyPermission = "sign"
	AzureKeyVaultKeyPermissionUnwrapKey         AzureKeyVaultKeyPermission = "unwrapkey"
	AzureKeyVaultKeyPermissionUpdate            AzureKeyVaultKeyPermission = "update"
	AzureKeyVaultKeyPermissionVerify            AzureKeyVaultKeyPermission = "verify"
	AzureKeyVaultKeyPermissionWrapKey           AzureKeyVaultKeyPermission = "wrapkey"
)

type AzureKeyVaultPolicy 

type AzureKeyVaultPolicy struct {
	//+optional
	CertificatePermissions []AzureKeyVaultCertificatePermission `json:"certificatePermissions,omitempty" yaml:"certificatePermissions,omitempty"`
	//+optional
	KeyPermissions []AzureKeyVaultKeyPermission `json:"keyPermissions,omitempty" yaml:"keyPermissions,omitempty"`
	//+optional
	SecretPermissions []AzureKeyVaultSecretPermission `json:"secretPermissions,omitempty" yaml:"secretPermissions,omitempty"`
	//+optional
	StoragePermissions []AzureKeyVaultStoragePermission `json:"storagePermissions,omitempty" yaml:"storagePermissions,omitempty"`
}

func (*AzureKeyVaultPolicy) DeepCopy 

func (in *AzureKeyVaultPolicy) DeepCopy() *AzureKeyVaultPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureKeyVaultPolicy.

func (*AzureKeyVaultPolicy) DeepCopyInto 

func (in *AzureKeyVaultPolicy) DeepCopyInto(out *AzureKeyVaultPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AzureKeyVaultSecretPermission 

type AzureKeyVaultSecretPermission string

+kubebuilder:validation:Enum=all;backup;delete;get;list;purge;recover;restore;set 

const (
	AzureKeyVaultSecretPermissionAll     AzureKeyVaultSecretPermission = "all"
	AzureKeyVaultSecretPermissionBackup  AzureKeyVaultSecretPermission = "backup"
	AzureKeyVaultSecretPermissionDelete  AzureKeyVaultSecretPermission = "delete"
	AzureKeyVaultSecretPermissionGet     AzureKeyVaultSecretPermission = "get"
	AzureKeyVaultSecretPermissionList    AzureKeyVaultSecretPermission = "list"
	AzureKeyVaultSecretPermissionPurge   AzureKeyVaultSecretPermission = "purge"
	AzureKeyVaultSecretPermissionRecover AzureKeyVaultSecretPermission = "recover"
	AzureKeyVaultSecretPermissionRestore AzureKeyVaultSecretPermission = "restore"
	AzureKeyVaultSecretPermissionSet     AzureKeyVaultSecretPermission = "set"
)

type AzureKeyVaultStoragePermission 

type AzureKeyVaultStoragePermission string

+kubebuilder:validation:Enum=all;backup;delete;deletesas;get;getsas;list;listsas;purge;recover;regeneratekey;restore;set;setsas;update 

const (
	AzureKeyVaultStoragePermissionAll           AzureKeyVaultStoragePermission = "all"
	AzureKeyVaultStoragePermissionBackup        AzureKeyVaultStoragePermission = "backup"
	AzureKeyVaultStoragePermissionDelete        AzureKeyVaultStoragePermission = "delete"
	AzureKeyVaultStoragePermissionDeleteSas     AzureKeyVaultStoragePermission = "deletesas"
	AzureKeyVaultStoragePermissionGet           AzureKeyVaultStoragePermission = "get"
	AzureKeyVaultStoragePermissionGetSas        AzureKeyVaultStoragePermission = "getsas"
	AzureKeyVaultStoragePermissionList          AzureKeyVaultStoragePermission = "list"
	AzureKeyVaultStoragePermissionListSas       AzureKeyVaultStoragePermission = "listsas"
	AzureKeyVaultStoragePermissionPurge         AzureKeyVaultStoragePermission = "purge"
	AzureKeyVaultStoragePermissionRecover       AzureKeyVaultStoragePermission = "recover"
	AzureKeyVaultStoragePermissionRegenerateKey AzureKeyVaultStoragePermission = "regeneratekey"
	AzureKeyVaultStoragePermissionRestore       AzureKeyVaultStoragePermission = "restore"
	AzureKeyVaultStoragePermissionSet           AzureKeyVaultStoragePermission = "set"
	AzureKeyVaultStoragePermissionSetSas        AzureKeyVaultStoragePermission = "setsas"
	AzureKeyVaultStoragePermissionUpdate        AzureKeyVaultStoragePermission = "update"
)

type AzureTarget 

type AzureTarget struct {
	Scope string `json:"scope,omitempty" yaml:"scope,omitempty"`
	//+optional
	Roles []string `json:"roles,omitempty" yaml:"roles,omitempty"`
	//+optional
	KeyVaultPolicy *AzureKeyVaultPolicy `json:"keyVaultPolicy,omitempty" yaml:"keyVaultPolicy,omitempty"`
	//+optional
	Actions []AzureAction `json:"actions,omitempty" yaml:"actions,omitempty"`
	//+optional
	DataActions []AzureDataAction `json:"dataActions,omitempty" yaml:"dataActions,omitempty"`
}

func (*AzureTarget) DeepCopy 

func (in *AzureTarget) DeepCopy() *AzureTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureTarget.

func (*AzureTarget) DeepCopyInto 

func (in *AzureTarget) DeepCopyInto(out *AzureTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClientIntents 

type ClientIntents struct {
	metav1.TypeMeta   `json:",inline" yaml:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" yaml:"metadata,omitempty"`

	Spec   *IntentsSpec  `json:"spec,omitempty" yaml:"spec,omitempty"`
	Status IntentsStatus `json:"status,omitempty" yaml:"status,omitempty"`
}

ClientIntents is the Schema for the intents API

func (*ClientIntents) DeepCopy 

func (in *ClientIntents) DeepCopy() *ClientIntents

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientIntents.

func (*ClientIntents) DeepCopyInto 

func (in *ClientIntents) DeepCopyInto(out *ClientIntents)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClientIntents) DeepCopyObject 

func (in *ClientIntents) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClientIntents) GetClientKind 

func (in *ClientIntents) GetClientKind() string

func (*ClientIntents) GetDatabaseIntents 

func (in *ClientIntents) GetDatabaseIntents() []Target

func (*ClientIntents) GetFilteredTargetList 

func (in *ClientIntents) GetFilteredTargetList(intentTypes ...IntentType) []Target

func (*ClientIntents) GetIntentsLabelMapping 

func (in *ClientIntents) GetIntentsLabelMapping(requestNamespace string) map[string]string

func (*ClientIntents) GetServersWithoutSidecar 

func (in *ClientIntents) GetServersWithoutSidecar() (sets.Set[string], error)

func (*ClientIntents) GetTargetList 

func (in *ClientIntents) GetTargetList() []Target

func (*ClientIntents) GetWorkloadName 

func (in *ClientIntents) GetWorkloadName() string

func (*ClientIntents) HasDatabaseTypeInCallList 

func (in *ClientIntents) HasDatabaseTypeInCallList() bool

func (*ClientIntents) HasKafkaTypeInCallList 

func (in *ClientIntents) HasKafkaTypeInCallList() bool

func (*ClientIntents) Hub 

func (in *ClientIntents) Hub()

func (*ClientIntents) IsServerMissingSidecar 

func (in *ClientIntents) IsServerMissingSidecar(intent Target) (bool, error)

func (*ClientIntents) SetupWebhookWithManager 

func (in *ClientIntents) SetupWebhookWithManager(mgr ctrl.Manager, validator webhook.CustomValidator) error

func (*ClientIntents) ToServiceIdentity 

func (in *ClientIntents) ToServiceIdentity() serviceidentity.ServiceIdentity

type ClientIntentsList 

type ClientIntentsList struct {
	metav1.TypeMeta `json:",inline" yaml:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" yaml:"metadata,omitempty"`
	Items           []ClientIntents `json:"items" yaml:"items"`
}

ClientIntentsList contains a list of ClientIntents

func (*ClientIntentsList) DeepCopy 

func (in *ClientIntentsList) DeepCopy() *ClientIntentsList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientIntentsList.

func (*ClientIntentsList) DeepCopyInto 

func (in *ClientIntentsList) DeepCopyInto(out *ClientIntentsList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClientIntentsList) DeepCopyObject 

func (in *ClientIntentsList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClientIntentsList) FormatAsOtterizeIntents 

func (in *ClientIntentsList) FormatAsOtterizeIntents(ctx context.Context, k8sClient client.Client) ([]*graphqlclient.IntentInput, error)

type DBPermissionChange 

type DBPermissionChange string
const (
	DBPermissionChangeApply  DBPermissionChange = "APPLY"
	DBPermissionChangeDelete DBPermissionChange = "DELETE"
)

type DatabaseCredentials 

type DatabaseCredentials struct {
	// Username is the plaintext username to access the database
	//+optional
	Username string `json:"username,omitempty"`
	// Password is the plaintext password to access the database
	//+optional
	Password string `json:"password,omitempty"`
	// SecretRef is a reference to a k8s secret storing the credentials
	//+optional
	SecretRef *DatabaseCredentialsSecretRef `json:"secretRef,omitempty"`
}

DatabaseCredentials defines the credentials to access the database

func (*DatabaseCredentials) DeepCopy 

func (in *DatabaseCredentials) DeepCopy() *DatabaseCredentials

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseCredentials.

func (*DatabaseCredentials) DeepCopyInto 

func (in *DatabaseCredentials) DeepCopyInto(out *DatabaseCredentials)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatabaseCredentialsSecretRef 

type DatabaseCredentialsSecretRef struct {
	// Name is the name of he k8s secret storing the credentials
	Name string `json:"name,omitempty"`
	// Namespace is the namespace in which the secret is stored.
	// If not provided, the operator will look for the secret in the same namespace as the database ServerConfig.
	//+optional
	Namespace string `json:"namespace,omitempty"`
	// UsernameKey is the key in the secret that stores the username
	//+optional
	//+kubebuilder:default="username"
	UsernameKey string `json:"usernameKey,omitempty"`
	// PasswordKey is the key in the secret that stores the password
	//+optional
	//+kubebuilder:default="password"
	PasswordKey string `json:"passwordKey,omitempty"`
}

func (*DatabaseCredentialsSecretRef) DeepCopy 

func (in *DatabaseCredentialsSecretRef) DeepCopy() *DatabaseCredentialsSecretRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseCredentialsSecretRef.

func (*DatabaseCredentialsSecretRef) DeepCopyInto 

func (in *DatabaseCredentialsSecretRef) DeepCopyInto(out *DatabaseCredentialsSecretRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatabaseOperation 

type DatabaseOperation string

+kubebuilder:validation:Enum=ALL;SELECT;INSERT;UPDATE;DELETE 

const (
	DatabaseOperationAll    DatabaseOperation = "ALL"
	DatabaseOperationSelect DatabaseOperation = "SELECT"
	DatabaseOperationInsert DatabaseOperation = "INSERT"
	DatabaseOperationUpdate DatabaseOperation = "UPDATE"
	DatabaseOperationDelete DatabaseOperation = "DELETE"
)

type GCPTarget 

type GCPTarget struct {
	Resource    string   `json:"resource,omitempty" yaml:"resource,omitempty"`
	Permissions []string `json:"permissions,omitempty" yaml:"permissions,omitempty"`
}

func (*GCPTarget) DeepCopy 

func (in *GCPTarget) DeepCopy() *GCPTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCPTarget.

func (*GCPTarget) DeepCopyInto 

func (in *GCPTarget) DeepCopyInto(out *GCPTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type HTTPMethod 

type HTTPMethod string

+kubebuilder:validation:Enum=GET;POST;PUT;DELETE;OPTIONS;TRACE;PATCH;CONNECT 

const (
	HTTPMethodGet     HTTPMethod = "GET"
	HTTPMethodPost    HTTPMethod = "POST"
	HTTPMethodPut     HTTPMethod = "PUT"
	HTTPMethodDelete  HTTPMethod = "DELETE"
	HTTPMethodOptions HTTPMethod = "OPTIONS"
	HTTPMethodTrace   HTTPMethod = "TRACE"
	HTTPMethodPatch   HTTPMethod = "PATCH"
	HTTPMethodConnect HTTPMethod = "CONNECT"
)

type HTTPTarget 

type HTTPTarget struct {
	Path    string       `json:"path"`
	Methods []HTTPMethod `json:"methods" yaml:"methods"`
}

func (*HTTPTarget) DeepCopy 

func (in *HTTPTarget) DeepCopy() *HTTPTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPTarget.

func (*HTTPTarget) DeepCopyInto 

func (in *HTTPTarget) DeepCopyInto(out *HTTPTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IntentType 

type IntentType string

+kubebuilder:validation:Enum=http;kafka;database;aws;gcp;azure;internet 

const (
	IntentTypeHTTP     IntentType = "http"
	IntentTypeKafka    IntentType = "kafka"
	IntentTypeDatabase IntentType = "database"
	IntentTypeAWS      IntentType = "aws"
	IntentTypeGCP      IntentType = "gcp"
	IntentTypeAzure    IntentType = "azure"
	IntentTypeInternet IntentType = "internet"
)

type IntentsSpec 

type IntentsSpec struct {
	Workload Workload `json:"workload" yaml:"workload"`
	Targets  []Target `json:"targets" yaml:"targets"`
}

IntentsSpec defines the desired state of ClientIntents

func (*IntentsSpec) DeepCopy 

func (in *IntentsSpec) DeepCopy() *IntentsSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntentsSpec.

func (*IntentsSpec) DeepCopyInto 

func (in *IntentsSpec) DeepCopyInto(out *IntentsSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IntentsStatus 

type IntentsStatus struct {
	// upToDate field reflects whether the client intents have successfully been applied
	// to the cluster to the state specified
	// +optional
	UpToDate bool `json:"upToDate"`
	// The last generation of the intents that was successfully reconciled.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration"`
	// ResolvedIPs stores resolved IPs for a domain name - the network mapper populates it when DNS internetTarget is used
	// +optional
	ResolvedIPs []ResolvedIPs `json:"resolvedIPs,omitempty" yaml:"resolvedIPs,omitempty"`
}

IntentsStatus defines the observed state of ClientIntents

func (*IntentsStatus) DeepCopy 

func (in *IntentsStatus) DeepCopy() *IntentsStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntentsStatus.

func (*IntentsStatus) DeepCopyInto 

func (in *IntentsStatus) DeepCopyInto(out *IntentsStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Internet 

type Internet struct {
	//+optional
	Domains []string `json:"domains,omitempty" yaml:"domains,omitempty"`
	//+optional
	Ips []string `json:"ips,omitempty" yaml:"ips,omitempty"`
	//+optional
	Ports []int `json:"ports,omitempty" yaml:"ports,omitempty"`
}

func (*Internet) DeepCopy 

func (in *Internet) DeepCopy() *Internet

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Internet.

func (*Internet) DeepCopyInto 

func (in *Internet) DeepCopyInto(out *Internet)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaOperation 

type KafkaOperation string

+kubebuilder:validation:Enum=all;consume;produce;create;alter;delete;describe;ClusterAction;DescribeConfigs;AlterConfigs;IdempotentWrite 

const (
	KafkaOperationAll             KafkaOperation = "all"
	KafkaOperationConsume         KafkaOperation = "consume"
	KafkaOperationProduce         KafkaOperation = "produce"
	KafkaOperationCreate          KafkaOperation = "create"
	KafkaOperationAlter           KafkaOperation = "alter"
	KafkaOperationDelete          KafkaOperation = "delete"
	KafkaOperationDescribe        KafkaOperation = "describe"
	KafkaOperationClusterAction   KafkaOperation = "ClusterAction"
	KafkaOperationDescribeConfigs KafkaOperation = "DescribeConfigs"
	KafkaOperationAlterConfigs    KafkaOperation = "AlterConfigs"
	KafkaOperationIdempotentWrite KafkaOperation = "IdempotentWrite"
)

type KafkaServerConfig 

type KafkaServerConfig struct {
	metav1.TypeMeta   `json:",inline" yaml:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" yaml:"metadata,omitempty"`

	Spec   KafkaServerConfigSpec   `json:"spec,omitempty" yaml:"spec,omitempty"`
	Status KafkaServerConfigStatus `json:"status,omitempty" yaml:"status,omitempty"`
}

KafkaServerConfig is the Schema for the kafkaserverconfigs API

func (*KafkaServerConfig) DeepCopy 

func (in *KafkaServerConfig) DeepCopy() *KafkaServerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaServerConfig.

func (*KafkaServerConfig) DeepCopyInto 

func (in *KafkaServerConfig) DeepCopyInto(out *KafkaServerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaServerConfig) DeepCopyObject 

func (in *KafkaServerConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*KafkaServerConfig) Hub 

func (ksc *KafkaServerConfig) Hub()

func (*KafkaServerConfig) SetupWebhookWithManager 

func (ksc *KafkaServerConfig) SetupWebhookWithManager(mgr ctrl.Manager) error

type KafkaServerConfigList 

type KafkaServerConfigList struct {
	metav1.TypeMeta `json:",inline" yaml:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" yaml:"metadata,omitempty"`
	Items           []KafkaServerConfig `json:"items" yaml:"items"`
}

KafkaServerConfigList contains a list of KafkaServerConfig

func (*KafkaServerConfigList) DeepCopy 

func (in *KafkaServerConfigList) DeepCopy() *KafkaServerConfigList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaServerConfigList.

func (*KafkaServerConfigList) DeepCopyInto 

func (in *KafkaServerConfigList) DeepCopyInto(out *KafkaServerConfigList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaServerConfigList) DeepCopyObject 

func (in *KafkaServerConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaServerConfigSpec 

type KafkaServerConfigSpec struct {
	Workload Workload `json:"workload,omitempty" yaml:"workload,omitempty"`
	// If Intents for network policies are enabled, and there are other Intents to this Kafka server,
	// will automatically create an Target so that the Intents Operator can connect. Set to true to disable.
	NoAutoCreateIntentsForOperator bool   `json:"noAutoCreateIntentsForOperator,omitempty" yaml:"noAutoCreateIntentsForOperator,omitempty"`
	Addr                           string `json:"addr,omitempty" yaml:"addr,omitempty"`
	// +kubebuilder:validation:Optional
	TLS    TLSSource     `json:"tls,omitempty" yaml:"tls,omitempty"`
	Topics []TopicConfig `json:"topics,omitempty" yaml:"topics,omitempty"`
}

KafkaServerConfigSpec defines the desired state of KafkaServerConfig

func (*KafkaServerConfigSpec) DeepCopy 

func (in *KafkaServerConfigSpec) DeepCopy() *KafkaServerConfigSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaServerConfigSpec.

func (*KafkaServerConfigSpec) DeepCopyInto 

func (in *KafkaServerConfigSpec) DeepCopyInto(out *KafkaServerConfigSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaServerConfigStatus 

type KafkaServerConfigStatus struct {
}

KafkaServerConfigStatus defines the observed state of KafkaServerConfig

func (*KafkaServerConfigStatus) DeepCopy 

func (in *KafkaServerConfigStatus) DeepCopy() *KafkaServerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaServerConfigStatus.

func (*KafkaServerConfigStatus) DeepCopyInto 

func (in *KafkaServerConfigStatus) DeepCopyInto(out *KafkaServerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaTarget 

type KafkaTarget struct {
	Name string `json:"name" yaml:"name"`
	//+optional
	Topics []KafkaTopic `json:"topics,omitempty" yaml:"topics,omitempty"`
}

func (*KafkaTarget) DeepCopy 

func (in *KafkaTarget) DeepCopy() *KafkaTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTarget.

func (*KafkaTarget) DeepCopyInto 

func (in *KafkaTarget) DeepCopyInto(out *KafkaTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaTopic 

type KafkaTopic struct {
	Name       string           `json:"name" yaml:"name"`
	Operations []KafkaOperation `json:"operations" yaml:"operations"`
}

func (*KafkaTopic) DeepCopy 

func (in *KafkaTopic) DeepCopy() *KafkaTopic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopic.

func (*KafkaTopic) DeepCopyInto 

func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KubernetesTarget 

type KubernetesTarget struct {
	Name string `json:"name" yaml:"name"`
	//+optional
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`
	//+optional
	HTTP []HTTPTarget `json:"http,omitempty" yaml:"http,omitempty"`
}

func (*KubernetesTarget) DeepCopy 

func (in *KubernetesTarget) DeepCopy() *KubernetesTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesTarget.

func (*KubernetesTarget) DeepCopyInto 

func (in *KubernetesTarget) DeepCopyInto(out *KubernetesTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MySQLServerConfig 

type MySQLServerConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MySQLServerConfigSpec   `json:"spec,omitempty"`
	Status MySQLServerConfigStatus `json:"status,omitempty"`
}

MySQLServerConfig is the Schema for the mysqlserverconfig API

func (*MySQLServerConfig) DeepCopy 

func (in *MySQLServerConfig) DeepCopy() *MySQLServerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLServerConfig.

func (*MySQLServerConfig) DeepCopyInto 

func (in *MySQLServerConfig) DeepCopyInto(out *MySQLServerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MySQLServerConfig) DeepCopyObject 

func (in *MySQLServerConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*MySQLServerConfig) Hub 

func (in *MySQLServerConfig) Hub()

func (*MySQLServerConfig) SetupWebhookWithManager 

func (in *MySQLServerConfig) SetupWebhookWithManager(mgr ctrl.Manager, validator webhook.CustomValidator) error

type MySQLServerConfigList 

type MySQLServerConfigList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []MySQLServerConfig `json:"items"`
}

MySQLServerConfigList contains a list of MySQLServerConfig

func (*MySQLServerConfigList) DeepCopy 

func (in *MySQLServerConfigList) DeepCopy() *MySQLServerConfigList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLServerConfigList.

func (*MySQLServerConfigList) DeepCopyInto 

func (in *MySQLServerConfigList) DeepCopyInto(out *MySQLServerConfigList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MySQLServerConfigList) DeepCopyObject 

func (in *MySQLServerConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type MySQLServerConfigSpec 

type MySQLServerConfigSpec struct {
	Address     string              `json:"address"`
	Credentials DatabaseCredentials `json:"credentials"`
}

MySQLServerConfigSpec defines the desired state of MySQLServerConfig

func (*MySQLServerConfigSpec) DeepCopy 

func (in *MySQLServerConfigSpec) DeepCopy() *MySQLServerConfigSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLServerConfigSpec.

func (*MySQLServerConfigSpec) DeepCopyInto 

func (in *MySQLServerConfigSpec) DeepCopyInto(out *MySQLServerConfigSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MySQLServerConfigStatus 

type MySQLServerConfigStatus struct {
}

MySQLServerConfigStatus defines the observed state of MySQLServerConfig

func (*MySQLServerConfigStatus) DeepCopy 

func (in *MySQLServerConfigStatus) DeepCopy() *MySQLServerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLServerConfigStatus.

func (*MySQLServerConfigStatus) DeepCopyInto 

func (in *MySQLServerConfigStatus) DeepCopyInto(out *MySQLServerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PostgreSQLServerConfig 

type PostgreSQLServerConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PostgreSQLServerConfigSpec   `json:"spec,omitempty"`
	Status PostgreSQLServerConfigStatus `json:"status,omitempty"`
}

PostgreSQLServerConfig is the Schema for the databaseserverconfig API

func (*PostgreSQLServerConfig) DeepCopy 

func (in *PostgreSQLServerConfig) DeepCopy() *PostgreSQLServerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLServerConfig.

func (*PostgreSQLServerConfig) DeepCopyInto 

func (in *PostgreSQLServerConfig) DeepCopyInto(out *PostgreSQLServerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PostgreSQLServerConfig) DeepCopyObject 

func (in *PostgreSQLServerConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*PostgreSQLServerConfig) Hub 

func (in *PostgreSQLServerConfig) Hub()

func (*PostgreSQLServerConfig) SetupWebhookWithManager 

func (in *PostgreSQLServerConfig) SetupWebhookWithManager(mgr ctrl.Manager, validator webhook.CustomValidator) error

type PostgreSQLServerConfigList 

type PostgreSQLServerConfigList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PostgreSQLServerConfig `json:"items"`
}

PostgreSQLServerConfigList contains a list of PostgreSQLServerConfig

func (*PostgreSQLServerConfigList) DeepCopy 

func (in *PostgreSQLServerConfigList) DeepCopy() *PostgreSQLServerConfigList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLServerConfigList.

func (*PostgreSQLServerConfigList) DeepCopyInto 

func (in *PostgreSQLServerConfigList) DeepCopyInto(out *PostgreSQLServerConfigList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PostgreSQLServerConfigList) DeepCopyObject 

func (in *PostgreSQLServerConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type PostgreSQLServerConfigSpec 

type PostgreSQLServerConfigSpec struct {
	Address     string              `json:"address"`
	Credentials DatabaseCredentials `json:"credentials"`
}

PostgreSQLServerConfigSpec defines the desired state of PostgreSQLServerConfig

func (*PostgreSQLServerConfigSpec) DeepCopy 

func (in *PostgreSQLServerConfigSpec) DeepCopy() *PostgreSQLServerConfigSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLServerConfigSpec.

func (*PostgreSQLServerConfigSpec) DeepCopyInto 

func (in *PostgreSQLServerConfigSpec) DeepCopyInto(out *PostgreSQLServerConfigSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PostgreSQLServerConfigStatus 

type PostgreSQLServerConfigStatus struct {
}

PostgreSQLServerConfigStatus defines the observed state of PostgreSQLServerConfig

func (*PostgreSQLServerConfigStatus) DeepCopy 

func (in *PostgreSQLServerConfigStatus) DeepCopy() *PostgreSQLServerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLServerConfigStatus.

func (*PostgreSQLServerConfigStatus) DeepCopyInto 

func (in *PostgreSQLServerConfigStatus) DeepCopyInto(out *PostgreSQLServerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ProtectedService 

type ProtectedService struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ProtectedServiceSpec   `json:"spec,omitempty"`
	Status ProtectedServiceStatus `json:"status,omitempty"`
}

ProtectedService is the Schema for the protectedservice API

func (*ProtectedService) DeepCopy 

func (in *ProtectedService) DeepCopy() *ProtectedService

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProtectedService.

func (*ProtectedService) DeepCopyInto 

func (in *ProtectedService) DeepCopyInto(out *ProtectedService)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ProtectedService) DeepCopyObject 

func (in *ProtectedService) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ProtectedService) GetKind 

func (in *ProtectedService) GetKind() string

func (*ProtectedService) Hub 

func (in *ProtectedService) Hub()

func (*ProtectedService) SetupWebhookWithManager 

func (in *ProtectedService) SetupWebhookWithManager(mgr ctrl.Manager, validator webhook.CustomValidator) error

func (*ProtectedService) ToServiceIdentity 

func (in *ProtectedService) ToServiceIdentity() serviceidentity.ServiceIdentity

type ProtectedServiceList 

type ProtectedServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ProtectedService `json:"items"`
}

ProtectedServiceList contains a list of ProtectedService

func (*ProtectedServiceList) DeepCopy 

func (in *ProtectedServiceList) DeepCopy() *ProtectedServiceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProtectedServiceList.

func (*ProtectedServiceList) DeepCopyInto 

func (in *ProtectedServiceList) DeepCopyInto(out *ProtectedServiceList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ProtectedServiceList) DeepCopyObject 

func (in *ProtectedServiceList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ProtectedServiceSpec 

type ProtectedServiceSpec struct {
	Name string `json:"name,omitempty"`

	//+optional
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`
}

ProtectedServiceSpec defines the desired state of ProtectedService

func (*ProtectedServiceSpec) DeepCopy 

func (in *ProtectedServiceSpec) DeepCopy() *ProtectedServiceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProtectedServiceSpec.

func (*ProtectedServiceSpec) DeepCopyInto 

func (in *ProtectedServiceSpec) DeepCopyInto(out *ProtectedServiceSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ProtectedServiceStatus 

type ProtectedServiceStatus struct {
}

ProtectedServiceStatus defines the observed state of ProtectedService

func (*ProtectedServiceStatus) DeepCopy 

func (in *ProtectedServiceStatus) DeepCopy() *ProtectedServiceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProtectedServiceStatus.

func (*ProtectedServiceStatus) DeepCopyInto 

func (in *ProtectedServiceStatus) DeepCopyInto(out *ProtectedServiceStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ResolvedIPs 

type ResolvedIPs struct {
	DNS string   `json:"dns,omitempty" yaml:"dns,omitempty"`
	IPs []string `json:"ips,omitempty" yaml:"ips,omitempty"`
}

func (*ResolvedIPs) DeepCopy 

func (in *ResolvedIPs) DeepCopy() *ResolvedIPs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResolvedIPs.

func (*ResolvedIPs) DeepCopyInto 

func (in *ResolvedIPs) DeepCopyInto(out *ResolvedIPs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ResourcePatternType 

type ResourcePatternType string

+kubebuilder:validation:Enum=literal;prefix

type SQLPrivileges 

type SQLPrivileges struct {
	DatabaseName string `json:"databaseName" yaml:"databaseName"`
	//+optional
	Table string `json:"table" yaml:"table"`
	//+optional
	Operations []DatabaseOperation `json:"operations" yaml:"operations"`
}

func (*SQLPrivileges) DeepCopy 

func (in *SQLPrivileges) DeepCopy() *SQLPrivileges

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SQLPrivileges.

func (*SQLPrivileges) DeepCopyInto 

func (in *SQLPrivileges) DeepCopyInto(out *SQLPrivileges)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SQLTarget 

type SQLTarget struct {
	Name string `json:"name" yaml:"name"`
	//+optional
	Privileges []SQLPrivileges `json:"privileges,omitempty" yaml:"privileges,omitempty"`
}

func (*SQLTarget) DeepCopy 

func (in *SQLTarget) DeepCopy() *SQLTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SQLTarget.

func (*SQLTarget) DeepCopyInto 

func (in *SQLTarget) DeepCopyInto(out *SQLTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServiceTarget 

type ServiceTarget struct {
	Name string       `json:"name" yaml:"name"`
	HTTP []HTTPTarget `json:"http,omitempty" yaml:"http,omitempty"`
}

func (*ServiceTarget) DeepCopy 

func (in *ServiceTarget) DeepCopy() *ServiceTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceTarget.

func (*ServiceTarget) DeepCopyInto 

func (in *ServiceTarget) DeepCopyInto(out *ServiceTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TLSSource 

type TLSSource struct {
	// +kubebuilder:validation:Required
	CertFile string `json:"certFile" yaml:"certFile"`
	// +kubebuilder:validation:Required
	KeyFile string `json:"keyFile" yaml:"keyFile"`
	// +kubebuilder:validation:Required
	RootCAFile string `json:"rootCAFile" yaml:"rootCAFile"`
}

func (*TLSSource) DeepCopy 

func (in *TLSSource) DeepCopy() *TLSSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSSource.

func (*TLSSource) DeepCopyInto 

func (in *TLSSource) DeepCopyInto(out *TLSSource)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Target 

type Target struct {
	//+optional
	Kubernetes *KubernetesTarget `json:"kubernetes,omitempty" yaml:"kubernetes,omitempty"`

	//+optional
	Service *ServiceTarget `json:"service,omitempty" yaml:"service,omitempty"`

	//+optional
	Kafka *KafkaTarget `json:"kafka,omitempty" yaml:"kafka,omitempty"`

	//+optional
	SQL *SQLTarget `json:"sql,omitempty" yaml:"sql,omitempty"`

	//+optional
	AWS *AWSTarget `json:"aws,omitempty" yaml:"aws,omitempty"`

	//+optional
	GCP *GCPTarget `json:"gcp,omitempty" yaml:"gcp,omitempty"`

	//+optional
	Azure *AzureTarget `json:"azure,omitempty" yaml:"azure,omitempty"`

	//+optional
	Internet *Internet `json:"internet,omitempty" yaml:"internet,omitempty"`
}

func (*Target) ConvertToCloudFormat 

func (in *Target) ConvertToCloudFormat(ctx context.Context, k8sClient client.Client, clientServiceIdentity serviceidentity.ServiceIdentity) (graphqlclient.IntentInput, error)

func (*Target) DeepCopy 

func (in *Target) DeepCopy() *Target

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Target.

func (*Target) DeepCopyInto 

func (in *Target) DeepCopyInto(out *Target)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Target) GetHTTPResources 

func (in *Target) GetHTTPResources() []HTTPTarget

func (*Target) GetIntentType 

func (in *Target) GetIntentType() IntentType

func (*Target) GetK8sServiceFullyQualifiedName 

func (in *Target) GetK8sServiceFullyQualifiedName(intentsObjNamespace string) (string, bool)

func (*Target) GetServerFullyQualifiedName 

func (in *Target) GetServerFullyQualifiedName(intentsObjNamespace string) string

func (*Target) GetTargetServerKind 

func (in *Target) GetTargetServerKind() string

func (*Target) GetTargetServerName 

func (in *Target) GetTargetServerName() string

GetTargetServerName returns server's service name, without namespace, or the Kubernetes service without the `svc:` prefix

func (*Target) GetTargetServerNameAsWritten 

func (in *Target) GetTargetServerNameAsWritten() string

func (*Target) GetTargetServerNamespace 

func (in *Target) GetTargetServerNamespace(intentsObjNamespace string) string

GetTargetServerNamespace returns target namespace for intent if exists or the entire resource's namespace if the specific intent has no target namespace, as it's optional

func (*Target) IsTargetInCluster 

func (in *Target) IsTargetInCluster() bool

func (*Target) IsTargetOutOfCluster 

func (in *Target) IsTargetOutOfCluster() bool

func (*Target) IsTargetServerKubernetesService 

func (in *Target) IsTargetServerKubernetesService() bool

func (*Target) IsTargetTheKubernetesAPIServer 

func (in *Target) IsTargetTheKubernetesAPIServer(objectNamespace string) bool

func (*Target) ToServiceIdentity 

func (in *Target) ToServiceIdentity(intentsObjNamespace string) serviceidentity.ServiceIdentity

type TopicConfig 

type TopicConfig struct {
	Topic                  string              `json:"topic" yaml:"topic"`
	Pattern                ResourcePatternType `json:"pattern" yaml:"pattern"`
	ClientIdentityRequired bool                `json:"clientIdentityRequired" yaml:"clientIdentityRequired"`
	IntentsRequired        bool                `json:"intentsRequired" yaml:"intentsRequired"`
}

func (*TopicConfig) DeepCopy 

func (in *TopicConfig) DeepCopy() *TopicConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicConfig.

func (*TopicConfig) DeepCopyInto 

func (in *TopicConfig) DeepCopyInto(out *TopicConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Workload 

type Workload struct {
	Name string `json:"name" yaml:"name"`
	//+optional
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`
}

func (*Workload) DeepCopy 

func (in *Workload) DeepCopy() *Workload

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Workload.

func (*Workload) DeepCopyInto 

func (in *Workload) DeepCopyInto(out *Workload)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.