v1alpha1

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Feb 4, 2026 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 (
	ConditionTypeReady ConditionType = "Ready"

	ConditionReasonReady    ConditionReason = "Ready"
	ConditionReasonNotReady ConditionReason = "NotReady"
)
View Source
const (
	RelationOr         ConditionGroupRelation       = 0
	RelationAnd        ConditionGroupRelation       = 1
	TypeSrn            RoleBindingConditionType     = 0
	OperatorKeyMatch   RoleBindingConditionOperator = 0
	OperatorRegexMatch RoleBindingConditionOperator = 1
)
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 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

func (in *APIKey) DeepCopy() *APIKey

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

func (*APIKey) DeepCopyInto added in v0.10.0

func (in *APIKey) DeepCopyInto(out *APIKey)

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

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

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

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 ClusterRole added in v0.12.0

type ClusterRole struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   ClusterRoleSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status ClusterRoleStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

ClusterRole is a resource that defines a set of permissions that can be applied to a set of subjects. +k8s:openapi-gen=true +resource:path=clusterroles,strategy=ClusterRoleStrategy +kubebuilder:categories=all

func (*ClusterRole) DeepCopy added in v0.12.0

func (in *ClusterRole) DeepCopy() *ClusterRole

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

func (*ClusterRole) DeepCopyInto added in v0.12.0

func (in *ClusterRole) DeepCopyInto(out *ClusterRole)

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

func (*ClusterRole) DeepCopyObject added in v0.12.0

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

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

type ClusterRoleList added in v0.12.0

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

ClusterRoleList contains a list of ClusterRole

func (*ClusterRoleList) DeepCopy added in v0.12.0

func (in *ClusterRoleList) DeepCopy() *ClusterRoleList

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

func (*ClusterRoleList) DeepCopyInto added in v0.12.0

func (in *ClusterRoleList) DeepCopyInto(out *ClusterRoleList)

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

func (*ClusterRoleList) DeepCopyObject added in v0.12.0

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

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

type ClusterRoleSpec added in v0.12.0

type ClusterRoleSpec struct {
	// +listType=atomic
	// Permissions Designed for general permission format
	//     SERVICE.RESOURCE.VERB
	Permissions []string `json:"permissions,omitempty" protobuf:"bytes,1,opt,name=permissions"`
}

ClusterRoleSpec defines the desired state of ClusterRole

func (*ClusterRoleSpec) DeepCopy added in v0.12.0

func (in *ClusterRoleSpec) DeepCopy() *ClusterRoleSpec

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

func (*ClusterRoleSpec) DeepCopyInto added in v0.12.0

func (in *ClusterRoleSpec) DeepCopyInto(out *ClusterRoleSpec)

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

type ClusterRoleStatus added in v0.12.0

type ClusterRoleStatus struct {
	// Conditions is an array of current observed conditions.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`

	// FailedClusters is an array of clusters which failed to apply the ClusterRole resources.
	// +deprecated, shouldn't expose the failed clusters to the user
	// +optional
	// +listType=atomic
	FailedClusters []FailedCluster `json:"failedClusters,omitempty" protobuf:"bytes,2,rep,name=failedClusters"`
}

ClusterRoleStatus defines the observed state of ClusterRole

func (*ClusterRoleStatus) DeepCopy added in v0.12.0

func (in *ClusterRoleStatus) DeepCopy() *ClusterRoleStatus

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

func (*ClusterRoleStatus) DeepCopyInto added in v0.12.0

func (in *ClusterRoleStatus) DeepCopyInto(out *ClusterRoleStatus)

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

type Condition added in v0.10.0

type Condition struct {
	Type               ConditionType          `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ConditionType"`
	Status             metav1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/apimachinery/pkg/apis/meta/v1.ConditionStatus"`
	Reason             ConditionReason        `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason,casttype=ConditionReason"`
	Message            string                 `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
	LastTransitionTime metav1.Time            `json:"lastTransitionTime,omitempty" protobuf:"bytes,5,opt,name=lastTransitionTime"`
	// +optional
	// +kubebuilder:validation:Minimum=0
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,6,opt,name=observedGeneration"`
}

