Documentation
¶
Overview ¶
+k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud/apis/cloud +k8s:defaulter-gen=TypeMeta +k8s:protobuf-gen=package +groupName=cloud.streamnative.io
Index ¶
- Constants
- Variables
- func Resource(resource string) schema.GroupResource
- type APIKey
- type APIKeyList
- type APIKeySpec
- type APIKeyStatus
- type AWSCloudConnection
- type AmqpConfig
- type AuditLog
- type AzureConnection
- type BookKeeperSetReference
- type ClusterRole
- type ClusterRoleList
- type ClusterRoleSpec
- type ClusterRoleStatus
- type Condition
- type ConditionGroup
- type ConditionGroupRelation
- type ConditionReason
- type ConditionType
- type Config
- type Domain
- type DomainTLS
- type DomainType
- type EncryptedToken
- type EncryptionKey
- type FailedCluster
- type GCPCloudConnection
- type KafkaConfig
- type LakehouseStorageConfig
- type MqttConfig
- type PoolMemberReference
- type PoolRef
- type ProtocolsConfig
- type PullPolicy
- type ResourceName
- type RoleBinding
- type RoleBindingCondition
- type RoleBindingConditionOperator
- type RoleBindingConditionType
- type RoleBindingList
- type RoleBindingSpec
- type RoleBindingStatus
- type RoleRef
- type Secret
- type SecretList
- type SecretRef
- type SecretSpec
- type SecretStatus
- type ServiceAccount
- type ServiceAccountBinding
- type ServiceAccountBindingList
- type ServiceAccountBindingSpec
- type ServiceAccountBindingStatus
- type ServiceAccountList
- type ServiceAccountSpec
- type ServiceAccountStatus
- type SharingConfig
- type Srn
- type Subject
- type Taint
- type TaintEffect
- type Toleration
- type TolerationOperator
- type ZooKeeperSetReference
Constants ¶
const ( AnnotationReconcilePaused = "cloud.streamnative.io/reconcile-paused" AnnotationReconcileMode = "cloud.streamnative.io/reconcile-mode" )
const ( // ReconcileModeMinimal mode only reconcile minimal resources as necessary to keep the cluster running properly like certificates ReconcileModeMinimal = "minimal" // ReconcileModeBasic mode reconcile resources before zookeeper ReconcileModeBasic = "basic" )
const ( ConditionTypeReady ConditionType = "Ready" ConditionReasonReady ConditionReason = "Ready" ConditionReasonNotReady ConditionReason = "NotReady" )
const ( RelationOr ConditionGroupRelation = 0 RelationAnd ConditionGroupRelation = 1 TypeSrn RoleBindingConditionType = 0 OperatorKeyMatch RoleBindingConditionOperator = 0 OperatorRegexMatch RoleBindingConditionOperator = 1 )
const GroupName = "cloud.streamnative.io"
GroupName specifies the group name used to register the objects.
Variables ¶
var ( // localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes. SchemeBuilder runtime.SchemeBuilder // Deprecated: use Install instead AddToScheme = localSchemeBuilder.AddToScheme Install = localSchemeBuilder.AddToScheme )
var GroupVersion = v1.GroupVersion{Group: GroupName, Version: "v1alpha1"}
GroupVersion specifies the group and the version used to register the objects.
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects Deprecated: use GroupVersion instead.
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type APIKey ¶ added in v0.10.0
type APIKey struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec APIKeySpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status APIKeyStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
APIKey is a resource that represents an API key for a service account +k8s:openapi-gen=true +resource:path=apikeys,strategy=APIKeyStrategy +kubebuilder:categories=all
func (*APIKey) DeepCopy ¶ added in v0.10.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIKey.
func (*APIKey) DeepCopyInto ¶ added in v0.10.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*APIKey) DeepCopyObject ¶ added in v0.10.0
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type APIKeyList ¶ added in v0.10.0
type APIKeyList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []APIKey `json:"items"`
}
APIKeyList contains a list of APIKey
func (*APIKeyList) DeepCopy ¶ added in v0.10.0
func (in *APIKeyList) DeepCopy() *APIKeyList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIKeyList.
func (*APIKeyList) DeepCopyInto ¶ added in v0.10.0
func (in *APIKeyList) DeepCopyInto(out *APIKeyList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*APIKeyList) DeepCopyObject ¶ added in v0.10.0
func (in *APIKeyList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type APIKeySpec ¶ added in v0.10.0
type APIKeySpec struct {
// InstanceName is the name of the instance this API key is for
InstanceName string `json:"instanceName,omitempty" protobuf:"bytes,1,opt,name=instanceName"`
// ServiceAccountName is the name of the service account this API key is for
ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,2,opt,name=serviceAccountName"`
// Description is a user defined description of the key
// +optional
Description string `json:"description,omitempty" protobuf:"bytes,3,opt,name=description"`
// Expiration is a duration (as a golang duration string) that defines how long this API key is valid for.
// This can only be set on initial creation and not updated later
// +optional
ExpirationTime *metav1.Time `json:"expirationTime,omitempty" protobuf:"bytes,4,opt,name=expiration"`
// Revoke is a boolean that defines if the token of this API key should be revoked.
// +kubebuilder:default=false
// +optional
Revoke bool `json:"revoke,omitempty" protobuf:"bytes,5,opt,name=revoke"`
// EncryptionKey is a public key to encrypt the API Key token.
// Please provide an RSA key with modulus length of at least 2048 bits.
// See: https://developer.mozilla.org/en-US/docs/Web/API/SubtleCrypto/generateKey#rsa_key_pair_generation
// See: https://developer.mozilla.org/en-US/docs/Web/API/SubtleCrypto/exportKey#subjectpublickeyinfo_export
// +optional
EncryptionKey *EncryptionKey `json:"encryptionKey,omitempty" protobuf:"bytes,6,opt,name=encryptionKey"`
}
APIKeySpec defines the desired state of APIKey
func (*APIKeySpec) DeepCopy ¶ added in v0.10.0
func (in *APIKeySpec) DeepCopy() *APIKeySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIKeySpec.
func (*APIKeySpec) DeepCopyInto ¶ added in v0.10.0
func (in *APIKeySpec) DeepCopyInto(out *APIKeySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type APIKeyStatus ¶ added in v0.10.0
type APIKeyStatus struct {
// KeyID is a generated field that is a uid for the token
// +optional
KeyID *string `json:"keyId,omitempty" protobuf:"bytes,1,opt,name=keyId"`
// IssuedAt is a timestamp of when the key was issued, stored as an epoch in seconds
// +optional
IssuedAt *metav1.Time `json:"issuedAt,omitempty" protobuf:"bytes,2,opt,name=issuedAt"`
// ExpiresAt is a timestamp of when the key expires
// +optional
ExpiresAt *metav1.Time `json:"expiresAt,omitempty" protobuf:"bytes,3,opt,name=expiresAt"`
// Token is the plaintext security token issued for the key.
// +optional
Token *string `json:"token,omitempty" protobuf:"bytes,4,opt,name=keySecret"`
// Token is the encrypted security token issued for the key.
// +optional
EncryptedToken *EncryptedToken `json:"encryptedToken,omitempty" protobuf:"bytes,7,opt,name=encryptedToken"`
// Conditions is an array of current observed service account conditions.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,5,rep,name=conditions"`
// ExpiresAt is a timestamp of when the key was revoked, it triggers revocation action
// +optional
RevokedAt *metav1.Time `json:"revokedAt,omitempty" protobuf:"bytes,6,opt,name=revokedAt"`
}
APIKeyStatus defines the observed state of ServiceAccount
func (*APIKeyStatus) DeepCopy ¶ added in v0.10.0
func (in *APIKeyStatus) DeepCopy() *APIKeyStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIKeyStatus.
func (*APIKeyStatus) DeepCopyInto ¶ added in v0.10.0
func (in *APIKeyStatus) DeepCopyInto(out *APIKeyStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AWSCloudConnection ¶
type AWSCloudConnection struct {
//nolint:stylecheck
AccountId string `json:"accountId" protobuf:"bytes,1,name=accountId"`
}
func (*AWSCloudConnection) DeepCopy ¶
func (in *AWSCloudConnection) DeepCopy() *AWSCloudConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AWSCloudConnection.
func (*AWSCloudConnection) DeepCopyInto ¶
func (in *AWSCloudConnection) DeepCopyInto(out *AWSCloudConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AmqpConfig ¶
type AmqpConfig struct {
}
func (*AmqpConfig) DeepCopy ¶
func (in *AmqpConfig) DeepCopy() *AmqpConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AmqpConfig.
func (*AmqpConfig) DeepCopyInto ¶
func (in *AmqpConfig) DeepCopyInto(out *AmqpConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AuditLog ¶
type AuditLog struct {
// +listType=set
Categories []string `json:"categories" protobuf:"bytes,1,rep,name=categories"`
}
func (*AuditLog) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuditLog.
func (*AuditLog) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AzureConnection ¶
type AzureConnection struct {
//nolint:stylecheck
SubscriptionId string `json:"subscriptionId" protobuf:"bytes,1,name=subscriptionId"`
//nolint:stylecheck
TenantId string `json:"tenantId" protobuf:"bytes,2,name=tenantId"`
//nolint:stylecheck
ClientId string `json:"clientId" protobuf:"bytes,3,name=clientId"`
//nolint:stylecheck
SupportClientId string `json:"supportClientId" protobuf:"bytes,4,name=supportClientId"`
}
func (*AzureConnection) DeepCopy ¶
func (in *AzureConnection) DeepCopy() *AzureConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureConnection.
func (*AzureConnection) DeepCopyInto ¶
func (in *AzureConnection) DeepCopyInto(out *AzureConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BookKeeperSetReference ¶
type BookKeeperSetReference struct {
// +optional
Namespace string `json:"namespace,omitempty" protobuf:"bytes,1,opt,name=namespace"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}
BookKeeperSetReference is a fully-qualified reference to a BookKeeperSet with a given name.
func (*BookKeeperSetReference) DeepCopy ¶
func (in *BookKeeperSetReference) DeepCopy() *BookKeeperSetReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookKeeperSetReference.
func (*BookKeeperSetReference) DeepCopyInto ¶
func (in *BookKeeperSetReference) DeepCopyInto(out *BookKeeperSetReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BookKeeperSetReference) ToNamespacedName ¶
func (r *BookKeeperSetReference) ToNamespacedName() types.NamespacedName
type ClusterRole ¶ added in v0.12.0
type ClusterRole struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec ClusterRoleSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status ClusterRoleStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
ClusterRole is a resource that defines a set of permissions that can be applied to a set of subjects. +k8s:openapi-gen=true +resource:path=clusterroles,strategy=ClusterRoleStrategy +kubebuilder:categories=all
func (*ClusterRole) DeepCopy ¶ added in v0.12.0
func (in *ClusterRole) DeepCopy() *ClusterRole
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterRole.
func (*ClusterRole) DeepCopyInto ¶ added in v0.12.0
func (in *ClusterRole) DeepCopyInto(out *ClusterRole)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterRole) DeepCopyObject ¶ added in v0.12.0
func (in *ClusterRole) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterRoleList ¶ added in v0.12.0
type ClusterRoleList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ClusterRole `json:"items"`
}
ClusterRoleList contains a list of ClusterRole
func (*ClusterRoleList) DeepCopy ¶ added in v0.12.0
func (in *ClusterRoleList) DeepCopy() *ClusterRoleList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterRoleList.
func (*ClusterRoleList) DeepCopyInto ¶ added in v0.12.0
func (in *ClusterRoleList) DeepCopyInto(out *ClusterRoleList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterRoleList) DeepCopyObject ¶ added in v0.12.0
func (in *ClusterRoleList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterRoleSpec ¶ added in v0.12.0
type ClusterRoleSpec struct {
// +listType=atomic
// Permissions Designed for general permission format
// SERVICE.RESOURCE.VERB
Permissions []string `json:"permissions,omitempty" protobuf:"bytes,1,opt,name=permissions"`
}
ClusterRoleSpec defines the desired state of ClusterRole
func (*ClusterRoleSpec) DeepCopy ¶ added in v0.12.0
func (in *ClusterRoleSpec) DeepCopy() *ClusterRoleSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterRoleSpec.
func (*ClusterRoleSpec) DeepCopyInto ¶ added in v0.12.0
func (in *ClusterRoleSpec) DeepCopyInto(out *ClusterRoleSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterRoleStatus ¶ added in v0.12.0
type ClusterRoleStatus struct {
// Conditions is an array of current observed conditions.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
// FailedClusters is an array of clusters which failed to apply the ClusterRole resources.
// +deprecated, shouldn't expose the failed clusters to the user
// +optional
// +listType=atomic
FailedClusters []FailedCluster `json:"failedClusters,omitempty" protobuf:"bytes,2,rep,name=failedClusters"`
}
ClusterRoleStatus defines the observed state of ClusterRole
func (*ClusterRoleStatus) DeepCopy ¶ added in v0.12.0
func (in *ClusterRoleStatus) DeepCopy() *ClusterRoleStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterRoleStatus.
func (*ClusterRoleStatus) DeepCopyInto ¶ added in v0.12.0
func (in *ClusterRoleStatus) DeepCopyInto(out *ClusterRoleStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Condition ¶ added in v0.10.0
type Condition struct {
Type ConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ConditionType"`
Status metav1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/apimachinery/pkg/apis/meta/v1.ConditionStatus"`
Reason ConditionReason `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason,casttype=ConditionReason"`
Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,5,opt,name=lastTransitionTime"`
// +optional
// +kubebuilder:validation:Minimum=0
ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,6,opt,name=observedGeneration"`
}
func (*Condition) DeepCopy ¶ added in v0.10.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶ added in v0.10.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionGroup ¶ added in v0.12.0
type ConditionGroup struct {
Relation ConditionGroupRelation `json:"relation,omitempty" protobuf:"bytes,1,opt,name=relation"`
Conditions []RoleBindingCondition `json:"conditions" protobuf:"bytes,2,req,name=conditions"`
ConditionGroups []ConditionGroup `json:"conditionGroups,omitempty" protobuf:"bytes,3,opt,name=conditionGroups"`
}
ConditionGroup is a group of conditions that are used to determine if a role binding should be applied. Deprecated
func (*ConditionGroup) DeepCopy ¶ added in v0.12.0
func (in *ConditionGroup) DeepCopy() *ConditionGroup
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionGroup.
func (*ConditionGroup) DeepCopyInto ¶ added in v0.12.0
func (in *ConditionGroup) DeepCopyInto(out *ConditionGroup)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionGroupRelation ¶ added in v0.12.0
type ConditionGroupRelation int
type ConditionReason ¶ added in v0.10.0
type ConditionReason string
type ConditionType ¶ added in v0.10.0
type ConditionType string
type Config ¶
type Config struct {
// WebsocketEnabled controls whether websocket is enabled.
// +optional
WebsocketEnabled *bool `json:"websocketEnabled,omitempty" protobuf:"varint,1,opt,name=websocketEnabled"`
// FunctionEnabled controls whether function is enabled.
// +optional
FunctionEnabled *bool `json:"functionEnabled,omitempty" protobuf:"varint,2,opt,name=functionEnabled"`
// TransactionEnabled controls whether transaction is enabled.
// +optional
TransactionEnabled *bool `json:"transactionEnabled,omitempty" protobuf:"varint,3,opt,name=transactionEnabled"`
// Protocols controls the protocols enabled in brokers.
// +optional
Protocols *ProtocolsConfig `json:"protocols,omitempty" protobuf:"bytes,5,opt,name=protocols"`
// AuditLog controls the custom config of audit log.
// +optional
AuditLog *AuditLog `json:"auditLog,omitempty" protobuf:"bytes,6,opt,name=auditLog"`
// LakehouseStorage controls the lakehouse storage config.
// +optional
LakehouseStorage *LakehouseStorageConfig `json:"lakehouseStorage,omitempty" protobuf:"bytes,7,opt,name=lakehouseStorage"`
// Custom accepts custom configurations.
// +optional
Custom map[string]string `json:"custom,omitempty" protobuf:"bytes,4,rep,name=custom"`
}
func (*Config) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Config.
func (*Config) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Domain ¶
type Domain struct {
Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
// +optional
Type DomainType `json:"type,omitempty" protobuf:"bytes,2,opt,name=type"`
// +optional
TLS *DomainTLS `json:"tls,omitempty" protobuf:"bytes,3,opt,name=tls"`
}
func (*Domain) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Domain.
func (*Domain) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DomainTLS ¶
type DomainTLS struct {
// CertificateName specifies the certificate object name to use.
// +optional
CertificateName string `json:"certificateName,omitempty" protobuf:"bytes,1,opt,name=name"`
}
func (*DomainTLS) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DomainTLS.
func (*DomainTLS) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DomainType ¶
type DomainType string
const ( DomainTypeService DomainType = "service" DomainTypeIngress DomainType = "" )
type EncryptedToken ¶ added in v0.10.0
type EncryptedToken struct {
// JWE is the token as a JSON Web Encryption (JWE) message.
// For RSA public keys, the key encryption algorithm is RSA-OAEP, and the content encryption algorithm is AES GCM.
// +optional
JWE *string `json:"jwe,omitempty" protobuf:"bytes,7,opt,name=jwe"`
}
EncryptedToken is token that is encrypted using an encryption key. +structType=atomic
func (*EncryptedToken) DeepCopy ¶ added in v0.10.0
func (in *EncryptedToken) DeepCopy() *EncryptedToken
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptedToken.
func (*EncryptedToken) DeepCopyInto ¶ added in v0.10.0
func (in *EncryptedToken) DeepCopyInto(out *EncryptedToken)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionKey ¶ added in v0.10.0
type EncryptionKey struct {
// PEM is a PEM-encoded public key in PKIX, ASN.1 DER form ("spki" format).
// +optional
PEM string `json:"pem,omitempty" protobuf:"bytes,1,opt,name=pem"`
// JWK is a JWK-encoded public key.
// +optional
JWK string `json:"jwk,omitempty" protobuf:"bytes,2,opt,name=jwk"`
}
EncryptionKey specifies a public key for encryption purposes. Either a PEM or JWK must be specified.
func (*EncryptionKey) DeepCopy ¶ added in v0.10.0
func (in *EncryptionKey) DeepCopy() *EncryptionKey
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionKey.
func (*EncryptionKey) DeepCopyInto ¶ added in v0.10.0
func (in *EncryptionKey) DeepCopyInto(out *EncryptionKey)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FailedCluster ¶ added in v0.12.0
type FailedCluster struct {
// Name is the Cluster's name
Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
// Namespace is the Cluster's namespace
Namespace string `json:"namespace" protobuf:"bytes,2,opt,name=namespace"`
// Reason is the failed reason
Reason string `json:"reason" protobuf:"bytes,3,opt,name=reason"`
}
func (*FailedCluster) DeepCopy ¶ added in v0.12.0
func (in *FailedCluster) DeepCopy() *FailedCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FailedCluster.
func (*FailedCluster) DeepCopyInto ¶ added in v0.12.0
func (in *FailedCluster) DeepCopyInto(out *FailedCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GCPCloudConnection ¶
type GCPCloudConnection struct {
//nolint:stylecheck
ProjectId string `json:"projectId" protobuf:"bytes,1,name=projectId"`
}
func (*GCPCloudConnection) DeepCopy ¶
func (in *GCPCloudConnection) DeepCopy() *GCPCloudConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCPCloudConnection.
func (*GCPCloudConnection) DeepCopyInto ¶
func (in *GCPCloudConnection) DeepCopyInto(out *GCPCloudConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaConfig ¶
type KafkaConfig struct {
}
func (*KafkaConfig) DeepCopy ¶
func (in *KafkaConfig) DeepCopy() *KafkaConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConfig.
func (*KafkaConfig) DeepCopyInto ¶
func (in *KafkaConfig) DeepCopyInto(out *KafkaConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LakehouseStorageConfig ¶
type LakehouseStorageConfig struct {
// +optional
// +kubebuilder:validation:Enum:=iceberg
// +kubebuilder:default=iceberg
LakehouseType *string `json:"lakehouseType,omitempty" protobuf:"bytes,1,opt,name=lakehouseType"`
// +optional
// +kubebuilder:validation:Enum:=rest
// +kubebuilder:default=rest
CatalogType *string `json:"catalogType,omitempty" protobuf:"bytes,2,opt,name=catalogType"`
// todo: maybe we need to support mount secrets as the catalog credentials?
// +kubebuilder:validation:Required
CatalogCredentials string `json:"catalogCredentials" protobuf:"bytes,3,opt,name=catalogCredentials"`
// +kubebuilder:validation:Required
//nolint:stylecheck
CatalogConnectionUrl string `json:"catalogConnectionUrl" protobuf:"bytes,4,opt,name=catalogConnectionUrl"`
// +kubebuilder:validation:Required
CatalogWarehouse string `json:"catalogWarehouse" protobuf:"bytes,5,opt,name=catalogWarehouse"`
}
func (*LakehouseStorageConfig) DeepCopy ¶
func (in *LakehouseStorageConfig) DeepCopy() *LakehouseStorageConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LakehouseStorageConfig.
func (*LakehouseStorageConfig) DeepCopyInto ¶
func (in *LakehouseStorageConfig) DeepCopyInto(out *LakehouseStorageConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MqttConfig ¶
type MqttConfig struct {
}
MqttConfig defines the mqtt protocol config
func (*MqttConfig) DeepCopy ¶
func (in *MqttConfig) DeepCopy() *MqttConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MqttConfig.
func (*MqttConfig) DeepCopyInto ¶
func (in *MqttConfig) DeepCopyInto(out *MqttConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PoolMemberReference ¶
type PoolMemberReference struct {
Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}
PoolMemberReference is a reference to a pool member with a given name.
func (*PoolMemberReference) DeepCopy ¶
func (in *PoolMemberReference) DeepCopy() *PoolMemberReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PoolMemberReference.
func (*PoolMemberReference) DeepCopyInto ¶
func (in *PoolMemberReference) DeepCopyInto(out *PoolMemberReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (PoolMemberReference) ToNamespacedName ¶
func (r PoolMemberReference) ToNamespacedName() types.NamespacedName
type PoolRef ¶
type PoolRef struct {
Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}
PoolRef is a reference to a pool with a given name.
func (*PoolRef) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PoolRef.
func (*PoolRef) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (PoolRef) ToNamespacedName ¶
func (r PoolRef) ToNamespacedName() types.NamespacedName
type ProtocolsConfig ¶
type ProtocolsConfig struct {
// Kafka controls whether to enable Kafka protocol in brokers
// +optional
Kafka *KafkaConfig `json:"kafka,omitempty" protobuf:"bytes,1,opt,name=kafka"`
// Amqp controls whether to enable Amqp protocol in brokers
// +optional
//nolint:stylecheck
Amqp *AmqpConfig `json:"amqp,omitempty" protobuf:"bytes,2,opt,name=amqp"`
// Mqtt controls whether to enable mqtt protocol in brokers
// +optional
Mqtt *MqttConfig `json:"mqtt,omitempty" protobuf:"bytes,3,opt,name=mqtt"`
}
func (*ProtocolsConfig) DeepCopy ¶
func (in *ProtocolsConfig) DeepCopy() *ProtocolsConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProtocolsConfig.
func (*ProtocolsConfig) DeepCopyInto ¶
func (in *ProtocolsConfig) DeepCopyInto(out *ProtocolsConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PullPolicy ¶
type PullPolicy string
PullPolicy describes a policy for if/when to pull a container image
const ( // PullAlways means that kubelet always attempts to pull the latest image. Container will fail If the pull fails. PullAlways PullPolicy = "Always" // PullNever means that kubelet never pulls an image, but only uses a local image. Container will fail if the image isn't present PullNever PullPolicy = "Never" // PullIfNotPresent means that kubelet pulls if the image isn't present on disk. Container will fail if the image isn't present and the pull fails. PullIfNotPresent PullPolicy = "IfNotPresent" )
type ResourceName ¶ added in v0.12.0
type ResourceName struct {
Organization string `json:"organization,omitempty" protobuf:"bytes,1,opt,name=organization"`
Instance string `json:"instance,omitempty" protobuf:"bytes,2,opt,name=instance"`
Cluster string `json:"cluster,omitempty" protobuf:"bytes,3,opt,name=cluster"`
Tenant string `json:"tenant,omitempty" protobuf:"bytes,4,opt,name=tenant"`
Namespace string `json:"namespace,omitempty" protobuf:"bytes,5,opt,name=namespace"`
TopicDomain string `json:"topicDomain,omitempty" protobuf:"bytes,6,opt,name=topicDomain"`
TopicName string `json:"topicName,omitempty" protobuf:"bytes,7,opt,name=topicName"`
Subscription string `json:"subscription,omitempty" protobuf:"bytes,8,opt,name=subscription"`
ServiceAccount string `json:"serviceAccount,omitempty" protobuf:"bytes,9,opt,name=serviceAccount"`
APIKey string `json:"apiKey,omitempty" protobuf:"bytes,10,opt,name=apiKey"`
Secret string `json:"secret,omitempty" protobuf:"bytes,11,opt,name=secret"`
}
func (*ResourceName) DeepCopy ¶ added in v0.12.0
func (in *ResourceName) DeepCopy() *ResourceName
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceName.
func (*ResourceName) DeepCopyInto ¶ added in v0.12.0
func (in *ResourceName) DeepCopyInto(out *ResourceName)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleBinding ¶ added in v0.12.0
type RoleBinding struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec RoleBindingSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status RoleBindingStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
RoleBinding is a resource that grants a set of permissions to a set of subjects. +k8s:openapi-gen=true +resource:path=rolebindings,strategy=RoleBindingStrategy +kubebuilder:categories=all
func (*RoleBinding) DeepCopy ¶ added in v0.12.0
func (in *RoleBinding) DeepCopy() *RoleBinding
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleBinding.
func (*RoleBinding) DeepCopyInto ¶ added in v0.12.0
func (in *RoleBinding) DeepCopyInto(out *RoleBinding)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RoleBinding) DeepCopyObject ¶ added in v0.12.0
func (in *RoleBinding) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RoleBindingCondition ¶ added in v0.12.0
type RoleBindingCondition struct {
Type RoleBindingConditionType `json:"type,omitempty" protobuf:"bytes,1,opt,name=type"`
Operator RoleBindingConditionOperator `json:"operator,omitempty" protobuf:"bytes,2,opt,name=operator"`
Srn Srn `json:"srn,omitempty" protobuf:"bytes,3,opt,name=srn"`
}
RoleBindingCondition is a condition that is used to determine if a role binding should be applied. Deprecated
func (*RoleBindingCondition) DeepCopy ¶ added in v0.12.0
func (in *RoleBindingCondition) DeepCopy() *RoleBindingCondition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleBindingCondition.
func (*RoleBindingCondition) DeepCopyInto ¶ added in v0.12.0
func (in *RoleBindingCondition) DeepCopyInto(out *RoleBindingCondition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleBindingConditionOperator ¶ added in v0.12.0
type RoleBindingConditionOperator int
type RoleBindingConditionType ¶ added in v0.12.0
type RoleBindingConditionType int
type RoleBindingList ¶ added in v0.12.0
type RoleBindingList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []RoleBinding `json:"items"`
}
RoleBindingList contains a list of RoleBinding
func (*RoleBindingList) DeepCopy ¶ added in v0.12.0
func (in *RoleBindingList) DeepCopy() *RoleBindingList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleBindingList.
func (*RoleBindingList) DeepCopyInto ¶ added in v0.12.0
func (in *RoleBindingList) DeepCopyInto(out *RoleBindingList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RoleBindingList) DeepCopyObject ¶ added in v0.12.0
func (in *RoleBindingList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RoleBindingSpec ¶ added in v0.12.0
type RoleBindingSpec struct {
// +listType=atomic
Subjects []Subject `json:"subjects" protobuf:"bytes,1,rep,name=subjects"`
RoleRef RoleRef `json:"roleRef" protobuf:"bytes,2,opt,name=roleRef"`
// +optional
ConditionGroup *ConditionGroup `json:"conditionGroup,omitempty" protobuf:"bytes,3,opt,name=conditionGroup"`
// +optional
CEL *string `json:"cel,omitempty" protobuf:"bytes,4,opt,name=cel"`
// +optional
// +listType=atomic
// ResourceNames indicate the StreamNative Resource Name
ResourceNames []ResourceName `json:"resourceNames,omitempty" protobuf:"bytes,5,opt,name=resourceNames"`
}
RoleBindingSpec defines the desired state of RoleBinding
func (*RoleBindingSpec) DeepCopy ¶ added in v0.12.0
func (in *RoleBindingSpec) DeepCopy() *RoleBindingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleBindingSpec.
func (*RoleBindingSpec) DeepCopyInto ¶ added in v0.12.0
func (in *RoleBindingSpec) DeepCopyInto(out *RoleBindingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleBindingStatus ¶ added in v0.12.0
type RoleBindingStatus struct {
// Conditions is an array of current observed conditions.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
// FailedClusters is an array of clusters which failed to apply the RoleBinding resources.
// +optional
// +listType=atomic
FailedClusters []FailedCluster `json:"failedClusters,omitempty" protobuf:"bytes,2,rep,name=failedClusters"`
// SyncedClusters is a map of clusters which applied the RoleBinding resources and the RoleBinding's generation.
// If the generation in this map is same with the current RoleBinding's generation, it will skip apply the
// RoleBinding to the cluster
// +optional
// +listType=atomic
SyncedClusters map[string]int64 `json:"syncedClusters,omitempty" protobuf:"bytes,3,rep,name=syncedClusters"`
}
RoleBindingStatus defines the observed state of RoleBinding
func (*RoleBindingStatus) DeepCopy ¶ added in v0.12.0
func (in *RoleBindingStatus) DeepCopy() *RoleBindingStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleBindingStatus.
func (*RoleBindingStatus) DeepCopyInto ¶ added in v0.12.0
func (in *RoleBindingStatus) DeepCopyInto(out *RoleBindingStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleRef ¶
type RoleRef struct {
Kind string `json:"kind" protobuf:"bytes,1,opt,name=kind"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
APIGroup string `json:"apiGroup" protobuf:"bytes,3,opt,name=apiGroup"`
}
func (*RoleRef) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleRef.
func (*RoleRef) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Secret ¶
type Secret struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec SecretSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status SecretStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
// InstanceName is the name of the instance this secret is for (e.g. pulsar-instance)
// +optional
InstanceName string `json:"instanceName" protobuf:"bytes,4,opt,name=instanceName"`
// Location is the location of the secret.
// +optional
Location string `json:"location" protobuf:"bytes,5,opt,name=location"`
// the value should be base64 encoded
Data map[string]string `json:"data,omitempty" protobuf:"bytes,6,opt,name=data"`
// PoolMemberRef is the pool member to deploy the secret.
// admission controller will infer this information automatically
// +optional
PoolMemberRef *PoolMemberReference `json:"poolMemberRef,omitempty" protobuf:"bytes,7,opt,name=poolMemberRef"`
// +optional
// +listType=atomic
Tolerations []Toleration `json:"tolerations,omitempty" protobuf:"bytes,8,opt,name=tolerations"`
// Type Used to facilitate programmatic handling of secret data.
// +optional
Type *corev1.SecretType `json:"type,omitempty" protobuf:"bytes,9,opt,name=type"`
}
Secret is the Schema for the secrets API +k8s:openapi-gen=true +resource:path=secrets,strategy=SecretStrategy +kubebuilder:categories=all
func (*Secret) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Secret.
func (*Secret) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Secret) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SecretList ¶
type SecretList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Secret `json:"items"`
}
SecretList contains a list of Secret
func (*SecretList) DeepCopy ¶
func (in *SecretList) DeepCopy() *SecretList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretList.
func (*SecretList) DeepCopyInto ¶
func (in *SecretList) DeepCopyInto(out *SecretList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SecretList) DeepCopyObject ¶
func (in *SecretList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SecretRef ¶
type SecretRef struct {
// Namespace is the secret namespace
// +optional
Namespace string `json:"namespace,omitempty" protobuf:"bytes,1,opt,name=namespace"`
// Name is the secret name
Name string `json:"name,omitempty" protobuf:"bytes,2,opt,name=name"`
}
SecretRef is a reference to a Cloud Secret with a given name
func (*SecretRef) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretRef.
func (*SecretRef) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SecretRef) ToNamespacedName ¶
func (s *SecretRef) ToNamespacedName() types.NamespacedName
type SecretSpec ¶
type SecretSpec struct {
}
func (*SecretSpec) DeepCopy ¶
func (in *SecretSpec) DeepCopy() *SecretSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretSpec.
func (*SecretSpec) DeepCopyInto ¶
func (in *SecretSpec) DeepCopyInto(out *SecretSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SecretStatus ¶
type SecretStatus struct {
}
func (*SecretStatus) DeepCopy ¶
func (in *SecretStatus) DeepCopy() *SecretStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretStatus.
func (*SecretStatus) DeepCopyInto ¶
func (in *SecretStatus) DeepCopyInto(out *SecretStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceAccount ¶ added in v0.10.0
type ServiceAccount struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec ServiceAccountSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status ServiceAccountStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
ServiceAccount is a resource that represents a service account for a cluster +k8s:openapi-gen=true +resource:path=serviceaccounts,strategy=ServiceAccountStrategy +kubebuilder:categories=all
func (*ServiceAccount) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccount) DeepCopy() *ServiceAccount
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccount.
func (*ServiceAccount) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccount) DeepCopyInto(out *ServiceAccount)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceAccount) DeepCopyObject ¶ added in v0.10.0
func (in *ServiceAccount) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceAccountBinding ¶ added in v0.10.0
type ServiceAccountBinding struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec ServiceAccountBindingSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status ServiceAccountBindingStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
ServiceAccountBinding is a resource that represents a binding between a service account and a pool member +k8s:openapi-gen=true +resource:path=serviceaccountbindings,strategy=ServiceAccountBindingStrategy +kubebuilder:categories=all
func (*ServiceAccountBinding) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountBinding) DeepCopy() *ServiceAccountBinding
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountBinding.
func (*ServiceAccountBinding) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountBinding) DeepCopyInto(out *ServiceAccountBinding)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceAccountBinding) DeepCopyObject ¶ added in v0.10.0
func (in *ServiceAccountBinding) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceAccountBindingList ¶ added in v0.10.0
type ServiceAccountBindingList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ServiceAccountBinding `json:"items"`
}
ServiceAccountBindingList contains a list of ServiceAccountBinding
func (*ServiceAccountBindingList) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountBindingList) DeepCopy() *ServiceAccountBindingList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountBindingList.
func (*ServiceAccountBindingList) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountBindingList) DeepCopyInto(out *ServiceAccountBindingList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceAccountBindingList) DeepCopyObject ¶ added in v0.10.0
func (in *ServiceAccountBindingList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceAccountBindingSpec ¶ added in v0.10.0
type ServiceAccountBindingSpec struct {
// refers to the ServiceAccount under the same namespace as this binding object
ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,4,name=serviceAccountName"`
// refers to a PoolMember in the current namespace or other namespaces
PoolMemberRef PoolMemberReference `json:"poolMemberRef,omitempty" protobuf:"bytes,5,name=poolMemberRef"`
}
ServiceAccountBindingSpec defines the desired state of ServiceAccountBinding
func (*ServiceAccountBindingSpec) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountBindingSpec) DeepCopy() *ServiceAccountBindingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountBindingSpec.
func (*ServiceAccountBindingSpec) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountBindingSpec) DeepCopyInto(out *ServiceAccountBindingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceAccountBindingStatus ¶ added in v0.10.0
type ServiceAccountBindingStatus struct {
// Conditions is an array of current observed service account binding conditions.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}
ServiceAccountBindingStatus defines the observed state of ServiceAccountBinding
func (*ServiceAccountBindingStatus) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountBindingStatus) DeepCopy() *ServiceAccountBindingStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountBindingStatus.
func (*ServiceAccountBindingStatus) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountBindingStatus) DeepCopyInto(out *ServiceAccountBindingStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceAccountList ¶ added in v0.10.0
type ServiceAccountList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ServiceAccount `json:"items"`
}
ServiceAccountList contains a list of ServiceAccount
func (*ServiceAccountList) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountList) DeepCopy() *ServiceAccountList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountList.
func (*ServiceAccountList) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountList) DeepCopyInto(out *ServiceAccountList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceAccountList) DeepCopyObject ¶ added in v0.10.0
func (in *ServiceAccountList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceAccountSpec ¶ added in v0.10.0
type ServiceAccountSpec struct {
}
ServiceAccountSpec defines the desired state of ServiceAccount
func (*ServiceAccountSpec) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountSpec) DeepCopy() *ServiceAccountSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountSpec.
func (*ServiceAccountSpec) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountSpec) DeepCopyInto(out *ServiceAccountSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceAccountStatus ¶ added in v0.10.0
type ServiceAccountStatus struct {
// PrivateKeyType indicates the type of private key information
// +optional
PrivateKeyType string `json:"privateKeyType,omitempty" protobuf:"bytes,1,opt,name=privateKeyType"`
// PrivateKeyData provides the private key data (in base-64 format) for authentication purposes
// +optional
PrivateKeyData string `json:"privateKeyData,omitempty" protobuf:"bytes,2,opt,name=privateKeyData"`
// Conditions is an array of current observed service account conditions.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
// +listType=map
// +listMapKey=type
Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,3,rep,name=conditions"`
}
ServiceAccountStatus defines the observed state of ServiceAccount
func (*ServiceAccountStatus) DeepCopy ¶ added in v0.10.0
func (in *ServiceAccountStatus) DeepCopy() *ServiceAccountStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountStatus.
func (*ServiceAccountStatus) DeepCopyInto ¶ added in v0.10.0
func (in *ServiceAccountStatus) DeepCopyInto(out *ServiceAccountStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SharingConfig ¶
type SharingConfig struct {
// +listType=atomic
Namespaces []string `json:"namespaces" protobuf:"bytes,1,rep,name=namespaces"`
}
func (*SharingConfig) DeepCopy ¶
func (in *SharingConfig) DeepCopy() *SharingConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SharingConfig.
func (*SharingConfig) DeepCopyInto ¶
func (in *SharingConfig) DeepCopyInto(out *SharingConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Srn ¶ added in v0.12.0
type Srn struct {
Schema string `json:"schema,omitempty" protobuf:"bytes,1,opt,name=schema"`
Version string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"`
Organization string `json:"organization,omitempty" protobuf:"bytes,3,opt,name=organization"`
Instance string `json:"instance,omitempty" protobuf:"bytes,4,opt,name=instance"`
Cluster string `json:"cluster,omitempty" protobuf:"bytes,5,opt,name=cluster"`
Tenant string `json:"tenant,omitempty" protobuf:"bytes,6,opt,name=tenant"`
Namespace string `json:"namespace,omitempty" protobuf:"bytes,7,opt,name=namespace"`
TopicDomain string `json:"topicDomain,omitempty" protobuf:"bytes,8,opt,name=topicDomain"`
TopicName string `json:"topicName,omitempty" protobuf:"bytes,9,opt,name=topicName"`
Subscription string `json:"subscription,omitempty" protobuf:"bytes,10,opt,name=subscription"`
}
Srn is a StreamNative Resource Name. Deprecated
func (*Srn) DeepCopy ¶ added in v0.12.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Srn.
func (*Srn) DeepCopyInto ¶ added in v0.12.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Subject ¶
type Subject struct {
Kind string `json:"kind" protobuf:"bytes,1,opt,name=kind"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
// +optional
Namespace string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
APIGroup string `json:"apiGroup" protobuf:"bytes,4,opt,name=apiGroup"`
}
func (*Subject) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Subject.
func (*Subject) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Taint ¶
type Taint struct {
// Required. The taint key to be applied to a workload cluster.
Key string `json:"key" protobuf:"bytes,1,opt,name=key"`
// Optional. The taint value corresponding to the taint key.
// +optional
Value string `json:"value,omitempty" protobuf:"bytes,2,opt,name=value"`
// Required. The effect of the taint on workloads
// that do not tolerate the taint.
// Valid effects are NoSchedule, PreferNoSchedule and NoExecute.
Effect TaintEffect `json:"effect" protobuf:"bytes,3,opt,name=effect,casttype=TaintEffect"`
// TimeAdded represents the time at which the taint was added.
// +optional
TimeAdded *metav1.Time `json:"timeAdded,omitempty" protobuf:"bytes,4,opt,name=timeAdded"`
}
Taint - The workload cluster this Taint is attached to has the "effect" on any workload that does not tolerate the Taint.
func (*Taint) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Taint.
func (*Taint) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TaintEffect ¶
type TaintEffect string
const ( // TaintEffectNoSchedule has the effect of not scheduling new workloads onto the workload cluster // unless they tolerate the taint. // Enforced by the scheduler. TaintEffectNoSchedule TaintEffect = "NoSchedule" // TaintEffectPreferNoSchedule is Like TaintEffectNoSchedule, but the scheduler tries not to schedule // new workloads onto the workload cluster, rather than prohibiting it entirely. // Enforced by the scheduler. TaintEffectPreferNoSchedule TaintEffect = "PreferNoSchedule" // TaintEffectNoCleanup has the effect of skipping any cleanup of workload objects. // Set this effect to allow for API object finalization, which normally requires // the workload cluster to be ready, to proceed without normal cleanups. TaintEffectNoCleanup TaintEffect = "NoCleanup" // TaintEffectNoConnect has the effect of skipping any attempts to connect to the workload cluster. TaintEffectNoConnect TaintEffect = "NoConnect" )
type Toleration ¶
type Toleration struct {
// Key is the taint key that the toleration applies to. Empty means match all taint keys.
// If the key is empty, operator must be Exists; this combination means to match all values and all keys.
// +optional
Key string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
// Operator represents a key's relationship to the value.
// Valid operators are Exists and Equal. Defaults to Equal.
// Exists is equivalent to wildcard for value, so that a workload can
// tolerate all taints of a particular category.
// +optional
Operator TolerationOperator `json:"operator,omitempty" protobuf:"bytes,2,opt,name=operator,casttype=TolerationOperator"`
// Value is the taint value the toleration matches to.
// If the operator is Exists, the value should be empty, otherwise just a regular string.
// +optional
Value string `json:"value,omitempty" protobuf:"bytes,3,opt,name=value"`
// Effect indicates the taint effect to match. Empty means match all taint effects.
// When specified, allowed values are NoSchedule and PreferNoSchedule.
// +optional
Effect TaintEffect `json:"effect,omitempty" protobuf:"bytes,4,opt,name=effect,casttype=TaintEffect"`
}
Toleration The workload this Toleration is attached to tolerates any taint that matches the triple <key,value,effect> using the matching operator <operator>.
func (*Toleration) DeepCopy ¶
func (in *Toleration) DeepCopy() *Toleration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Toleration.
func (*Toleration) DeepCopyInto ¶
func (in *Toleration) DeepCopyInto(out *Toleration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (Toleration) MatchAllEffects ¶
func (t Toleration) MatchAllEffects() bool
func (Toleration) MatchAllKeys ¶
func (t Toleration) MatchAllKeys() bool
func (Toleration) MatchAllValues ¶
func (t Toleration) MatchAllValues() bool
func (Toleration) Tolerates ¶
func (t Toleration) Tolerates(taint Taint) bool
type TolerationOperator ¶
type TolerationOperator string
TolerationOperator A toleration operator is the set of operators that can be used in a toleration.
const ( TolerationOpExists TolerationOperator = "Exists" TolerationOpEqual TolerationOperator = "Equal" )
type ZooKeeperSetReference ¶
type ZooKeeperSetReference struct {
// +optional
Namespace string `json:"namespace,omitempty" protobuf:"bytes,1,opt,name=namespace"`
Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}
ZooKeeperSetReference is a fully-qualified reference to a ZooKeeperSet with a given name.
func (*ZooKeeperSetReference) DeepCopy ¶
func (in *ZooKeeperSetReference) DeepCopy() *ZooKeeperSetReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZooKeeperSetReference.
func (*ZooKeeperSetReference) DeepCopyInto ¶
func (in *ZooKeeperSetReference) DeepCopyInto(out *ZooKeeperSetReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ZooKeeperSetReference) ToNamespacedName ¶
func (r *ZooKeeperSetReference) ToNamespacedName() types.NamespacedName