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 AWSCloudConnection
- type AmqpConfig
- type AuditLog
- type AzureConnection
- type BookKeeperSetReference
- type Config
- type Domain
- type DomainTLS
- type DomainType
- 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 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 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 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 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 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 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