func (*Condition) DeepCopy added in v0.10.0

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto added in v0.10.0

func (in *Condition) DeepCopyInto(out *Condition)

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

type ConditionGroup added in v0.12.0

type ConditionGroup struct {
	Relation        ConditionGroupRelation `json:"relation,omitempty" protobuf:"bytes,1,opt,name=relation"`
	Conditions      []RoleBindingCondition `json:"conditions" protobuf:"bytes,2,req,name=conditions"`
	ConditionGroups []ConditionGroup       `json:"conditionGroups,omitempty" protobuf:"bytes,3,opt,name=conditionGroups"`
}

ConditionGroup is a group of conditions that are used to determine if a role binding should be applied. Deprecated

func (*ConditionGroup) DeepCopy added in v0.12.0

func (in *ConditionGroup) DeepCopy() *ConditionGroup

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

func (*ConditionGroup) DeepCopyInto added in v0.12.0

func (in *ConditionGroup) DeepCopyInto(out *ConditionGroup)

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

type ConditionGroupRelation added in v0.12.0

type ConditionGroupRelation int

type ConditionReason added in v0.10.0

type ConditionReason string

type ConditionType added in v0.10.0

type ConditionType string

type Config

type Config struct {
	// WebsocketEnabled controls whether websocket is enabled.
	// +optional
	WebsocketEnabled *bool `json:"websocketEnabled,omitempty" protobuf:"varint,1,opt,name=websocketEnabled"`

	// FunctionEnabled controls whether function is enabled.
	// +optional
	FunctionEnabled *bool `json:"functionEnabled,omitempty" protobuf:"varint,2,opt,name=functionEnabled"`

	// TransactionEnabled controls whether transaction is enabled.
	// +optional
	TransactionEnabled *bool `json:"transactionEnabled,omitempty" protobuf:"varint,3,opt,name=transactionEnabled"`

	// Protocols controls the protocols enabled in brokers.
	// +optional
	Protocols *ProtocolsConfig `json:"protocols,omitempty" protobuf:"bytes,5,opt,name=protocols"`

	// AuditLog controls the custom config of audit log.
	// +optional
	AuditLog *AuditLog `json:"auditLog,omitempty" protobuf:"bytes,6,opt,name=auditLog"`

	// LakehouseStorage controls the lakehouse storage config.
	// +optional
	LakehouseStorage *LakehouseStorageConfig `json:"lakehouseStorage,omitempty" protobuf:"bytes,7,opt,name=lakehouseStorage"`

	// Custom accepts custom configurations.
	// +optional
	Custom map[string]string `json:"custom,omitempty" protobuf:"bytes,4,rep,name=custom"`
}

func (*Config) DeepCopy

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 EncryptedToken added in v0.10.0

type EncryptedToken struct {
	// JWE is the token as a JSON Web Encryption (JWE) message.
	// For RSA public keys, the key encryption algorithm is RSA-OAEP, and the content encryption algorithm is AES GCM.
	// +optional
	JWE *string `json:"jwe,omitempty" protobuf:"bytes,7,opt,name=jwe"`
}

EncryptedToken is token that is encrypted using an encryption key. +structType=atomic

func (*EncryptedToken) DeepCopy added in v0.10.0

func (in *EncryptedToken) DeepCopy() *EncryptedToken

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

func (*EncryptedToken) DeepCopyInto added in v0.10.0

func (in *EncryptedToken) DeepCopyInto(out *EncryptedToken)

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

type EncryptionKey added in v0.10.0

type EncryptionKey struct {
	// PEM is a PEM-encoded public key in PKIX, ASN.1 DER form ("spki" format).
	// +optional
	PEM string `json:"pem,omitempty" protobuf:"bytes,1,opt,name=pem"`

	// JWK is a JWK-encoded public key.
	// +optional
	JWK string `json:"jwk,omitempty" protobuf:"bytes,2,opt,name=jwk"`
}

