v1alpha1

package
v1.129.2 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

+kcc:proto=google.cloud.managedkafka.v1

+kubebuilder:object:generate=true +groupName=managedkafka.cnrm.cloud.google.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "managedkafka.cnrm.cloud.google.com", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var ManagedKafkaClusterGVK = GroupVersion.WithKind("ManagedKafkaCluster")
View Source 
var ManagedKafkaTopicGVK = GroupVersion.WithKind("ManagedKafkaTopic")

Functions

This section is empty.

Types

type AccessConfig 

type AccessConfig struct {
	// Required. Virtual Private Cloud (VPC) networks that must be granted direct
	//  access to the Kafka cluster. Minimum of 1 network is required. Maximum 10
	//  networks can be specified.
	// +kcc:proto:field=google.cloud.managedkafka.v1.AccessConfig.network_configs
	// +required
	NetworkConfigs []NetworkConfig `json:"networkConfigs,omitempty"`
}

+kcc:proto=google.cloud.managedkafka.v1.AccessConfig

func (*AccessConfig) DeepCopy 

func (in *AccessConfig) DeepCopy() *AccessConfig

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

func (*AccessConfig) DeepCopyInto 

func (in *AccessConfig) DeepCopyInto(out *AccessConfig)

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

type CapacityConfig 

type CapacityConfig struct {
	// Required. The number of vCPUs to provision for the cluster. Minimum: 3.
	// +kcc:proto:field=google.cloud.managedkafka.v1.CapacityConfig.vcpu_count
	// +required
	VcpuCount *int64 `json:"vcpuCount,omitempty"`

	// Required. The memory to provision for the cluster in bytes.
	//  The CPU:memory ratio (vCPU:GiB) must be between 1:1 and 1:8.
	//  Minimum: 3221225472 (3 GiB).
	// +kcc:proto:field=google.cloud.managedkafka.v1.CapacityConfig.memory_bytes
	// +required
	MemoryBytes *int64 `json:"memoryBytes,omitempty"`
}

+kcc:proto=google.cloud.managedkafka.v1.CapacityConfig

func (*CapacityConfig) DeepCopy 

func (in *CapacityConfig) DeepCopy() *CapacityConfig

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

func (*CapacityConfig) DeepCopyInto 

func (in *CapacityConfig) DeepCopyInto(out *CapacityConfig)

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

type ClusterIdentity 

type ClusterIdentity struct {
	// contains filtered or unexported fields
}

ClusterIdentity defines the resource reference to ManagedKafkaCluster, which "External" field holds the GCP identifier for the KRM object.

func NewClusterIdentity 

func NewClusterIdentity(ctx context.Context, reader client.Reader, obj *ManagedKafkaCluster) (*ClusterIdentity, error)

New builds a ClusterIdentity from the Config Connector Cluster object.

func (*ClusterIdentity) DeepCopy 

func (in *ClusterIdentity) DeepCopy() *ClusterIdentity

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

func (*ClusterIdentity) DeepCopyInto 

func (in *ClusterIdentity) DeepCopyInto(out *ClusterIdentity)

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

func (*ClusterIdentity) ID 

func (i *ClusterIdentity) ID() string

func (*ClusterIdentity) Parent 

func (i *ClusterIdentity) Parent() *ClusterParent

func (*ClusterIdentity) String 

func (i *ClusterIdentity) String() string

type ClusterParent 

type ClusterParent struct {
	ProjectID string
	Location  string
}

func ParseClusterExternal 

func ParseClusterExternal(external string) (parent *ClusterParent, resourceID string, err error)

func (*ClusterParent) DeepCopy 

func (in *ClusterParent) DeepCopy() *ClusterParent

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

func (*ClusterParent) DeepCopyInto 

func (in *ClusterParent) DeepCopyInto(out *ClusterParent)

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

func (*ClusterParent) String 

func (p *ClusterParent) String() string

type ClusterRef 

