v1beta1

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: "v1beta1"}

	// 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")

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

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.