EncryptionKey specifies a public key for encryption purposes. Either a PEM or JWK must be specified.

func (*EncryptionKey) DeepCopy added in v0.10.0

func (in *EncryptionKey) DeepCopy() *EncryptionKey

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

func (*EncryptionKey) DeepCopyInto added in v0.10.0

func (in *EncryptionKey) DeepCopyInto(out *EncryptionKey)

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

type FailedCluster added in v0.12.0

type FailedCluster struct {
	// Name is the Cluster's name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Namespace is the Cluster's namespace
	Namespace string `json:"namespace" protobuf:"bytes,2,opt,name=namespace"`

	// Reason is the failed reason
	Reason string `json:"reason" protobuf:"bytes,3,opt,name=reason"`
}

func (*FailedCluster) DeepCopy added in v0.12.0

func (in *FailedCluster) DeepCopy() *FailedCluster

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

func (*FailedCluster) DeepCopyInto added in v0.12.0

func (in *FailedCluster) DeepCopyInto(out *FailedCluster)

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

type GCPCloudConnection

type GCPCloudConnection struct {
	//nolint:stylecheck
	ProjectId string `json:"projectId" protobuf:"bytes,1,name=projectId"`
}

func (*GCPCloudConnection) DeepCopy

func (in *GCPCloudConnection) DeepCopy() *GCPCloudConnection

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

func (*GCPCloudConnection) DeepCopyInto

func (in *GCPCloudConnection) DeepCopyInto(out *GCPCloudConnection)

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

type KafkaConfig

type KafkaConfig struct {
}

func (*KafkaConfig) DeepCopy

func (in *KafkaConfig) DeepCopy() *KafkaConfig

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

func (*KafkaConfig) DeepCopyInto

func (in *KafkaConfig) DeepCopyInto(out *KafkaConfig)

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

type LakehouseStorageConfig

type LakehouseStorageConfig struct {

	// +optional
	// +kubebuilder:validation:Enum:=iceberg
	// +kubebuilder:default=iceberg
	LakehouseType *string `json:"lakehouseType,omitempty" protobuf:"bytes,1,opt,name=lakehouseType"`

	// +optional
	// +kubebuilder:validation:Enum:=rest
	// +kubebuilder:default=rest
	CatalogType *string `json:"catalogType,omitempty" protobuf:"bytes,2,opt,name=catalogType"`

	// todo: maybe we need to support mount secrets as the catalog credentials?
	// +kubebuilder:validation:Required
	CatalogCredentials string `json:"catalogCredentials" protobuf:"bytes,3,opt,name=catalogCredentials"`

	// +kubebuilder:validation:Required
	//nolint:stylecheck
	CatalogConnectionUrl string `json:"catalogConnectionUrl" protobuf:"bytes,4,opt,name=catalogConnectionUrl"`

	// +kubebuilder:validation:Required
	CatalogWarehouse string `json:"catalogWarehouse" protobuf:"bytes,5,opt,name=catalogWarehouse"`
}

func (*LakehouseStorageConfig) DeepCopy

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 ResourceName added in v0.12.0

type ResourceName struct {
	Organization   string `json:"organization,omitempty" protobuf:"bytes,1,opt,name=organization"`
	Instance       string `json:"instance,omitempty" protobuf:"bytes,2,opt,name=instance"`
	Cluster        string `json:"cluster,omitempty" protobuf:"bytes,3,opt,name=cluster"`
	Tenant         string `json:"tenant,omitempty" protobuf:"bytes,4,opt,name=tenant"`
	Namespace      string `json:"namespace,omitempty" protobuf:"bytes,5,opt,name=namespace"`
	TopicDomain    string `json:"topicDomain,omitempty" protobuf:"bytes,6,opt,name=topicDomain"`
	TopicName      string `json:"topicName,omitempty" protobuf:"bytes,7,opt,name=topicName"`
	Subscription   string `json:"subscription,omitempty" protobuf:"bytes,8,opt,name=subscription"`
	ServiceAccount string `json:"serviceAccount,omitempty" protobuf:"bytes,9,opt,name=serviceAccount"`
	APIKey         string `json:"apiKey,omitempty" protobuf:"bytes,10,opt,name=apiKey"`
	Secret         string `json:"secret,omitempty" protobuf:"bytes,11,opt,name=secret"`
}

