v1alpha1

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2020 License: Apache-2.0 Imports: 16 Imported by: 5

Documentation

Overview

+groupName=streaming.projectriff.io

Copyright 2020 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package v1alpha1 contains API Schema definitions for the streaming v1alpha1 API group +kubebuilder:object:generate=true

Copyright 2019 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2019 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2019 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2019 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2019 the original author or authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	GatewayConditionReady                              = apis.ConditionReady
	GatewayConditionDeploymentReady apis.ConditionType = "DeploymentReady"
	GatewayConditionServiceReady    apis.ConditionType = "ServiceReady"
)
View Source 
const (
	InMemoryGatewayConditionReady                           = apis.ConditionReady
	InMemoryGatewayConditionGatewayReady apis.ConditionType = "GatewayReady"
)
View Source 
const (
	KafkaGatewayConditionReady                           = apis.ConditionReady
	KafkaGatewayConditionGatewayReady apis.ConditionType = "GatewayReady"
)
View Source 
const (
	ProcessorConditionReady                                = apis.ConditionReady
	ProcessorConditionStreamsReady      apis.ConditionType = "StreamsReady"
	ProcessorConditionDeploymentReady   apis.ConditionType = "DeploymentReady"
	ProcessorConditionScaledObjectReady apis.ConditionType = "ScaledObjectReady"
)
View Source 
const (
	Earliest = "earliest"
	Latest   = "latest"
)
View Source 
const (
	PulsarGatewayConditionReady                           = apis.ConditionReady
	PulsarGatewayConditionGatewayReady apis.ConditionType = "GatewayReady"
)
View Source 
const (
	StreamConditionReady                                = apis.ConditionReady
	StreamConditionResourceAvailable apis.ConditionType = "ResourceAvailable"
	StreamConditionBindingReady      apis.ConditionType = "BindingReady"
)

Variables

View Source 
var (
	GatewayLabelKey     = GroupVersion.Group + "/gateway"
	GatewayTypeLabelKey = GroupVersion.Group + "/gateway-type"
)
View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "streaming.projectriff.io", 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 (
	InMemoryGatewayLabelKey = GroupVersion.Group + "/inmemory-gateway"
	InMemoryGatewayType     = "inmemory"
)
View Source 
var (
	KafkaGatewayLabelKey = GroupVersion.Group + "/kafka-gateway"
	KafkaGatewayType     = "kafka"
)
View Source 
var (
	PulsarGatewayLabelKey = GroupVersion.Group + "/pulsar-gateway"
	PulsarGatewayType     = "pulsar"
)
View Source 
var (
	ProcessorLabelKey = GroupVersion.Group + "/processor"
)
View Source 
var SchemeGroupVersion = GroupVersion

compatibility with k8s.io/code-generator

View Source 
var (
	StreamLabelKey = GroupVersion.Group + "/stream"
)

Functions

This section is empty.

Types

type BindingReference added in v0.5.0 

type BindingReference struct {
	// Metadata references a ConfigMap with the binding metadata properties
	MetadataRef corev1.LocalObjectReference `json:"metadataRef,omitempty"`

	// Secret references a Secret with the binding secret properties
	SecretRef corev1.LocalObjectReference `json:"secretRef,omitempty"`
}

func (*BindingReference) DeepCopy added in v0.5.0 

func (in *BindingReference) DeepCopy() *BindingReference

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

func (*BindingReference) DeepCopyInto added in v0.5.0 

func (in *BindingReference) DeepCopyInto(out *BindingReference)

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

type Build added in v0.5.0 

type Build struct {
	// ContainerRef references a container in this namespace.
	ContainerRef string `json:"containerRef,omitempty"`

	// FunctionRef references an application in this namespace.
	FunctionRef string `json:"functionRef,omitempty"`
}

func (*Build) DeepCopy added in v0.5.0 

func (in *Build) DeepCopy() *Build

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

func (*Build) DeepCopyInto added in v0.5.0 

func (in *Build) DeepCopyInto(out *Build)

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