type ClusterRef struct {
	// A reference to an externally managed ManagedKafkaCluster resource.
	// Should be in the format "projects/{{projectID}}/locations/{{location}}/clusters/{{clusterID}}".
	External string `json:"external,omitempty"`

	// The name of a ManagedKafkaCluster resource.
	Name string `json:"name,omitempty"`

	// The namespace of a ManagedKafkaCluster resource.
	Namespace string `json:"namespace,omitempty"`
}

ClusterRef defines the resource reference to ManagedKafkaCluster, which "External" field holds the GCP identifier for the KRM object.

func (*ClusterRef) DeepCopy 

func (in *ClusterRef) DeepCopy() *ClusterRef

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

func (*ClusterRef) DeepCopyInto 

func (in *ClusterRef) DeepCopyInto(out *ClusterRef)

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

func (*ClusterRef) NormalizedExternal 

func (r *ClusterRef) NormalizedExternal(ctx context.Context, reader client.Reader, otherNamespace string) (string, error)

NormalizedExternal provision the "External" value for other resource that depends on ManagedKafkaCluster. If the "External" is given in the other resource's spec.ManagedKafkaClusterRef, the given value will be used. Otherwise, the "Name" and "Namespace" will be used to query the actual ManagedKafkaCluster object from the cluster.

type GcpConfig 

type GcpConfig struct {
	// Required. Access configuration for the Kafka cluster.
	// +kcc:proto:field=google.cloud.managedkafka.v1.GcpConfig.access_config
	// +required
	AccessConfig *AccessConfig `json:"accessConfig,omitempty"`

	// Optional. Immutable. The Cloud KMS Key name to use for encryption. The key
	//  must be located in the same region as the cluster and cannot be changed.
	// +kcc:proto:field=google.cloud.managedkafka.v1.GcpConfig.kms_key
	KmsKeyRef *refs.KMSCryptoKeyRef `json:"kmsKeyRef,omitempty"`
}

+kcc:proto=google.cloud.managedkafka.v1.GcpConfig

func (*GcpConfig) DeepCopy 

func (in *GcpConfig) DeepCopy() *GcpConfig

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

func (*GcpConfig) DeepCopyInto 

func (in *GcpConfig) DeepCopyInto(out *GcpConfig)

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

type ManagedKafkaCluster 

type ManagedKafkaCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// +required
	Spec   ManagedKafkaClusterSpec   `json:"spec,omitempty"`
	Status ManagedKafkaClusterStatus `json:"status,omitempty"`
}

ManagedKafkaCluster is the Schema for the ManagedKafkaCluster API +k8s:openapi-gen=true

func (*ManagedKafkaCluster) DeepCopy 

func (in *ManagedKafkaCluster) DeepCopy() *ManagedKafkaCluster

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

func (*ManagedKafkaCluster) DeepCopyInto 

func (in *ManagedKafkaCluster) DeepCopyInto(out *ManagedKafkaCluster)

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

func (*ManagedKafkaCluster) DeepCopyObject 

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

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

type ManagedKafkaClusterList 

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

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object ManagedKafkaClusterList contains a list of ManagedKafkaCluster

func (*ManagedKafkaClusterList) DeepCopy 

func (in *ManagedKafkaClusterList) DeepCopy() *ManagedKafkaClusterList

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

func (*ManagedKafkaClusterList) DeepCopyInto 

func (in *ManagedKafkaClusterList) DeepCopyInto(out *ManagedKafkaClusterList)

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

func (*ManagedKafkaClusterList) DeepCopyObject 

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

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

type ManagedKafkaClusterObservedState 

type ManagedKafkaClusterObservedState struct {
	// Output only. The time when the cluster was created.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.create_time
	CreateTime *string `json:"createTime,omitempty"`

	// Output only. The time when the cluster was last updated.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.update_time
	UpdateTime *string `json:"updateTime,omitempty"`

	// Output only. The current state of the cluster.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.state
	State *string `json:"state,omitempty"`
}

ManagedKafkaClusterObservedState is the state of the ManagedKafkaCluster resource as most recently observed in GCP. +kcc:proto=google.cloud.managedkafka.v1.Cluster