func (*ResourceName) DeepCopy added in v0.12.0

func (in *ResourceName) DeepCopy() *ResourceName

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

func (*ResourceName) DeepCopyInto added in v0.12.0

func (in *ResourceName) DeepCopyInto(out *ResourceName)

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

type RoleBinding added in v0.12.0

type RoleBinding struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   RoleBindingSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status RoleBindingStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

RoleBinding is a resource that grants a set of permissions to a set of subjects. +k8s:openapi-gen=true +resource:path=rolebindings,strategy=RoleBindingStrategy +kubebuilder:categories=all

func (*RoleBinding) DeepCopy added in v0.12.0

func (in *RoleBinding) DeepCopy() *RoleBinding

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

func (*RoleBinding) DeepCopyInto added in v0.12.0

func (in *RoleBinding) DeepCopyInto(out *RoleBinding)

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

func (*RoleBinding) DeepCopyObject added in v0.12.0

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

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

type RoleBindingCondition added in v0.12.0

type RoleBindingCondition struct {
	Type     RoleBindingConditionType     `json:"type,omitempty" protobuf:"bytes,1,opt,name=type"`
	Operator RoleBindingConditionOperator `json:"operator,omitempty" protobuf:"bytes,2,opt,name=operator"`
	Srn      Srn                          `json:"srn,omitempty" protobuf:"bytes,3,opt,name=srn"`
}

RoleBindingCondition is a condition that is used to determine if a role binding should be applied. Deprecated

func (*RoleBindingCondition) DeepCopy added in v0.12.0

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

func (*RoleBindingCondition) DeepCopyInto added in v0.12.0

func (in *RoleBindingCondition) DeepCopyInto(out *RoleBindingCondition)

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

type RoleBindingConditionOperator added in v0.12.0

type RoleBindingConditionOperator int

type RoleBindingConditionType added in v0.12.0

type RoleBindingConditionType int

type RoleBindingList added in v0.12.0

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

RoleBindingList contains a list of RoleBinding

func (*RoleBindingList) DeepCopy added in v0.12.0

func (in *RoleBindingList) DeepCopy() *RoleBindingList

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

func (*RoleBindingList) DeepCopyInto added in v0.12.0

func (in *RoleBindingList) DeepCopyInto(out *RoleBindingList)

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

func (*RoleBindingList) DeepCopyObject added in v0.12.0

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

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

type RoleBindingSpec added in v0.12.0

type RoleBindingSpec struct {
	// +listType=atomic
	Subjects []Subject `json:"subjects" protobuf:"bytes,1,rep,name=subjects"`
	RoleRef  RoleRef   `json:"roleRef" protobuf:"bytes,2,opt,name=roleRef"`

	// +optional
	ConditionGroup *ConditionGroup `json:"conditionGroup,omitempty" protobuf:"bytes,3,opt,name=conditionGroup"`
	// +optional
	CEL *string `json:"cel,omitempty" protobuf:"bytes,4,opt,name=cel"`

	// +optional
	// +listType=atomic
	// ResourceNames indicate the StreamNative Resource Name
	ResourceNames []ResourceName `json:"resourceNames,omitempty" protobuf:"bytes,5,opt,name=resourceNames"`
}

RoleBindingSpec defines the desired state of RoleBinding

func (*RoleBindingSpec) DeepCopy added in v0.12.0

func (in *RoleBindingSpec) DeepCopy() *RoleBindingSpec

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