func (*Build) Validate added in v0.5.0 

func (b *Build) Validate() validation.FieldErrors

type Gateway added in v0.5.0 

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

	Spec   GatewaySpec   `json:"spec,omitempty"`
	Status GatewayStatus `json:"status,omitempty"`
}

Gateway is the Schema for the gateways API

func (*Gateway) DeepCopy added in v0.5.0 

func (in *Gateway) DeepCopy() *Gateway

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

func (*Gateway) DeepCopyInto added in v0.5.0 

func (in *Gateway) DeepCopyInto(out *Gateway)

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

func (*Gateway) DeepCopyObject added in v0.5.0 

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

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

func (*Gateway) Default added in v0.5.0 

func (r *Gateway) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Gateway) GetGroupVersionKind added in v0.5.0 

func (*Gateway) GetGroupVersionKind() schema.GroupVersionKind

func (*Gateway) GetStatus added in v0.5.0 

func (g *Gateway) GetStatus() apis.ResourceStatus

func (*Gateway) Validate added in v0.5.0 

func (r *Gateway) Validate() validation.FieldErrors

func (*Gateway) ValidateCreate added in v0.5.0 

func (r *Gateway) ValidateCreate() error

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

func (*Gateway) ValidateDelete added in v0.5.0 

func (r *Gateway) ValidateDelete() error

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

func (*Gateway) ValidateUpdate added in v0.5.0 

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

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

type GatewayList added in v0.5.0 

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

GatewayList contains a list of Gateway

func (*GatewayList) DeepCopy added in v0.5.0 

func (in *GatewayList) DeepCopy() *GatewayList

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

func (*GatewayList) DeepCopyInto added in v0.5.0 

func (in *GatewayList) DeepCopyInto(out *GatewayList)

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

func (*GatewayList) DeepCopyObject added in v0.5.0 

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

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

type GatewaySpec added in v0.5.0 

type GatewaySpec struct {

	// +optional
	Template *corev1.PodTemplateSpec `json:"template,omitempty"`
	Ports    []corev1.ServicePort    `json:"ports,omitempty"`
}

GatewaySpec defines the desired state of Gateway

func (*GatewaySpec) DeepCopy added in v0.5.0 

func (in *GatewaySpec) DeepCopy() *GatewaySpec

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

func (*GatewaySpec) DeepCopyInto added in v0.5.0 

func (in *GatewaySpec) DeepCopyInto(out *GatewaySpec)

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

func (*GatewaySpec) Default added in v0.5.0 

func (s *GatewaySpec) Default()

func (*GatewaySpec) Validate added in v0.5.0 

func (s *GatewaySpec) Validate() validation.FieldErrors

type GatewayStatus added in v0.5.0 

type GatewayStatus struct {
	apis.Status   `json:",inline"`
	Address       *apis.Addressable               `json:"address,omitempty"`
	DeploymentRef *refs.TypedLocalObjectReference `json:"deploymentRef,omitempty"`
	ServiceRef    *refs.TypedLocalObjectReference `json:"serviceRef,omitempty"`
}

GatewayStatus defines the observed state of Gateway

func (*GatewayStatus) DeepCopy added in v0.5.0 

func (in *GatewayStatus) DeepCopy() *GatewayStatus

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

func (*GatewayStatus) DeepCopyInto added in v0.5.0 

func (in *GatewayStatus) DeepCopyInto(out *GatewayStatus)

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

func (*GatewayStatus) GetCondition added in v0.5.0 

func (s *GatewayStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*GatewayStatus) GetObservedGeneration added in v0.5.0 

func (s *GatewayStatus) GetObservedGeneration() int64

func (*GatewayStatus) GetReadyConditionType added in v0.5.0 

func (*GatewayStatus) GetReadyConditionType() apis.ConditionType

func (*GatewayStatus) InitializeConditions added in v0.5.0 

func (s *GatewayStatus) InitializeConditions()

func (*GatewayStatus) IsReady added in v0.5.0 

func (s *GatewayStatus) IsReady() bool