func (*ManagedKafkaClusterObservedState) DeepCopy 

func (in *ManagedKafkaClusterObservedState) DeepCopy() *ManagedKafkaClusterObservedState

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

func (*ManagedKafkaClusterObservedState) DeepCopyInto 

func (in *ManagedKafkaClusterObservedState) DeepCopyInto(out *ManagedKafkaClusterObservedState)

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

type ManagedKafkaClusterSpec 

type ManagedKafkaClusterSpec struct {
	commonv1alpha1.CommonSpec `json:",inline"`

	// +required
	Location string `json:"location"`

	// The ManagedKafkaCluster name. If not given, the metadata.name will be used.
	ResourceID *string `json:"resourceID,omitempty"`

	// Required. Configuration properties for a Kafka cluster deployed to Google
	//  Cloud Platform.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.gcp_config
	// +required
	GcpConfig *GcpConfig `json:"gcpConfig,omitempty"`

	// Optional. Labels as key value pairs.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.labels
	Labels map[string]string `json:"labels,omitempty"`

	// Required. Capacity configuration for the Kafka cluster.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.capacity_config
	// +required
	CapacityConfig *CapacityConfig `json:"capacityConfig,omitempty"`

	// Optional. Rebalance configuration for the Kafka cluster.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Cluster.rebalance_config
	RebalanceConfig *RebalanceConfig `json:"rebalanceConfig,omitempty"`
}

ManagedKafkaClusterSpec defines the desired state of ManagedKafkaCluster +kcc:proto=google.cloud.managedkafka.v1.Cluster

func (*ManagedKafkaClusterSpec) DeepCopy 

func (in *ManagedKafkaClusterSpec) DeepCopy() *ManagedKafkaClusterSpec

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

func (*ManagedKafkaClusterSpec) DeepCopyInto 

func (in *ManagedKafkaClusterSpec) DeepCopyInto(out *ManagedKafkaClusterSpec)

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

type ManagedKafkaClusterStatus 