func (*RoleBindingSpec) DeepCopyInto added in v0.12.0

func (in *RoleBindingSpec) DeepCopyInto(out *RoleBindingSpec)

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

type RoleBindingStatus added in v0.12.0

type RoleBindingStatus struct {
	// Conditions is an array of current observed conditions.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`

	// FailedClusters is an array of clusters which failed to apply the RoleBinding resources.
	// +optional
	// +listType=atomic
	FailedClusters []FailedCluster `json:"failedClusters,omitempty" protobuf:"bytes,2,rep,name=failedClusters"`

	// SyncedClusters is a map of clusters which applied the RoleBinding resources and the RoleBinding's generation.
	// If the generation in this map is same with the current RoleBinding's generation, it will skip apply the
	// RoleBinding to the cluster
	// +optional
	// +listType=atomic
	SyncedClusters map[string]int64 `json:"syncedClusters,omitempty" protobuf:"bytes,3,rep,name=syncedClusters"`
}

RoleBindingStatus defines the observed state of RoleBinding

func (*RoleBindingStatus) DeepCopy added in v0.12.0

func (in *RoleBindingStatus) DeepCopy() *RoleBindingStatus

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

func (*RoleBindingStatus) DeepCopyInto added in v0.12.0

func (in *RoleBindingStatus) DeepCopyInto(out *RoleBindingStatus)

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

type RoleRef

type RoleRef struct {
	Kind     string `json:"kind" protobuf:"bytes,1,opt,name=kind"`
	Name     string `json:"name" protobuf:"bytes,2,opt,name=name"`
	APIGroup string `json:"apiGroup" protobuf:"bytes,3,opt,name=apiGroup"`
}

func (*RoleRef) DeepCopy

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

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

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

func (*ServiceAccountBindingList) DeepCopyInto added in v0.10.0

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

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

func (*ServiceAccountBindingSpec) DeepCopyInto added in v0.10.0

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

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

func (*ServiceAccountBindingStatus) DeepCopyInto added in v0.10.0

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

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

func (*ServiceAccountStatus) DeepCopyInto added in v0.10.0

func (in *ServiceAccountStatus) DeepCopyInto(out *ServiceAccountStatus)

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

type SharingConfig

type SharingConfig struct {
	// +listType=atomic
	Namespaces []string `json:"namespaces" protobuf:"bytes,1,rep,name=namespaces"`
}

func (*SharingConfig) DeepCopy

func (in *SharingConfig) DeepCopy() *SharingConfig

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

func (*SharingConfig) DeepCopyInto

func (in *SharingConfig) DeepCopyInto(out *SharingConfig)

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

type Srn added in v0.12.0

type Srn struct {
	Schema       string `json:"schema,omitempty" protobuf:"bytes,1,opt,name=schema"`
	Version      string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"`
	Organization string `json:"organization,omitempty" protobuf:"bytes,3,opt,name=organization"`
	Instance     string `json:"instance,omitempty" protobuf:"bytes,4,opt,name=instance"`
	Cluster      string `json:"cluster,omitempty" protobuf:"bytes,5,opt,name=cluster"`
	Tenant       string `json:"tenant,omitempty" protobuf:"bytes,6,opt,name=tenant"`
	Namespace    string `json:"namespace,omitempty" protobuf:"bytes,7,opt,name=namespace"`
	TopicDomain  string `json:"topicDomain,omitempty" protobuf:"bytes,8,opt,name=topicDomain"`
	TopicName    string `json:"topicName,omitempty" protobuf:"bytes,9,opt,name=topicName"`
	Subscription string `json:"subscription,omitempty" protobuf:"bytes,10,opt,name=subscription"`
}

Srn is a StreamNative Resource Name. Deprecated

func (*Srn) DeepCopy added in v0.12.0

func (in *Srn) DeepCopy() *Srn

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

func (*Srn) DeepCopyInto added in v0.12.0

func (in *Srn) DeepCopyInto(out *Srn)

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