v1alpha1

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package v1alpha1 contains the v1alpha1 group eventstreamsadminv1 resources of the IBM Cloud provider. +kubebuilder:object:generate=true +groupName=eventstreamsadminv1.ibmcloud.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	Group   = "eventstreamsadminv1.ibmcloud.crossplane.io"
	Version = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var (
	TopicKind             = reflect.TypeOf(Topic{}).Name()
	TopicGroupKind        = schema.GroupKind{Group: Group, Kind: TopicKind}.String()
	TopicKindAPIVersion   = TopicKind + "." + SchemeGroupVersion.String()
	TopicGroupVersionKind = SchemeGroupVersion.WithKind(TopicKind)
)

resourcecontrollerv2 types metadata.

Functions

func ConnSecretRef 

func ConnSecretRef() reference.ExtractValueFn

ConnSecretRef extracts the connection secret namespace and name

Types

type ConfigCreate 

type ConfigCreate struct {

	// The name of the config property.
	Name string `json:"name,omitempty"`

	// The value for a config property.
	Value string `json:"value,omitempty"`
}

ConfigCreate : ConfigCreate struct

func (*ConfigCreate) DeepCopy 

func (in *ConfigCreate) DeepCopy() *ConfigCreate

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

func (*ConfigCreate) DeepCopyInto 

func (in *ConfigCreate) DeepCopyInto(out *ConfigCreate)

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

type ReplicaAssignment 

type ReplicaAssignment struct {
	// The ID of the partition.
	ID int64 `json:"id,omitempty"`

	Brokers *ReplicaAssignmentBrokers `json:"brokers,omitempty"`
}

ReplicaAssignment : ReplicaAssignment struct

func (*ReplicaAssignment) DeepCopy 

func (in *ReplicaAssignment) DeepCopy() *ReplicaAssignment

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

func (*ReplicaAssignment) DeepCopyInto 

func (in *ReplicaAssignment) DeepCopyInto(out *ReplicaAssignment)

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

type ReplicaAssignmentBrokers 

type ReplicaAssignmentBrokers struct {
	Replicas []int64 `json:"replicas,omitempty"`
}

ReplicaAssignmentBrokers : ReplicaAssignmentBrokers struct

func (*ReplicaAssignmentBrokers) DeepCopy 

func (in *ReplicaAssignmentBrokers) DeepCopy() *ReplicaAssignmentBrokers

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

func (*ReplicaAssignmentBrokers) DeepCopyInto 

func (in *ReplicaAssignmentBrokers) DeepCopyInto(out *ReplicaAssignmentBrokers)

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

type Topic 

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

	Spec   TopicSpec   `json:"spec"`
	Status TopicStatus `json:"status,omitempty"`
}

A Topic represents an instance of a managed service on IBM Cloud +kubebuilder:subresource:status +kubebuilder:printcolumn:name="STATUS",type="string",JSONPath=".status.bindingPhase" +kubebuilder:printcolumn:name="STATE",type="string",JSONPath=".status.atProvider.state" +kubebuilder:printcolumn:name="CLASS",type="string",JSONPath=".spec.classRef.name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,ibmcloud}

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

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

func (*Topic) DeepCopyInto 

func (in *Topic) DeepCopyInto(out *Topic)

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

func (*Topic) DeepCopyObject 

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

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

func (*Topic) GetCondition 

func (mg *Topic) GetCondition(ct runtimev1alpha1.ConditionType) runtimev1alpha1.Condition

GetCondition of this Topic.

func (*Topic) GetDeletionPolicy 

func (mg *Topic) GetDeletionPolicy() runtimev1alpha1.DeletionPolicy

GetDeletionPolicy of this Topic.

func (*Topic) GetProviderConfigReference 

func (mg *Topic) GetProviderConfigReference() *runtimev1alpha1.Reference

GetProviderConfigReference of this Topic.

func (*Topic) GetProviderReference 

func (mg *Topic) GetProviderReference() *runtimev1alpha1.Reference

GetProviderReference of this Topic. Deprecated: Use GetProviderConfigReference.

func (*Topic) GetWriteConnectionSecretToReference 

func (mg *Topic) GetWriteConnectionSecretToReference() *runtimev1alpha1.SecretReference

GetWriteConnectionSecretToReference of this Topic.

func (*Topic) ResolveReferences 

func (mg *Topic) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this ResourceKey Crossplane resolvers are not designed to resolve fields from non-Crossplane resources. There is a design doc in progress to support this type of scenario at https://github.com/crossplane/crossplane/pull/2385 At this time the only solution is a two steps approach: 1. use the resolver on a resource key to obtain the namespage and name of the secret from writeConnectionSecretToRef 2. use that namespace and name with the client.Reader to get the secret and extract the kafka_admin_url from there

func (*Topic) SetConditions 

func (mg *Topic) SetConditions(c ...runtimev1alpha1.Condition)

SetConditions of this Topic.

func (*Topic) SetDeletionPolicy 

func (mg *Topic) SetDeletionPolicy(r runtimev1alpha1.DeletionPolicy)

SetDeletionPolicy of this Topic.

func (*Topic) SetProviderConfigReference 

func (mg *Topic) SetProviderConfigReference(r *runtimev1alpha1.Reference)

SetProviderConfigReference of this Topic.