func (*GatewayStatus) PropagateDeploymentStatus added in v0.5.0 

func (s *GatewayStatus) PropagateDeploymentStatus(cds *appsv1.DeploymentStatus)

func (*GatewayStatus) PropagateServiceStatus added in v0.5.0 

func (s *GatewayStatus) PropagateServiceStatus(ss *corev1.ServiceStatus)

type InMemoryGateway added in v0.5.0 

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

	Spec   InMemoryGatewaySpec   `json:"spec,omitempty"`
	Status InMemoryGatewayStatus `json:"status,omitempty"`
}

InMemoryGateway is the Schema for the gateways API

func (*InMemoryGateway) DeepCopy added in v0.5.0 

func (in *InMemoryGateway) DeepCopy() *InMemoryGateway

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

func (*InMemoryGateway) DeepCopyInto added in v0.5.0 

func (in *InMemoryGateway) DeepCopyInto(out *InMemoryGateway)

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

func (*InMemoryGateway) DeepCopyObject added in v0.5.0 

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

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

func (*InMemoryGateway) Default added in v0.5.0 

func (r *InMemoryGateway) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*InMemoryGateway) GetGroupVersionKind added in v0.5.0 

func (*InMemoryGateway) GetGroupVersionKind() schema.GroupVersionKind

func (*InMemoryGateway) GetStatus added in v0.5.0 

func (p *InMemoryGateway) GetStatus() apis.ResourceStatus

func (*InMemoryGateway) Validate added in v0.5.0 

func (r *InMemoryGateway) Validate() validation.FieldErrors

func (*InMemoryGateway) ValidateCreate added in v0.5.0 

func (r *InMemoryGateway) ValidateCreate() error

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

func (*InMemoryGateway) ValidateDelete added in v0.5.0 

func (r *InMemoryGateway) ValidateDelete() error

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

func (*InMemoryGateway) ValidateUpdate added in v0.5.0 

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

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

type InMemoryGatewayList added in v0.5.0 

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

InMemoryGatewayList contains a list of InMemoryGateway

func (*InMemoryGatewayList) DeepCopy added in v0.5.0 

func (in *InMemoryGatewayList) DeepCopy() *InMemoryGatewayList

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

func (*InMemoryGatewayList) DeepCopyInto added in v0.5.0 

func (in *InMemoryGatewayList) DeepCopyInto(out *InMemoryGatewayList)

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

func (*InMemoryGatewayList) DeepCopyObject added in v0.5.0 

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

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

type InMemoryGatewaySpec added in v0.5.0 

type InMemoryGatewaySpec struct {
}

InMemoryGatewaySpec defines the desired state of InMemoryGateway

func (*InMemoryGatewaySpec) DeepCopy added in v0.5.0 

func (in *InMemoryGatewaySpec) DeepCopy() *InMemoryGatewaySpec

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

func (*InMemoryGatewaySpec) DeepCopyInto added in v0.5.0 

func (in *InMemoryGatewaySpec) DeepCopyInto(out *InMemoryGatewaySpec)

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

func (*InMemoryGatewaySpec) Default added in v0.5.0 

func (s *InMemoryGatewaySpec) Default()

func (*InMemoryGatewaySpec) Validate added in v0.5.0 

func (s *InMemoryGatewaySpec) Validate() validation.FieldErrors

type InMemoryGatewayStatus added in v0.5.0 

type InMemoryGatewayStatus struct {
	apis.Status      `json:",inline"`
	Address          *apis.Addressable               `json:"address,omitempty"`
	GatewayRef       *refs.TypedLocalObjectReference `json:"gatewayRef,omitempty"`
	GatewayImage     string                          `json:"gatewayImage,omitempty"`
	ProvisionerImage string                          `json:"provisionerImage,omitempty"`
}

InMemoryGatewayStatus defines the observed state of InMemoryGateway

func (*InMemoryGatewayStatus) DeepCopy added in v0.5.0 

