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 Condition
- type ConditionReason
- type ConditionType
- type Config
- type Domain
- type DomainTLS
- type DomainType
- type EncryptedToken
- type EncryptionKey
- type GCPCloudConnection
- type KafkaConfig
- type LakehouseStorageConfig
- type MqttConfig
- type PoolMemberReference
- type PoolRef
- type ProtocolsConfig
- type PullPolicy
- 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 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 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 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 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 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 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 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