func (*Topic) SetProviderReference 

func (mg *Topic) SetProviderReference(r *runtimev1alpha1.Reference)

SetProviderReference of this Topic. Deprecated: Use SetProviderConfigReference.

func (*Topic) SetWriteConnectionSecretToReference 

func (mg *Topic) SetWriteConnectionSecretToReference(r *runtimev1alpha1.SecretReference)

SetWriteConnectionSecretToReference of this Topic.

type TopicConfigs 

type TopicConfigs struct {
	// The value of config property 'cleanup.policy'.
	CleanupPolicy string `json:"cleanupPolicy,omitempty"`

	// The value of config property 'min.insync.replicas'.
	MinInsyncReplicas string `json:"minInsyncReplicas,omitempty"`

	// The value of config property 'retention.bytes'.
	RetentionBytes string `json:"retentionBytes,omitempty"`

	// The value of config property 'retention.ms'.
	RetentionMs string `json:"retentionMs,omitempty"`

	// The value of config property 'segment.bytes'.
	SegmentBytes string `json:"segmentBytes,omitempty"`

	// The value of config property 'segment.index.bytes'.
	SegmentIndexBytes string `json:"segmentIndexBytes,omitempty"`

	// The value of config property 'segment.ms'.
	SegmentMs string `json:"segmentMs,omitempty"`
}

TopicConfigs : TopicConfigs struct

func (*TopicConfigs) DeepCopy 

func (in *TopicConfigs) DeepCopy() *TopicConfigs

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

func (*TopicConfigs) DeepCopyInto 

func (in *TopicConfigs) DeepCopyInto(out *TopicConfigs)

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

type TopicList 

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

TopicList contains a list of Topic

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

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

func (*TopicList) DeepCopyInto 

func (in *TopicList) DeepCopyInto(out *TopicList)

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

func (*TopicList) DeepCopyObject 

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

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

func (*TopicList) GetItems 

func (l *TopicList) GetItems() []resource.Managed

GetItems of this TopicList.

type TopicObservation 

type TopicObservation struct {

	// The number of replication factor.
	ReplicationFactor int64 `json:"replicationFactor,omitempty"`

	// The value of config property 'retention.ms'.
	RetentionMs int64 `json:"retentionMs,omitempty"`

	// The value of config property 'cleanup.policy'.
	CleanupPolicy string `json:"cleanupPolicy,omitempty"`

	// The config properties of the topic.
	Configs *TopicConfigs `json:"configs,omitempty"`

	// The replica assignment of the topic.
	ReplicaAssignments []ReplicaAssignment `json:"replicaAssignments,omitempty"`

	// The current state of the topic. For example, if the topic is deleted, it will return removed.
	State string `json:"state,omitempty"`
}

TopicObservation are the observable fields of a Topic.

func (*TopicObservation) DeepCopy 

func (in *TopicObservation) DeepCopy() *TopicObservation

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

func (*TopicObservation) DeepCopyInto 

func (in *TopicObservation) DeepCopyInto(out *TopicObservation)

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

type TopicParameters 

type TopicParameters struct {

	// The name of topic to be created.
	// +immutable
	Name string `json:"name"`

	// KafkaAdminURL is the URL to the Event Streams instance admin endpoint
	// +immutable
	// +optional
	KafkaAdminURL *string `json:"kafkaAdminUrl,omitempty"`

	// A reference to the Event Streams Secret Key used to set KafkaAdminURL
	// +immutable
	// +optional
	KafkaAdminURLRef *runtimev1alpha1.Reference `json:"kafkaAdminUrlRef,omitempty"`

	// SourceSelector selects a reference to a resource used to set Source
	// +immutable
	// +optional
	KafkaAdminURLSelector *runtimev1alpha1.Selector `json:"kafkaAdminUrlSelector,omitempty"`

	// The number of partitions.
	// +optional
	Partitions *int64 `json:"partitions,omitempty"`

	// The number of partitions, this field takes precedence over 'partitions'. Default value is 1 if not specified.
	// +optional
	PartitionCount *int64 `json:"partitionCount,omitempty"`

	// The config properties to be set for the new topic.
	// +immutable
	// +optional
	Configs []ConfigCreate `json:"configs,omitempty"`
}

TopicParameters are the configurable fields of a Topic.

func (*TopicParameters) DeepCopy 

func (in *TopicParameters) DeepCopy() *TopicParameters

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

func (*TopicParameters) DeepCopyInto 

func (in *TopicParameters) DeepCopyInto(out *TopicParameters)

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

type TopicSpec 

type TopicSpec struct {
	runtimev1alpha1.ResourceSpec `json:",inline"`
	ForProvider                  TopicParameters `json:"forProvider"`
}

A TopicSpec defines the desired state of a Topic.

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

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

func (*TopicSpec) DeepCopyInto 

func (in *TopicSpec) DeepCopyInto(out *TopicSpec)

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

type TopicStatus 

type TopicStatus struct {
	runtimev1alpha1.ResourceStatus `json:",inline"`
	AtProvider                     TopicObservation `json:"atProvider,omitempty"`
}

A TopicStatus represents the observed state of a Topic.

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

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

func (*TopicStatus) DeepCopyInto 

func (in *TopicStatus) DeepCopyInto(out *TopicStatus)

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.