func (in *InMemoryGatewayStatus) DeepCopy() *InMemoryGatewayStatus

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

func (*InMemoryGatewayStatus) DeepCopyInto added in v0.5.0 

func (in *InMemoryGatewayStatus) DeepCopyInto(out *InMemoryGatewayStatus)

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

func (*InMemoryGatewayStatus) GetCondition added in v0.5.0 

func (s *InMemoryGatewayStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*InMemoryGatewayStatus) GetObservedGeneration added in v0.5.0 

func (s *InMemoryGatewayStatus) GetObservedGeneration() int64

func (*InMemoryGatewayStatus) GetReadyConditionType added in v0.5.0 

func (*InMemoryGatewayStatus) GetReadyConditionType() apis.ConditionType

func (*InMemoryGatewayStatus) InitializeConditions added in v0.5.0 

func (s *InMemoryGatewayStatus) InitializeConditions()

func (*InMemoryGatewayStatus) IsReady added in v0.5.0 

func (s *InMemoryGatewayStatus) IsReady() bool

func (*InMemoryGatewayStatus) MarkGatewayNotOwned added in v0.5.0 

func (s *InMemoryGatewayStatus) MarkGatewayNotOwned(name string)

func (*InMemoryGatewayStatus) PropagateGatewayStatus added in v0.5.0 

func (s *InMemoryGatewayStatus) PropagateGatewayStatus(gs *GatewayStatus)

type InputStreamBinding added in v0.5.0 

type InputStreamBinding struct {
	// Stream name, from this namespace, to be bound to the processor
	Stream string `json:"stream"`

	// Alias exposes the stream under another name within the processor
	// +optional
	Alias string `json:"alias,omitempty"`

	// Where to start consuming this stream the first time a processor runs.
	StartOffset string `json:"startOffset"`
}

func (*InputStreamBinding) DeepCopy added in v0.5.0 

func (in *InputStreamBinding) DeepCopy() *InputStreamBinding

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

func (*InputStreamBinding) DeepCopyInto added in v0.5.0 

func (in *InputStreamBinding) DeepCopyInto(out *InputStreamBinding)

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

type KafkaGateway added in v0.5.0 

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

	Spec   KafkaGatewaySpec   `json:"spec,omitempty"`
	Status KafkaGatewayStatus `json:"status,omitempty"`
}

KafkaGateway is the Schema for the gateways API

func (*KafkaGateway) DeepCopy added in v0.5.0 

func (in *KafkaGateway) DeepCopy() *KafkaGateway

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

func (*KafkaGateway) DeepCopyInto added in v0.5.0 

func (in *KafkaGateway) DeepCopyInto(out *KafkaGateway)

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

func (*KafkaGateway) DeepCopyObject added in v0.5.0 

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

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

func (*KafkaGateway) Default added in v0.5.0 

func (r *KafkaGateway) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*KafkaGateway) GetGroupVersionKind added in v0.5.0 

func (*KafkaGateway) GetGroupVersionKind() schema.GroupVersionKind

func (*KafkaGateway) GetStatus added in v0.5.0 

func (p *KafkaGateway) GetStatus() apis.ResourceStatus

func (*KafkaGateway) Validate added in v0.5.0 

func (r *KafkaGateway) Validate() validation.FieldErrors

func (*KafkaGateway) ValidateCreate added in v0.5.0 

func (r *KafkaGateway) ValidateCreate() error

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

func (*KafkaGateway) ValidateDelete added in v0.5.0 

func (r *KafkaGateway) ValidateDelete() error

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

func (*KafkaGateway) ValidateUpdate added in v0.5.0 

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

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

type KafkaGatewayList added in v0.5.0 

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

KafkaGatewayList contains a list of KafkaGateway

func (*KafkaGatewayList) DeepCopy added in v0.5.0 

func (in *KafkaGatewayList) DeepCopy() *KafkaGatewayList

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

func (*KafkaGatewayList) DeepCopyInto added in v0.5.0 

func (in *KafkaGatewayList) DeepCopyInto(out *KafkaGatewayList)

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

func (*KafkaGatewayList) DeepCopyObject added in v0.5.0 

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

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

type KafkaGatewaySpec added in v0.5.0 

type KafkaGatewaySpec struct {

	// BootstrapServers is a comma-separated list of host and port pairs that are the
	// addresses of the Kafka brokers in a "bootstrap" Kafka cluster that a Kafka client
	// connects to initially to bootstrap itself.
	//
	// A host and port pair uses `:` as the separator.
	BootstrapServers string `json:"bootstrapServers"`
}

KafkaGatewaySpec defines the desired state of KafkaGateway

func (*KafkaGatewaySpec) DeepCopy added in v0.5.0 

func (in *KafkaGatewaySpec) DeepCopy() *KafkaGatewaySpec

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

func (*KafkaGatewaySpec) DeepCopyInto added in v0.5.0 

func (in *KafkaGatewaySpec) DeepCopyInto(out *KafkaGatewaySpec)

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

func (*KafkaGatewaySpec) Default added in v0.5.0 

func (s *KafkaGatewaySpec) Default()

func (*KafkaGatewaySpec) Validate added in v0.5.0 

func (s *KafkaGatewaySpec) Validate() validation.FieldErrors

type KafkaGatewayStatus added in v0.5.0 

type KafkaGatewayStatus struct {
	apis.Status      `json:",inline"`
	Address          *apis.Addressable               `json:"address,omitempty"`
	GatewayRef       *refs.TypedLocalObjectReference `json:"gatewayRef,omitempty"`
	GatewayImage     string                          `json:"gatewayImage,omitempty"`
	ProvisionerImage string                          `json:"provisionerImage,omitempty"`
}

KafkaGatewayStatus defines the observed state of KafkaGateway

func (*KafkaGatewayStatus) DeepCopy added in v0.5.0 

func (in *KafkaGatewayStatus) DeepCopy() *KafkaGatewayStatus

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

func (*KafkaGatewayStatus) DeepCopyInto added in v0.5.0 

func (in *KafkaGatewayStatus) DeepCopyInto(out *KafkaGatewayStatus)

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

func (*KafkaGatewayStatus) GetCondition added in v0.5.0 

func (s *KafkaGatewayStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*KafkaGatewayStatus) GetObservedGeneration added in v0.5.0 

func (s *KafkaGatewayStatus) GetObservedGeneration() int64

func (*KafkaGatewayStatus) GetReadyConditionType added in v0.5.0 

func (*KafkaGatewayStatus) GetReadyConditionType() apis.ConditionType

func (*KafkaGatewayStatus) InitializeConditions added in v0.5.0 

func (s *KafkaGatewayStatus) InitializeConditions()

func (*KafkaGatewayStatus) IsReady added in v0.5.0 

func (s *KafkaGatewayStatus) IsReady() bool

func (*KafkaGatewayStatus) MarkGatewayNotOwned added in v0.5.0 

func (s *KafkaGatewayStatus) MarkGatewayNotOwned(name string)

func (*KafkaGatewayStatus) PropagateGatewayStatus added in v0.5.0 

func (s *KafkaGatewayStatus) PropagateGatewayStatus(gs *GatewayStatus)

type OutputStreamBinding added in v0.5.0 

type OutputStreamBinding struct {
	// Stream name, from this namespace, to be bound to the processor
	Stream string `json:"stream"`

	// Alias exposes the stream under another name within the processor
	// +optional
	Alias string `json:"alias,omitempty"`
}

func (*OutputStreamBinding) DeepCopy added in v0.5.0 

func (in *OutputStreamBinding) DeepCopy() *OutputStreamBinding

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

func (*OutputStreamBinding) DeepCopyInto added in v0.5.0 

func (in *OutputStreamBinding) DeepCopyInto(out *OutputStreamBinding)

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

type Processor 

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

	Spec   ProcessorSpec   `json:"spec,omitempty"`
	Status ProcessorStatus `json:"status,omitempty"`
}

Processor is the Schema for the processors API

func (*Processor) DeepCopy 

func (in *Processor) DeepCopy() *Processor

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

func (*Processor) DeepCopyInto 

func (in *Processor) DeepCopyInto(out *Processor)

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

func (*Processor) DeepCopyObject 

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

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

func (*Processor) Default added in v0.5.0 

func (r *Processor) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Processor) GetGroupVersionKind 

func (*Processor) GetGroupVersionKind() schema.GroupVersionKind

func (*Processor) GetStatus 

func (p *Processor) GetStatus() apis.ResourceStatus

func (*Processor) Validate 

func (r *Processor) Validate() validation.FieldErrors

func (*Processor) ValidateCreate added in v0.5.0 

func (r *Processor) ValidateCreate() error

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

func (*Processor) ValidateDelete added in v0.5.0 

func (r *Processor) ValidateDelete() error

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

func (*Processor) ValidateUpdate added in v0.5.0 

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

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

type ProcessorList 

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

ProcessorList contains a list of Processor

func (*ProcessorList) DeepCopy 

func (in *ProcessorList) DeepCopy() *ProcessorList

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

func (*ProcessorList) DeepCopyInto 

func (in *ProcessorList) DeepCopyInto(out *ProcessorList)

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

func (*ProcessorList) DeepCopyObject 

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

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

type ProcessorSpec 

type ProcessorSpec struct {

	// Build resolves the image from a build resource. As the target build
	// produces new images, they will be automatically rolled out to the
	// processor.
	// +optional
	Build *Build `json:"build,omitempty"`

	// Inputs references an ordered list of streams to bind as inputs
	Inputs []InputStreamBinding `json:"inputs"`
	// Outputs references an ordered list of streams to bind as outputs
	// +optional
	Outputs []OutputStreamBinding `json:"outputs"`

	// Template pod
	// +optional
	Template *corev1.PodTemplateSpec `json:"template,omitempty"`
}

ProcessorSpec defines the desired state of Processor

func (*ProcessorSpec) DeepCopy 

func (in *ProcessorSpec) DeepCopy() *ProcessorSpec

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

func (*ProcessorSpec) DeepCopyInto 

func (in *ProcessorSpec) DeepCopyInto(out *ProcessorSpec)

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

func (*ProcessorSpec) Default added in v0.5.0 

func (s *ProcessorSpec) Default()

func (*ProcessorSpec) Validate 

func (s *ProcessorSpec) Validate() validation.FieldErrors

type ProcessorStatus 

type ProcessorStatus struct {
	apis.Status `json:",inline"`

	DeploymentRef   *refs.TypedLocalObjectReference `json:"deploymentRef,omitempty"`
	ScaledObjectRef *refs.TypedLocalObjectReference `json:"scaledObjectRef,omitempty"`
	LatestImage     string                          `json:"latestImage,omitempty"`
}

ProcessorStatus defines the observed state of Processor

func (*ProcessorStatus) DeepCopy 

func (in *ProcessorStatus) DeepCopy() *ProcessorStatus

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

func (*ProcessorStatus) DeepCopyInto 

func (in *ProcessorStatus) DeepCopyInto(out *ProcessorStatus)

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

func (*ProcessorStatus) GetCondition 

func (ps *ProcessorStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*ProcessorStatus) GetObservedGeneration 

func (ps *ProcessorStatus) GetObservedGeneration() int64

func (*ProcessorStatus) GetReadyConditionType 

func (*ProcessorStatus) GetReadyConditionType() apis.ConditionType

func (*ProcessorStatus) InitializeConditions 

func (ps *ProcessorStatus) InitializeConditions()

func (*ProcessorStatus) IsReady 

func (ps *ProcessorStatus) IsReady() bool

func (*ProcessorStatus) MarkStreamsNotReady added in v0.5.0 

func (ps *ProcessorStatus) MarkStreamsNotReady(message string)

func (*ProcessorStatus) MarkStreamsReady added in v0.5.0 

func (ps *ProcessorStatus) MarkStreamsReady()

func (*ProcessorStatus) PropagateDeploymentStatus 

func (ps *ProcessorStatus) PropagateDeploymentStatus(ds *appsv1.DeploymentStatus)

func (*ProcessorStatus) PropagateScaledObjectStatus added in v0.5.0 

func (ps *ProcessorStatus) PropagateScaledObjectStatus(sos *kedav1alpha1.ScaledObjectStatus)

type PulsarGateway added in v0.5.0 

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

	Spec   PulsarGatewaySpec   `json:"spec,omitempty"`
	Status PulsarGatewayStatus `json:"status,omitempty"`
}

PulsarGateway is the Schema for the gateways API

func (*PulsarGateway) DeepCopy added in v0.5.0 

func (in *PulsarGateway) DeepCopy() *PulsarGateway

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

func (*PulsarGateway) DeepCopyInto added in v0.5.0 

func (in *PulsarGateway) DeepCopyInto(out *PulsarGateway)

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

func (*PulsarGateway) DeepCopyObject added in v0.5.0 

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

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

func (*PulsarGateway) Default added in v0.5.0 

func (r *PulsarGateway) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*PulsarGateway) GetGroupVersionKind added in v0.5.0 

func (*PulsarGateway) GetGroupVersionKind() schema.GroupVersionKind

func (*PulsarGateway) GetStatus added in v0.5.0 

func (p *PulsarGateway) GetStatus() apis.ResourceStatus

func (*PulsarGateway) Validate added in v0.5.0 

func (r *PulsarGateway) Validate() validation.FieldErrors

func (*PulsarGateway) ValidateCreate added in v0.5.0 

func (r *PulsarGateway) ValidateCreate() error

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

func (*PulsarGateway) ValidateDelete added in v0.5.0 

func (r *PulsarGateway) ValidateDelete() error

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

func (*PulsarGateway) ValidateUpdate added in v0.5.0 

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

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

type PulsarGatewayList added in v0.5.0 

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

PulsarGatewayList contains a list of PulsarGateway

func (*PulsarGatewayList) DeepCopy added in v0.5.0 

func (in *PulsarGatewayList) DeepCopy() *PulsarGatewayList

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

func (*PulsarGatewayList) DeepCopyInto added in v0.5.0 

func (in *PulsarGatewayList) DeepCopyInto(out *PulsarGatewayList)

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

func (*PulsarGatewayList) DeepCopyObject added in v0.5.0 

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

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

type PulsarGatewaySpec added in v0.5.0 

type PulsarGatewaySpec struct {

	// ServiceURL is the Pulsar URL to connect to, in the form pulsar://host:port[,host2:port2].
	ServiceURL string `json:"serviceURL"`
}

PulsarGatewaySpec defines the desired state of PulsarGateway

func (*PulsarGatewaySpec) DeepCopy added in v0.5.0 

func (in *PulsarGatewaySpec) DeepCopy() *PulsarGatewaySpec

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

func (*PulsarGatewaySpec) DeepCopyInto added in v0.5.0 

func (in *PulsarGatewaySpec) DeepCopyInto(out *PulsarGatewaySpec)

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

func (*PulsarGatewaySpec) Default added in v0.5.0 

func (s *PulsarGatewaySpec) Default()

func (*PulsarGatewaySpec) Validate added in v0.5.0 

func (s *PulsarGatewaySpec) Validate() validation.FieldErrors

type PulsarGatewayStatus added in v0.5.0 

type PulsarGatewayStatus struct {
	apis.Status      `json:",inline"`
	Address          *apis.Addressable               `json:"address,omitempty"`
	GatewayRef       *refs.TypedLocalObjectReference `json:"gatewayRef,omitempty"`
	GatewayImage     string                          `json:"gatewayImage,omitempty"`
	ProvisionerImage string                          `json:"provisionerImage,omitempty"`
}

PulsarGatewayStatus defines the observed state of PulsarGateway

func (*PulsarGatewayStatus) DeepCopy added in v0.5.0 

func (in *PulsarGatewayStatus) DeepCopy() *PulsarGatewayStatus

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

func (*PulsarGatewayStatus) DeepCopyInto added in v0.5.0 

func (in *PulsarGatewayStatus) DeepCopyInto(out *PulsarGatewayStatus)

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

func (*PulsarGatewayStatus) GetCondition added in v0.5.0 

func (s *PulsarGatewayStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*PulsarGatewayStatus) GetObservedGeneration added in v0.5.0 

func (s *PulsarGatewayStatus) GetObservedGeneration() int64

func (*PulsarGatewayStatus) GetReadyConditionType added in v0.5.0 

func (*PulsarGatewayStatus) GetReadyConditionType() apis.ConditionType

func (*PulsarGatewayStatus) InitializeConditions added in v0.5.0 

func (s *PulsarGatewayStatus) InitializeConditions()

func (*PulsarGatewayStatus) IsReady added in v0.5.0 

func (s *PulsarGatewayStatus) IsReady() bool

func (*PulsarGatewayStatus) MarkGatewayNotOwned added in v0.5.0 

func (s *PulsarGatewayStatus) MarkGatewayNotOwned(name string)

func (*PulsarGatewayStatus) PropagateGatewayStatus added in v0.5.0 

func (s *PulsarGatewayStatus) PropagateGatewayStatus(gs *GatewayStatus)

type Stream 

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

	Spec   StreamSpec   `json:"spec,omitempty"`
	Status StreamStatus `json:"status,omitempty"`
}

Stream is the Schema for the streams API

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) Default added in v0.5.0 

func (r *Stream) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Stream) GetGroupVersionKind 

func (*Stream) GetGroupVersionKind() schema.GroupVersionKind

func (*Stream) GetStatus 

func (s *Stream) GetStatus() apis.ResourceStatus

func (*Stream) Validate 

func (r *Stream) Validate() validation.FieldErrors

func (*Stream) ValidateCreate added in v0.5.0 

func (r *Stream) ValidateCreate() error

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

func (*Stream) ValidateDelete added in v0.5.0 

func (r *Stream) ValidateDelete() error

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

func (*Stream) ValidateUpdate added in v0.5.0 

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           []Stream `json:"items"`
}

StreamList contains a list of Stream

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 StreamSpec 

type StreamSpec struct {
	Gateway     corev1.LocalObjectReference `json:"gateway"`
	ContentType string                      `json:"contentType"`
}

StreamSpec defines the desired state of Stream

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.

func (*StreamSpec) Default added in v0.5.0 

func (s *StreamSpec) Default()

func (*StreamSpec) Validate 

func (s *StreamSpec) Validate() validation.FieldErrors

type StreamStatus 

type StreamStatus struct {
	apis.Status `json:",inline"`

	Binding BindingReference `json:"binding,omitempty"`
}

StreamStatus defines the observed state of Stream

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.

func (*StreamStatus) GetCondition 

func (ss *StreamStatus) GetCondition(t apis.ConditionType) *apis.Condition

func (*StreamStatus) GetObservedGeneration 

func (ss *StreamStatus) GetObservedGeneration() int64

func (*StreamStatus) GetReadyConditionType 

func (*StreamStatus) GetReadyConditionType() apis.ConditionType

func (*StreamStatus) InitializeConditions 

func (ss *StreamStatus) InitializeConditions()

func (*StreamStatus) IsReady 

func (ss *StreamStatus) IsReady() bool

func (*StreamStatus) MarkBindingNotReady added in v0.5.0 

func (ss *StreamStatus) MarkBindingNotReady(message string, a ...interface{})

func (*StreamStatus) MarkBindingReady added in v0.5.0 

func (ss *StreamStatus) MarkBindingReady()

func (*StreamStatus) MarkStreamProvisionFailed 

func (ss *StreamStatus) MarkStreamProvisionFailed(message string)

func (*StreamStatus) MarkStreamProvisioned 

func (ss *StreamStatus) MarkStreamProvisioned()

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.