v1alpha1

package
v0.5.0 Latest Latest
Warning

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

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

Documentation

Overview

+groupName=streaming.oci.kubeform.com

Index

Constants

This section is empty.

Variables

View Source
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: streaming.GroupName, Version: "v1alpha1"}

Functions

func GetDecoder

func GetDecoder() map[string]jsoniter.ValDecoder

func GetEncoder

func GetEncoder() map[string]jsoniter.ValEncoder

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type ConnectHarness

type ConnectHarness struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConnectHarnessSpec   `json:"spec,omitempty"`
	Status            ConnectHarnessStatus `json:"status,omitempty"`
}

func (*ConnectHarness) DeepCopy

func (in *ConnectHarness) DeepCopy() *ConnectHarness

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

func (*ConnectHarness) DeepCopyInto

func (in *ConnectHarness) DeepCopyInto(out *ConnectHarness)

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

func (*ConnectHarness) DeepCopyObject

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

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

func (*ConnectHarness) SetupWebhookWithManager

func (r *ConnectHarness) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ConnectHarness) ValidateCreate

func (r *ConnectHarness) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ConnectHarness) ValidateDelete

func (r *ConnectHarness) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ConnectHarness) ValidateUpdate

func (r *ConnectHarness) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ConnectHarnessList

type ConnectHarnessList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ConnectHarness CRD objects
	Items []ConnectHarness `json:"items,omitempty"`
}

ConnectHarnessList is a list of ConnectHarnesss

func (*ConnectHarnessList) DeepCopy

func (in *ConnectHarnessList) DeepCopy() *ConnectHarnessList

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

func (*ConnectHarnessList) DeepCopyInto

func (in *ConnectHarnessList) DeepCopyInto(out *ConnectHarnessList)

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

func (*ConnectHarnessList) DeepCopyObject

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

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

type ConnectHarnessSpec

type ConnectHarnessSpec struct {
	State *ConnectHarnessSpecResource `json:"state,omitempty" tf:"-"`

	Resource ConnectHarnessSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ConnectHarnessSpec) DeepCopy

func (in *ConnectHarnessSpec) DeepCopy() *ConnectHarnessSpec

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

func (*ConnectHarnessSpec) DeepCopyInto

func (in *ConnectHarnessSpec) DeepCopyInto(out *ConnectHarnessSpec)

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

type ConnectHarnessSpecResource

type ConnectHarnessSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	CompartmentID *string `json:"compartmentID" tf:"compartment_id"`
	// +optional
	DefinedTags map[string]string `json:"definedTags,omitempty" tf:"defined_tags"`
	// +optional
	FreeformTags map[string]string `json:"freeformTags,omitempty" tf:"freeform_tags"`
	// +optional
	LifecycleStateDetails *string `json:"lifecycleStateDetails,omitempty" tf:"lifecycle_state_details"`
	Name                  *string `json:"name" tf:"name"`
	// +optional
	State *string `json:"state,omitempty" tf:"state"`
	// +optional
	TimeCreated *string `json:"timeCreated,omitempty" tf:"time_created"`
}

func (*ConnectHarnessSpecResource) DeepCopy

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

func (*ConnectHarnessSpecResource) DeepCopyInto

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

type ConnectHarnessStatus

type ConnectHarnessStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ConnectHarnessStatus) DeepCopy

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

func (*ConnectHarnessStatus) DeepCopyInto

func (in *ConnectHarnessStatus) DeepCopyInto(out *ConnectHarnessStatus)

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

type Stream

type Stream struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              StreamSpec   `json:"spec,omitempty"`
	Status            StreamStatus `json:"status,omitempty"`
}

func (*Stream) DeepCopy

func (in *Stream) DeepCopy() *Stream

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

func (*Stream) DeepCopyInto

func (in *Stream) DeepCopyInto(out *Stream)

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

func (*Stream) DeepCopyObject

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

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

func (*Stream) SetupWebhookWithManager

func (r *Stream) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Stream) ValidateCreate

func (r *Stream) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Stream) ValidateDelete

func (r *Stream) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Stream) ValidateUpdate

func (r *Stream) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type StreamList

type StreamList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Stream CRD objects
	Items []Stream `json:"items,omitempty"`
}

StreamList is a list of Streams

func (*StreamList) DeepCopy

func (in *StreamList) DeepCopy() *StreamList

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

func (*StreamList) DeepCopyInto

func (in *StreamList) DeepCopyInto(out *StreamList)

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

func (*StreamList) DeepCopyObject

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

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

type StreamPool

type StreamPool struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              StreamPoolSpec   `json:"spec,omitempty"`
	Status            StreamPoolStatus `json:"status,omitempty"`
}

func (*StreamPool) DeepCopy

func (in *StreamPool) DeepCopy() *StreamPool

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

func (*StreamPool) DeepCopyInto

func (in *StreamPool) DeepCopyInto(out *StreamPool)

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

func (*StreamPool) DeepCopyObject

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

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

func (*StreamPool) SetupWebhookWithManager

func (r *StreamPool) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*StreamPool) ValidateCreate

func (r *StreamPool) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*StreamPool) ValidateDelete

func (r *StreamPool) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*StreamPool) ValidateUpdate

func (r *StreamPool) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type StreamPoolList

type StreamPoolList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of StreamPool CRD objects
	Items []StreamPool `json:"items,omitempty"`
}

StreamPoolList is a list of StreamPools

func (*StreamPoolList) DeepCopy

func (in *StreamPoolList) DeepCopy() *StreamPoolList

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

func (*StreamPoolList) DeepCopyInto

func (in *StreamPoolList) DeepCopyInto(out *StreamPoolList)

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

func (*StreamPoolList) DeepCopyObject

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

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

type StreamPoolSpec

type StreamPoolSpec struct {
	State *StreamPoolSpecResource `json:"state,omitempty" tf:"-"`

	Resource StreamPoolSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*StreamPoolSpec) DeepCopy

func (in *StreamPoolSpec) DeepCopy() *StreamPoolSpec

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

func (*StreamPoolSpec) DeepCopyInto

func (in *StreamPoolSpec) DeepCopyInto(out *StreamPoolSpec)

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

type StreamPoolSpecCustomEncryptionKey

type StreamPoolSpecCustomEncryptionKey struct {
	// +optional
	KeyState *string `json:"keyState,omitempty" tf:"key_state"`
	KmsKeyID *string `json:"kmsKeyID" tf:"kms_key_id"`
}

func (*StreamPoolSpecCustomEncryptionKey) DeepCopy

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

func (*StreamPoolSpecCustomEncryptionKey) DeepCopyInto

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

type StreamPoolSpecCustomEncryptionKeyCodec

type StreamPoolSpecCustomEncryptionKeyCodec struct {
}

+k8s:deepcopy-gen=false

func (StreamPoolSpecCustomEncryptionKeyCodec) Decode

func (StreamPoolSpecCustomEncryptionKeyCodec) Encode

func (StreamPoolSpecCustomEncryptionKeyCodec) IsEmpty

type StreamPoolSpecKafkaSettings

type StreamPoolSpecKafkaSettings struct {
	// +optional
	AutoCreateTopicsEnable *bool `json:"autoCreateTopicsEnable,omitempty" tf:"auto_create_topics_enable"`
	// +optional
	BootstrapServers *string `json:"bootstrapServers,omitempty" tf:"bootstrap_servers"`
	// +optional
	LogRetentionHours *int64 `json:"logRetentionHours,omitempty" tf:"log_retention_hours"`
	// +optional
	NumPartitions *int64 `json:"numPartitions,omitempty" tf:"num_partitions"`
}

func (*StreamPoolSpecKafkaSettings) DeepCopy

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

func (*StreamPoolSpecKafkaSettings) DeepCopyInto

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

type StreamPoolSpecKafkaSettingsCodec

type StreamPoolSpecKafkaSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (StreamPoolSpecKafkaSettingsCodec) Decode

func (StreamPoolSpecKafkaSettingsCodec) Encode

func (StreamPoolSpecKafkaSettingsCodec) IsEmpty

type StreamPoolSpecPrivateEndpointSettings

type StreamPoolSpecPrivateEndpointSettings struct {
	// +optional
	NsgIDS []string `json:"nsgIDS,omitempty" tf:"nsg_ids"`
	// +optional
	PrivateEndpointIP *string `json:"privateEndpointIP,omitempty" tf:"private_endpoint_ip"`
	// +optional
	SubnetID *string `json:"subnetID,omitempty" tf:"subnet_id"`
}

func (*StreamPoolSpecPrivateEndpointSettings) DeepCopy

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

func (*StreamPoolSpecPrivateEndpointSettings) DeepCopyInto

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

type StreamPoolSpecPrivateEndpointSettingsCodec

type StreamPoolSpecPrivateEndpointSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (StreamPoolSpecPrivateEndpointSettingsCodec) Decode

func (StreamPoolSpecPrivateEndpointSettingsCodec) Encode

func (StreamPoolSpecPrivateEndpointSettingsCodec) IsEmpty

type StreamPoolSpecResource

type StreamPoolSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	CompartmentID *string `json:"compartmentID" tf:"compartment_id"`
	// +optional
	CustomEncryptionKey *StreamPoolSpecCustomEncryptionKey `json:"customEncryptionKey,omitempty" tf:"custom_encryption_key"`
	// +optional
	DefinedTags map[string]string `json:"definedTags,omitempty" tf:"defined_tags"`
	// +optional
	EndpointFqdn *string `json:"endpointFqdn,omitempty" tf:"endpoint_fqdn"`
	// +optional
	FreeformTags map[string]string `json:"freeformTags,omitempty" tf:"freeform_tags"`
	// +optional
	IsPrivate *bool `json:"isPrivate,omitempty" tf:"is_private"`
	// +optional
	KafkaSettings *StreamPoolSpecKafkaSettings `json:"kafkaSettings,omitempty" tf:"kafka_settings"`
	// +optional
	LifecycleStateDetails *string `json:"lifecycleStateDetails,omitempty" tf:"lifecycle_state_details"`
	Name                  *string `json:"name" tf:"name"`
	// +optional
	PrivateEndpointSettings *StreamPoolSpecPrivateEndpointSettings `json:"privateEndpointSettings,omitempty" tf:"private_endpoint_settings"`
	// +optional
	State *string `json:"state,omitempty" tf:"state"`
	// +optional
	TimeCreated *string `json:"timeCreated,omitempty" tf:"time_created"`
}

func (*StreamPoolSpecResource) DeepCopy

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

func (*StreamPoolSpecResource) DeepCopyInto

func (in *StreamPoolSpecResource) DeepCopyInto(out *StreamPoolSpecResource)

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

type StreamPoolStatus

type StreamPoolStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*StreamPoolStatus) DeepCopy

func (in *StreamPoolStatus) DeepCopy() *StreamPoolStatus

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

func (*StreamPoolStatus) DeepCopyInto

func (in *StreamPoolStatus) DeepCopyInto(out *StreamPoolStatus)

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

type StreamSpec

type StreamSpec struct {
	State *StreamSpecResource `json:"state,omitempty" tf:"-"`

	Resource StreamSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*StreamSpec) DeepCopy

func (in *StreamSpec) DeepCopy() *StreamSpec

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

func (*StreamSpec) DeepCopyInto

func (in *StreamSpec) DeepCopyInto(out *StreamSpec)

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

type StreamSpecResource

type StreamSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	CompartmentID *string `json:"compartmentID,omitempty" tf:"compartment_id"`
	// +optional
	DefinedTags map[string]string `json:"definedTags,omitempty" tf:"defined_tags"`
	// +optional
	FreeformTags map[string]string `json:"freeformTags,omitempty" tf:"freeform_tags"`
	// +optional
	LifecycleStateDetails *string `json:"lifecycleStateDetails,omitempty" tf:"lifecycle_state_details"`
	// +optional
	MessagesEndpoint *string `json:"messagesEndpoint,omitempty" tf:"messages_endpoint"`
	Name             *string `json:"name" tf:"name"`
	Partitions       *int64  `json:"partitions" tf:"partitions"`
	// +optional
	RetentionInHours *int64 `json:"retentionInHours,omitempty" tf:"retention_in_hours"`
	// +optional
	State *string `json:"state,omitempty" tf:"state"`
	// +optional
	StreamPoolID *string `json:"streamPoolID,omitempty" tf:"stream_pool_id"`
	// +optional
	TimeCreated *string `json:"timeCreated,omitempty" tf:"time_created"`
}

func (*StreamSpecResource) DeepCopy

func (in *StreamSpecResource) DeepCopy() *StreamSpecResource

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

func (*StreamSpecResource) DeepCopyInto

func (in *StreamSpecResource) DeepCopyInto(out *StreamSpecResource)

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

type StreamStatus

type StreamStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*StreamStatus) DeepCopy

func (in *StreamStatus) DeepCopy() *StreamStatus

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

func (*StreamStatus) DeepCopyInto

func (in *StreamStatus) DeepCopyInto(out *StreamStatus)

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

Jump to

Keyboard shortcuts

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