type ManagedKafkaClusterStatus struct {
	/* Conditions represent the latest available observations of the
	   object's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource.
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`

	// A unique specifier for the ManagedKafkaCluster resource in GCP.
	ExternalRef *string `json:"externalRef,omitempty"`

	// ObservedState is the state of the resource as most recently observed in GCP.
	ObservedState *ManagedKafkaClusterObservedState `json:"observedState,omitempty"`
}

ManagedKafkaClusterStatus defines the config connector machine state of ManagedKafkaCluster

func (*ManagedKafkaClusterStatus) DeepCopy 

func (in *ManagedKafkaClusterStatus) DeepCopy() *ManagedKafkaClusterStatus

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

func (*ManagedKafkaClusterStatus) DeepCopyInto 

func (in *ManagedKafkaClusterStatus) DeepCopyInto(out *ManagedKafkaClusterStatus)

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

type ManagedKafkaTopic added in v1.129.2 

type ManagedKafkaTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// +required
	Spec   ManagedKafkaTopicSpec   `json:"spec,omitempty"`
	Status ManagedKafkaTopicStatus `json:"status,omitempty"`
}

ManagedKafkaTopic is the Schema for the ManagedKafkaTopic API +k8s:openapi-gen=true

func (*ManagedKafkaTopic) DeepCopy added in v1.129.2 

func (in *ManagedKafkaTopic) DeepCopy() *ManagedKafkaTopic

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

func (*ManagedKafkaTopic) DeepCopyInto added in v1.129.2 

func (in *ManagedKafkaTopic) DeepCopyInto(out *ManagedKafkaTopic)

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

func (*ManagedKafkaTopic) DeepCopyObject added in v1.129.2 

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

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

type ManagedKafkaTopicList added in v1.129.2 

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

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object ManagedKafkaTopicList contains a list of ManagedKafkaTopic

func (*ManagedKafkaTopicList) DeepCopy added in v1.129.2 

func (in *ManagedKafkaTopicList) DeepCopy() *ManagedKafkaTopicList

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

func (*ManagedKafkaTopicList) DeepCopyInto added in v1.129.2 

func (in *ManagedKafkaTopicList) DeepCopyInto(out *ManagedKafkaTopicList)

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

func (*ManagedKafkaTopicList) DeepCopyObject added in v1.129.2 

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

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

type ManagedKafkaTopicSpec added in v1.129.2 

type ManagedKafkaTopicSpec struct {
	commonv1alpha1.CommonSpec `json:",inline"`

	// Required. the location of the Kafka resource.
	// See https://cloud.google.com/managed-kafka/docs/locations for a list of supported locations.
	// +required
	Location string `json:"location"`

	// Required. Reference to the Kafka cluster to create the topic in.
	// +required
	ClusterRef *ClusterRef `json:"clusterRef"`

	// The ManagedKafkaTopic name. If not given, the metadata.name will be used.
	ResourceID *string `json:"resourceID,omitempty"`

	// Required. The number of partitions this topic has. The partition count can
	//  only be increased, not decreased. Please note that if partitions are
	//  increased for a topic that has a key, the partitioning logic or the
	//  ordering of the messages will be affected.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Topic.partition_count
	PartitionCount *int32 `json:"partitionCount,omitempty"`

	// Required. Immutable. The number of replicas of each partition. A
	//  replication factor of 3 is recommended for high availability.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Topic.replication_factor
	ReplicationFactor *int32 `json:"replicationFactor,omitempty"`

	// Optional. Configurations for the topic that are overridden from the cluster
	//  defaults. The key of the map is a Kafka topic property name, for example:
	//  `cleanup.policy`, `compression.type`.
	// +kcc:proto:field=google.cloud.managedkafka.v1.Topic.configs
	Configs map[string]string `json:"configs,omitempty"`
}

ManagedKafkaTopicSpec defines the desired state of ManagedKafkaTopic +kcc:proto=google.cloud.managedkafka.v1.Topic

func (*ManagedKafkaTopicSpec) DeepCopy added in v1.129.2 

func (in *ManagedKafkaTopicSpec) DeepCopy() *ManagedKafkaTopicSpec

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

func (*ManagedKafkaTopicSpec) DeepCopyInto added in v1.129.2 

func (in *ManagedKafkaTopicSpec) DeepCopyInto(out *ManagedKafkaTopicSpec)

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

type ManagedKafkaTopicStatus added in v1.129.2 

type ManagedKafkaTopicStatus struct {
	/* Conditions represent the latest available observations of the
	   object's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource.
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`

	// A unique specifier for the ManagedKafkaTopic resource in GCP.
	ExternalRef *string `json:"externalRef,omitempty"`
}

ManagedKafkaTopicStatus defines the config connector machine state of ManagedKafkaTopic

func (*ManagedKafkaTopicStatus) DeepCopy added in v1.129.2 

func (in *ManagedKafkaTopicStatus) DeepCopy() *ManagedKafkaTopicStatus

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

func (*ManagedKafkaTopicStatus) DeepCopyInto added in v1.129.2 

func (in *ManagedKafkaTopicStatus) DeepCopyInto(out *ManagedKafkaTopicStatus)

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

type NetworkConfig 

type NetworkConfig struct {
	// Required. Reference to the VPC subnet in which to create Private Service Connect
	//  (PSC) endpoints for the Kafka brokers and bootstrap address.
	//
	//  The subnet must be located in the same region as the Kafka cluster. The
	//  project may differ. Multiple subnets from the same parent network must not
	//  be specified.
	//
	//  The CIDR range of the subnet must be within the IPv4 address ranges for
	//  private networks, as specified in RFC 1918.
	// +kcc:proto:field=google.cloud.managedkafka.v1.NetworkConfig.subnet
	// +required
	SubnetworkRef *refs.ComputeSubnetworkRef `json:"subnetworkRef"`
}

+kcc:proto=google.cloud.managedkafka.v1.NetworkConfig

func (*NetworkConfig) DeepCopy 

func (in *NetworkConfig) DeepCopy() *NetworkConfig

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

func (*NetworkConfig) DeepCopyInto 

func (in *NetworkConfig) DeepCopyInto(out *NetworkConfig)

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

type RebalanceConfig 

type RebalanceConfig struct {
	// Optional. The rebalance behavior for the cluster.
	//  When not specified, defaults to `NO_REBALANCE`.
	// +kcc:proto:field=google.cloud.managedkafka.v1.RebalanceConfig.mode
	Mode *string `json:"mode,omitempty"`
}

+kcc:proto=google.cloud.managedkafka.v1.RebalanceConfig

func (*RebalanceConfig) DeepCopy 

func (in *RebalanceConfig) DeepCopy() *RebalanceConfig

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

func (*RebalanceConfig) DeepCopyInto 

func (in *RebalanceConfig) DeepCopyInto(out *RebalanceConfig)

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

type TopicIdentity added in v1.129.2 

type TopicIdentity struct {
	// contains filtered or unexported fields
}

TopicIdentity defines the resource reference to ManagedKafkaTopic, which "External" field holds the GCP identifier for the KRM object.

func NewTopicIdentity added in v1.129.2 

func NewTopicIdentity(ctx context.Context, reader client.Reader, obj *ManagedKafkaTopic) (*TopicIdentity, error)

New builds a TopicIdentity from the Config Connector Topic object.

func (*TopicIdentity) DeepCopy added in v1.129.2 

func (in *TopicIdentity) DeepCopy() *TopicIdentity

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

func (*TopicIdentity) DeepCopyInto added in v1.129.2 

func (in *TopicIdentity) DeepCopyInto(out *TopicIdentity)

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

func (*TopicIdentity) ID added in v1.129.2 

func (i *TopicIdentity) ID() string

func (*TopicIdentity) Parent added in v1.129.2 

func (i *TopicIdentity) Parent() *TopicParent

func (*TopicIdentity) String added in v1.129.2 

func (i *TopicIdentity) String() string

type TopicParent added in v1.129.2 

type TopicParent struct {
	ProjectID string
	Location  string
	Cluster   string
}

func ParseTopicExternal added in v1.129.2 

func ParseTopicExternal(external string) (parent *TopicParent, resourceID string, err error)

func (*TopicParent) DeepCopy added in v1.129.2 

func (in *TopicParent) DeepCopy() *TopicParent

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

func (*TopicParent) DeepCopyInto added in v1.129.2 

func (in *TopicParent) DeepCopyInto(out *TopicParent)

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

func (*TopicParent) String added in v1.129.2 

func (p *TopicParent) String() string

type TopicRef added in v1.129.2 

type TopicRef struct {
	// A reference to an externally managed ManagedKafkaTopic resource.
	// Should be in the format "projects/{{projectID}}/locations/{{location}}/clusters/{{clusterID}}/topics/{{topicID}}".
	External string `json:"external,omitempty"`

	// The name of a ManagedKafkaTopic resource.
	Name string `json:"name,omitempty"`

	// The namespace of a ManagedKafkaTopic resource.
	Namespace string `json:"namespace,omitempty"`
}

TopicRef defines the resource reference to ManagedKafkaTopic, which "External" field holds the GCP identifier for the KRM object.

func (*TopicRef) DeepCopy added in v1.129.2 

func (in *TopicRef) DeepCopy() *TopicRef

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

func (*TopicRef) DeepCopyInto added in v1.129.2 

func (in *TopicRef) DeepCopyInto(out *TopicRef)

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

func (*TopicRef) NormalizedExternal added in v1.129.2 

func (r *TopicRef) NormalizedExternal(ctx context.Context, reader client.Reader, otherNamespace string) (string, error)

NormalizedExternal provision the "External" value for other resource that depends on ManagedKafkaTopic. If the "External" is given in the other resource's spec.ManagedKafkaTopicRef, the given value will be used. Otherwise, the "Name" and "Namespace" will be used to query the actual ManagedKafkaTopic object from the cluster.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.