v1alpha1

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

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

View Source
const (
	AnnotationReconcilePaused = "cloud.streamnative.io/reconcile-paused"
	AnnotationReconcileMode   = "cloud.streamnative.io/reconcile-mode"
)
View Source
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"
)
View Source
const GroupName = "cloud.streamnative.io"

GroupName specifies the group name used to register the objects.

Variables

View Source
var (
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	// Deprecated: use Install instead
	AddToScheme = localSchemeBuilder.AddToScheme
	Install     = localSchemeBuilder.AddToScheme
)
View Source
var GroupVersion = v1.GroupVersion{Group: GroupName, Version: "v1alpha1"}

GroupVersion specifies the group and the version used to register the objects.

View Source
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

func (in *AuditLog) DeepCopy() *AuditLog

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

func (*AuditLog) DeepCopyInto

func (in *AuditLog) DeepCopyInto(out *AuditLog)

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

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

func (in *Config) DeepCopy() *Config

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

func (*Config) DeepCopyInto

func (in *Config) DeepCopyInto(out *Config)

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

func (in *Domain) DeepCopy() *Domain

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

func (*Domain) DeepCopyInto

func (in *Domain) DeepCopyInto(out *Domain)

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

func (in *DomainTLS) DeepCopy() *DomainTLS

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

func (*DomainTLS) DeepCopyInto

func (in *DomainTLS) DeepCopyInto(out *DomainTLS)

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

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

func (in *PoolRef) DeepCopy() *PoolRef

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

func (*PoolRef) DeepCopyInto

func (in *PoolRef) DeepCopyInto(out *PoolRef)

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

func (in *RoleRef) DeepCopy() *RoleRef

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

func (*RoleRef) DeepCopyInto

func (in *RoleRef) DeepCopyInto(out *RoleRef)

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

func (in *Secret) DeepCopy() *Secret

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

func (*Secret) DeepCopyInto

func (in *Secret) DeepCopyInto(out *Secret)

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

func (*Secret) DeepCopyObject

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

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

func (in *SecretRef) DeepCopy() *SecretRef

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

func (*SecretRef) DeepCopyInto

func (in *SecretRef) DeepCopyInto(out *SecretRef)

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

func (in *Subject) DeepCopy() *Subject

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

func (*Subject) DeepCopyInto

func (in *Subject) DeepCopyInto(out *Subject)

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

func (in *Taint) DeepCopy() *Taint

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

func (*Taint) DeepCopyInto

func (in *Taint) DeepCopyInto(out *Taint)

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL