v1alpha1

Sep 19, 2022

Changes in this version

+ type AuthConfig struct

+ OAuth2Config *OAuth2Config

+ func (in *AuthConfig) DeepCopy() *AuthConfig

+ func (in *AuthConfig) DeepCopyInto(out *AuthConfig)

type FunctionMeshStatus

+ ObservedGeneration int64

type FunctionSpec

+ MinReplicas *int32

+ WindowConfig *WindowConfig

type FunctionStatus

+ ObservedGeneration int64

+ type OAuth2Config struct

+ Audience string

+ IssuerURL string

+ KeySecretKey string

+ KeySecretName string

+ Scope string

+ func (in *OAuth2Config) DeepCopy() *OAuth2Config

+ func (in *OAuth2Config) DeepCopyInto(out *OAuth2Config)

+ func (o *OAuth2Config) AuthenticationParameters() string

+ func (o *OAuth2Config) GetMountFile() string

+ func (o *OAuth2Config) GetMountPath() string

type PulsarMessaging

+ AuthConfig *AuthConfig

type RuntimeLogConfig

+ RotatePolicy *TriggeringPolicy

type SinkSpec

+ MinReplicas *int32

type SinkStatus

+ ObservedGeneration int64

type SourceSpec

+ MinReplicas *int32

type SourceStatus

+ ObservedGeneration int64

+ type TriggeringPolicy string

+ const SizedPolicyWith100MB

+ const SizedPolicyWith10MB

+ const SizedPolicyWith50MB

+ const TimedPolicyWithDaily

+ const TimedPolicyWithMonthly

+ const TimedPolicyWithWeekly

+ type WindowConfig struct

+ ActualWindowFunctionClassName string

+ LateDataTopic string

+ MaxLagMs *int64

+ SlidingIntervalCount *int32

+ SlidingIntervalDurationMs *int64

+ TimestampExtractorClassName *string

+ WatermarkEmitIntervalMs *int64

+ WindowLengthCount *int32

+ WindowLengthDurationMs *int64

+ func (in *WindowConfig) DeepCopy() *WindowConfig

+ func (in *WindowConfig) DeepCopyInto(out *WindowConfig)

Aug 19, 2022

Changes in this version

type GoRuntime

+ Log *RuntimeLogConfig

type JavaRuntime

+ Log *RuntimeLogConfig

+ type LogConfig struct

+ Key string

+ Name string

+ func (in *LogConfig) DeepCopy() *LogConfig

+ func (in *LogConfig) DeepCopyInto(out *LogConfig)

+ type LogLevel string

+ const LogLevelAll

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelOff

+ const LogLevelPanic

+ const LogLevelTrace

+ const LogLevelWarn

type PythonRuntime

+ Log *RuntimeLogConfig

type ResourceCondition

+ func CreateCondition(condType ResourceConditionType, status metav1.ConditionStatus, ...) ResourceCondition

type ResourceConditionType

+ const Orphaned

+ type RuntimeLogConfig struct

+ Level LogLevel

+ LogConfig *LogConfig

+ func (in *RuntimeLogConfig) DeepCopy() *RuntimeLogConfig

+ func (in *RuntimeLogConfig) DeepCopyInto(out *RuntimeLogConfig)

Jul 19, 2022

Changes in this version

type PodPolicy

+ Env []corev1.EnvVar

type PulsarMessaging

+ TLSConfig *PulsarTLSConfig

+ type PulsarTLSConfig struct

+ func (c *PulsarTLSConfig) AllowInsecureConnection() string

+ func (c *PulsarTLSConfig) EnableHostnameVerification() string

+ func (c *PulsarTLSConfig) GetMountPath() string

+ func (c *PulsarTLSConfig) HasSecretVolume() bool

+ func (c *PulsarTLSConfig) IsEnabled() bool

+ func (c *PulsarTLSConfig) SecretKey() string

+ func (c *PulsarTLSConfig) SecretName() string

+ func (in *PulsarTLSConfig) DeepCopy() *PulsarTLSConfig

+ func (in *PulsarTLSConfig) DeepCopyInto(out *PulsarTLSConfig)

+ type TLSConfig struct

+ AllowInsecure bool

+ CertSecretKey string

+ CertSecretName string

+ Enabled bool

+ HostnameVerification bool

+ func (in *TLSConfig) DeepCopy() *TLSConfig

+ func (in *TLSConfig) DeepCopyInto(out *TLSConfig)

Jun 22, 2022

Changes in this version

+ const AtleastOnce

+ const AtmostOnce

+ const DefaultCluster

+ const DefaultNamespace

+ const DefaultResourceCPU

+ const DefaultResourceMemory

+ const DefaultTenant

+ const EffectivelyOnce

+ const FunctionComponent

+ const PackageURLFunction

+ const PackageURLHTTP

+ const PackageURLHTTPS

+ const PackageURLSink

+ const PackageURLSource

+ const SinkComponent

+ const SourceComponent

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type BuiltinHPARule string

+ const AverageUtilizationCPUPercent20

+ const AverageUtilizationCPUPercent50

+ const AverageUtilizationCPUPercent80

+ const AverageUtilizationMemoryPercent20

+ const AverageUtilizationMemoryPercent50

+ const AverageUtilizationMemoryPercent80

+ type Component string

+ const HPA

+ const Service

+ const StatefulSet

+ type Config struct

+ Data map[string]interface{}

+ func NewConfig(cfg map[string]interface{}) Config

+ func (c *Config) DeepCopyInto(out *Config)

+ func (c *Config) MarshalJSON() ([]byte, error)

+ func (c *Config) UnmarshalJSON(data []byte) error

+ func (in *Config) DeepCopy() *Config

+ type ConsumerConfig struct

+ ConsumerProperties map[string]string

+ CryptoConfig *CryptoConfig

+ IsRegexPattern bool

+ ReceiverQueueSize *int32

+ SchemaProperties map[string]string

+ SchemaType string

+ SerdeClassName string

+ func (in *ConsumerConfig) DeepCopy() *ConsumerConfig

+ func (in *ConsumerConfig) DeepCopyInto(out *ConsumerConfig)

+ type CryptoConfig struct

+ ConsumerCryptoFailureAction string

+ CryptoKeyReaderClassName string

+ CryptoKeyReaderConfig map[string]string

+ CryptoSecrets []CryptoSecret

+ EncryptionKeys []string

+ ProducerCryptoFailureAction string

+ func (in *CryptoConfig) DeepCopy() *CryptoConfig

+ func (in *CryptoConfig) DeepCopyInto(out *CryptoConfig)

+ type CryptoSecret struct

+ AsVolume string

+ SecretKey string

+ SecretName string

+ func (in *CryptoSecret) DeepCopy() *CryptoSecret

+ func (in *CryptoSecret) DeepCopyInto(out *CryptoSecret)

+ type Function struct

+ Spec FunctionSpec

+ Status FunctionStatus

+ func (in *Function) DeepCopy() *Function

+ func (in *Function) DeepCopyInto(out *Function)

+ func (in *Function) DeepCopyObject() runtime.Object

+ func (r *Function) Default()

+ func (r *Function) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Function) ValidateCreate() error

+ func (r *Function) ValidateDelete() error

+ func (r *Function) ValidateUpdate(old runtime.Object) error

+ type FunctionList struct

+ Items []Function

+ func (in *FunctionList) DeepCopy() *FunctionList

+ func (in *FunctionList) DeepCopyInto(out *FunctionList)

+ func (in *FunctionList) DeepCopyObject() runtime.Object

+ type FunctionMesh struct

+ Spec FunctionMeshSpec

+ Status FunctionMeshStatus

+ func (in *FunctionMesh) DeepCopy() *FunctionMesh

+ func (in *FunctionMesh) DeepCopyInto(out *FunctionMesh)

+ func (in *FunctionMesh) DeepCopyObject() runtime.Object

+ type FunctionMeshList struct

+ Items []FunctionMesh

+ func (in *FunctionMeshList) DeepCopy() *FunctionMeshList

+ func (in *FunctionMeshList) DeepCopyInto(out *FunctionMeshList)

+ func (in *FunctionMeshList) DeepCopyObject() runtime.Object

+ type FunctionMeshSpec struct

+ Functions []FunctionSpec

+ Sinks []SinkSpec

+ Sources []SourceSpec

+ func (in *FunctionMeshSpec) DeepCopy() *FunctionMeshSpec

+ func (in *FunctionMeshSpec) DeepCopyInto(out *FunctionMeshSpec)

+ type FunctionMeshStatus struct

+ FunctionConditions map[string]ResourceCondition

+ SinkConditions map[string]ResourceCondition

+ SourceConditions map[string]ResourceCondition

+ func (in *FunctionMeshStatus) DeepCopy() *FunctionMeshStatus

+ func (in *FunctionMeshStatus) DeepCopyInto(out *FunctionMeshStatus)

+ type FunctionSpec struct

+ AutoAck *bool

+ ClassName string

+ CleanupSubscription bool

+ ClusterName string

+ DeadLetterTopic string

+ ForwardSourceMessageProperty *bool

+ FuncConfig *Config

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ Input InputConf

+ LogTopic string

+ MaxMessageRetry int32

+ MaxPendingAsyncRequests *int32

+ MaxReplicas *int32

+ Name string

+ Namespace string

+ Output OutputConf

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ StateConfig *Stateful

+ SubscriptionName string

+ SubscriptionPosition SubscribePosition

+ Tenant string

+ Timeout int32

+ VolumeMounts []corev1.VolumeMount

+ func (in *FunctionSpec) DeepCopy() *FunctionSpec

+ func (in *FunctionSpec) DeepCopyInto(out *FunctionSpec)

+ type FunctionStatus struct

+ Conditions map[Component]ResourceCondition

+ Replicas int32

+ Selector string

+ func (in *FunctionStatus) DeepCopy() *FunctionStatus

+ func (in *FunctionStatus) DeepCopyInto(out *FunctionStatus)

+ type GoRuntime struct

+ Go string

+ GoLocation string

+ func (in *GoRuntime) DeepCopy() *GoRuntime

+ func (in *GoRuntime) DeepCopyInto(out *GoRuntime)

+ type InputConf struct

+ CustomSchemaSources map[string]string

+ CustomSerdeSources map[string]string

+ SourceSpecs map[string]ConsumerConfig

+ TopicPattern string

+ Topics []string

+ TypeClassName string

+ func (in *InputConf) DeepCopy() *InputConf

+ func (in *InputConf) DeepCopyInto(out *InputConf)

+ type JavaRuntime struct

+ ExtraDependenciesDir string

+ Jar string

+ JarLocation string

+ func (in *JavaRuntime) DeepCopy() *JavaRuntime

+ func (in *JavaRuntime) DeepCopyInto(out *JavaRuntime)

+ type Messaging struct

+ Pulsar *PulsarMessaging

+ func (in *Messaging) DeepCopy() *Messaging

+ func (in *Messaging) DeepCopyInto(out *Messaging)

+ type OutputConf struct

+ CustomSchemaSinks map[string]string

+ ProducerConf *ProducerConfig

+ SinkSchemaType string

+ SinkSerdeClassName string

+ Topic string

+ TypeClassName string

+ func (in *OutputConf) DeepCopy() *OutputConf

+ func (in *OutputConf) DeepCopyInto(out *OutputConf)

+ type PodPolicy struct

+ Affinity *corev1.Affinity

+ Annotations map[string]string

+ AutoScalingBehavior *autov2beta2.HorizontalPodAutoscalerBehavior

+ AutoScalingMetrics []autov2beta2.MetricSpec

+ BuiltinAutoscaler []BuiltinHPARule

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ Labels map[string]string

+ NodeSelector map[string]string

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Sidecars []corev1.Container

+ TerminationGracePeriodSeconds int64

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

+ func (in *PodPolicy) DeepCopy() *PodPolicy

+ func (in *PodPolicy) DeepCopyInto(out *PodPolicy)

+ type ProcessGuarantee string

+ type ProducerConfig struct

+ BatchBuilder string

+ CryptoConfig *CryptoConfig

+ MaxPendingMessages int32

+ MaxPendingMessagesAcrossPartitions int32

+ UseThreadLocalProducers bool

+ func (in *ProducerConfig) DeepCopy() *ProducerConfig

+ func (in *ProducerConfig) DeepCopyInto(out *ProducerConfig)

+ type PulsarMessaging struct

+ AuthSecret string

+ PulsarConfig string

+ TLSSecret string

+ func (in *PulsarMessaging) DeepCopy() *PulsarMessaging

+ func (in *PulsarMessaging) DeepCopyInto(out *PulsarMessaging)

+ type PulsarStateStore struct

+ JavaProvider *PulsarStateStoreJavaProvider

+ ServiceURL string

+ func (in *PulsarStateStore) DeepCopy() *PulsarStateStore

+ func (in *PulsarStateStore) DeepCopyInto(out *PulsarStateStore)

+ type PulsarStateStoreJavaProvider struct

+ ClassName string

+ Config *Config

+ func (in *PulsarStateStoreJavaProvider) DeepCopy() *PulsarStateStoreJavaProvider

+ func (in *PulsarStateStoreJavaProvider) DeepCopyInto(out *PulsarStateStoreJavaProvider)

+ type PythonRuntime struct

+ Py string

+ PyLocation string

+ func (in *PythonRuntime) DeepCopy() *PythonRuntime

+ func (in *PythonRuntime) DeepCopyInto(out *PythonRuntime)

+ type ReconcileAction string

+ const Create

+ const Delete

+ const NoAction

+ const Update

+ const Wait

+ type ResourceCondition struct

+ Action ReconcileAction

+ Condition ResourceConditionType

+ Status metav1.ConditionStatus

+ func (in *ResourceCondition) DeepCopy() *ResourceCondition

+ func (in *ResourceCondition) DeepCopyInto(out *ResourceCondition)

+ type ResourceConditionType string

+ const FunctionReady

+ const HPAReady

+ const ServiceReady

+ const SinkReady

+ const SourceReady

+ const StatefulSetReady

+ type Runtime struct

+ Golang *GoRuntime

+ Java *JavaRuntime

+ Python *PythonRuntime

+ func (in *Runtime) DeepCopy() *Runtime

+ func (in *Runtime) DeepCopyInto(out *Runtime)

+ type SecretRef struct

+ Key string

+ Path string

+ func (in *SecretRef) DeepCopy() *SecretRef

+ func (in *SecretRef) DeepCopyInto(out *SecretRef)

+ type Sink struct

+ Spec SinkSpec

+ Status SinkStatus

+ func (in *Sink) DeepCopy() *Sink

+ func (in *Sink) DeepCopyInto(out *Sink)

+ func (in *Sink) DeepCopyObject() runtime.Object

+ func (r *Sink) Default()

+ func (r *Sink) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Sink) ValidateCreate() error

+ func (r *Sink) ValidateDelete() error

+ func (r *Sink) ValidateUpdate(old runtime.Object) error

+ type SinkList struct

+ Items []Sink

+ func (in *SinkList) DeepCopy() *SinkList

+ func (in *SinkList) DeepCopyInto(out *SinkList)

+ func (in *SinkList) DeepCopyObject() runtime.Object

+ type SinkSpec struct

+ AutoAck *bool

+ ClassName string

+ CleanupSubscription bool

+ ClusterName string

+ DeadLetterTopic string

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ Input InputConf

+ MaxMessageRetry int32

+ MaxReplicas *int32

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs int32

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RetainOrdering bool

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ SinkConfig *Config

+ SinkType string

+ SubscriptionName string

+ SubscriptionPosition SubscribePosition

+ Tenant string

+ Timeout int32

+ VolumeMounts []corev1.VolumeMount

+ func (in *SinkSpec) DeepCopy() *SinkSpec

+ func (in *SinkSpec) DeepCopyInto(out *SinkSpec)

+ type SinkStatus struct

+ Conditions map[Component]ResourceCondition

+ Replicas int32

+ Selector string

+ func (in *SinkStatus) DeepCopy() *SinkStatus

+ func (in *SinkStatus) DeepCopyInto(out *SinkStatus)

+ type Source struct

+ Spec SourceSpec

+ Status SourceStatus

+ func (in *Source) DeepCopy() *Source

+ func (in *Source) DeepCopyInto(out *Source)

+ func (in *Source) DeepCopyObject() runtime.Object

+ func (r *Source) Default()

+ func (r *Source) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Source) ValidateCreate() error

+ func (r *Source) ValidateDelete() error

+ func (r *Source) ValidateUpdate(old runtime.Object) error

+ type SourceList struct

+ Items []Source

+ func (in *SourceList) DeepCopy() *SourceList

+ func (in *SourceList) DeepCopyInto(out *SourceList)

+ func (in *SourceList) DeepCopyObject() runtime.Object

+ type SourceSpec struct

+ ClassName string

+ ClusterName string

+ ForwardSourceMessageProperty *bool

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ MaxReplicas *int32

+ Name string

+ Namespace string

+ Output OutputConf

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ SourceConfig *Config

+ SourceType string

+ Tenant string

+ VolumeMounts []corev1.VolumeMount

+ func (in *SourceSpec) DeepCopy() *SourceSpec

+ func (in *SourceSpec) DeepCopyInto(out *SourceSpec)

+ type SourceStatus struct

+ Conditions map[Component]ResourceCondition

+ Replicas int32

+ Selector string

+ func (in *SourceStatus) DeepCopy() *SourceStatus

+ func (in *SourceStatus) DeepCopyInto(out *SourceStatus)

+ type Stateful struct

+ Pulsar *PulsarStateStore

+ func (in *Stateful) DeepCopy() *Stateful

+ func (in *Stateful) DeepCopyInto(out *Stateful)

+ type SubscribePosition string

+ const Earliest

+ const Latest