Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1alpha1

package

Go to main page

Versions in this module

v0

v0.27.2

Apr 1, 2026

v0.27.1

Mar 24, 2026

v0.27.1-rc-4

Mar 24, 2026

v0.27.1-rc-3

Mar 24, 2026

v0.27.1-rc-2

Mar 24, 2026

v0.27.1-rc-1

Mar 24, 2026

v0.27.0

Mar 23, 2026

Changes in this version

+ const BatchSourceClass

+ const BatchSourceClassNameKey

+ const BatchSourceConfigKey

+ const FunctionComponent

+ const SinkComponent

+ const SourceComponent

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = GroupVersion

+ type AuthConfig struct

+ GenericAuth *GenericAuth

+ OAuth2Config *OAuth2Config

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

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

+ type BackendConfig struct

+ Spec BackendConfigSpec

+ Status BackendConfigStatus

+ func (in *BackendConfig) DeepCopy() *BackendConfig

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

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

+ type BackendConfigList struct

+ Items []BackendConfig

+ func (in *BackendConfigList) DeepCopy() *BackendConfigList

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

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

+ type BackendConfigSpec struct

+ AutoUpdate bool

+ Env map[string]string

+ Name string

+ Pod *PodPolicy

+ func (in *BackendConfigSpec) DeepCopy() *BackendConfigSpec

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

+ type BackendConfigStatus struct

+ func (in *BackendConfigStatus) DeepCopy() *BackendConfigStatus

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

+ type BatchSourceConfig struct

+ DiscoveryTriggererClassName string

+ DiscoveryTriggererConfig *Config

+ func (in *BatchSourceConfig) DeepCopy() *BatchSourceConfig

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

+ type BuiltinHPARule string

+ const AverageUtilizationCPUPercent20

+ const AverageUtilizationCPUPercent50

+ const AverageUtilizationCPUPercent80

+ const AverageUtilizationMemoryPercent20

+ const AverageUtilizationMemoryPercent50

+ const AverageUtilizationMemoryPercent80

+ type Component string

+ const HPA

+ const Service

+ const StatefulSet

+ const VPA

+ type CompressionType string

+ const LZ4

+ const NONE

+ const SNAPPY

+ const ZLIB

+ const ZSTD

+ 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 FormatType string

+ const JSON

+ const TEXT

+ type Function struct

+ Spec FunctionSpec

+ Status FunctionStatus

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

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

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

+ 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

+ Condition *ResourceCondition

+ FunctionConditions map[string]ResourceCondition

+ ObservedGeneration int64

+ 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

+ CleanupImage string

+ CleanupSubscription bool

+ ClusterName string

+ DeadLetterTopic string

+ DownloaderImage string

+ FilebeatImage string

+ ForwardSourceMessageProperty *bool

+ FuncConfig *Config

+ Image string

+ ImageHasPulsarctl bool

+ ImageHasWget bool

+ ImagePullPolicy corev1.PullPolicy

+ Input InputConf

+ LogTopic string

+ LogTopicAgent LogTopicAgent

+ MaxMessageRetry int32

+ MaxPendingAsyncRequests *int32

+ MaxReplicas *int32

+ MinReplicas *int32

+ Name string

+ Namespace string

+ Output OutputConf

+ PersistentVolumeClaimRetentionPolicy *appsv1.StatefulSetPersistentVolumeClaimRetentionPolicy

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ PulsarPackageService *PulsarMessaging

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ ShowPreciseParallelism bool

+ SinkConfig *SinkConnectorSpec

+ SkipToLatest bool

+ SourceConfig *SourceConnectorSpec

+ StateConfig *Stateful

+ SubscriptionName string

+ SubscriptionPosition SubscribePosition

+ Tenant string

+ Timeout int32

+ VolumeClaimTemplates []corev1.PersistentVolumeClaim

+ VolumeMounts []corev1.VolumeMount

+ WindowConfig *WindowConfig

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

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

+ type FunctionStatus struct

+ Conditions map[Component]ResourceCondition

+ GlobalBackendConfigRevision string

+ NamespacedBackendConfigRevision string

+ ObservedGeneration int64

+ PendingChange string

+ Replicas int32

+ Selector string

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

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

+ type GenericAuth struct

+ ClientAuthenticationParameters string

+ ClientAuthenticationPlugin string

+ func (in *GenericAuth) DeepCopy() *GenericAuth

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

+ type GenericRuntime struct

+ FunctionFile string

+ FunctionFileLocation string

+ Language string

+ func (in *GenericRuntime) DeepCopy() *GenericRuntime

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

+ type GoRuntime struct

+ Go string

+ GoLocation string

+ Log *RuntimeLogConfig

+ 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 JavaLog4JConfigFileType string

+ const XML

+ const YAML

+ type JavaRuntime struct

+ EntryClass *string

+ ExtraDependenciesDir string

+ InstancePath *string

+ Jar string

+ JarLocation string

+ JavaOpts []string

+ Log *RuntimeLogConfig

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

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

+ type Liveness struct

+ FailureThreshold int32

+ InitialDelaySeconds int32

+ PeriodSeconds int32

+ SuccessThreshold int32

+ func (in *Liveness) DeepCopy() *Liveness

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

+ 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 LogTopicAgent string

+ const RUNTIME

+ const SIDECAR

+ type Messaging struct

+ Pulsar *PulsarMessaging

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

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

+ 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 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 *autov2.HorizontalPodAutoscalerBehavior

+ AutoScalingMetrics []autov2.MetricSpec

+ BuiltinAutoscaler []BuiltinHPARule

+ DisableDefaultAffinity bool

+ Env []corev1.EnvVar

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ Labels map[string]string

+ Liveness *Liveness

+ NodeSelector map[string]string

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Sidecars []corev1.Container

+ TerminationGracePeriodSeconds *int64

+ Tolerations []corev1.Toleration

+ VPA *VPASpec

+ Volumes []corev1.Volume

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

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

+ type ProcessGuarantee string

+ const AtleastOnce

+ const AtmostOnce

+ const EffectivelyOnce

+ const Manual

+ type ProducerConfig struct

+ BatchBuilder string

+ CompressionType CompressionType

+ CryptoConfig *CryptoConfig

+ MaxPendingMessages int32

+ MaxPendingMessagesAcrossPartitions int32

+ UseThreadLocalProducers bool

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

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

+ type PulsarMessaging struct

+ AuthConfig *AuthConfig

+ AuthSecret string

+ CleanupAuthConfig *AuthConfig

+ PulsarConfig string

+ TLSConfig *PulsarTLSConfig

+ 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 PulsarTLSConfig struct

+ AllowInsecure bool

+ CertSecretKey string

+ CertSecretName string

+ Enabled bool

+ HostnameVerification bool

+ 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 PythonRuntime struct

+ Log *RuntimeLogConfig

+ 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 CreateCondition(condType ResourceConditionType, status metav1.ConditionStatus, ...) ResourceCondition

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

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

+ func (rc *ResourceCondition) SetCondition(condition ResourceConditionType, action ReconcileAction, ...)

+ type ResourceConditionType string

+ const FunctionReady

+ const HPAReady

+ const MeshReady

+ const Orphaned

+ const ServiceReady

+ const SinkReady

+ const SourceReady

+ const StatefulSetReady

+ const VPAReady

+ type Runtime struct

+ GenericRuntime *GenericRuntime

+ Golang *GoRuntime

+ Java *JavaRuntime

+ Python *PythonRuntime

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

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

+ type RuntimeLogConfig struct

+ Format *FormatType

+ JavaLog4JConfigFileType *JavaLog4JConfigFileType

+ Level LogLevel

+ LogConfig *LogConfig

+ RotatePolicy *TriggeringPolicy

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

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

+ 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

+ type SinkConnectorSpec struct

+ ClassName string

+ Configs *Config

+ SinkType string

+ TypeClassName string

+ func (in *SinkConnectorSpec) DeepCopy() *SinkConnectorSpec

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

+ 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

+ CleanupImage string

+ CleanupSubscription bool

+ ClusterName string

+ DeadLetterTopic string

+ DownloaderImage string

+ FilebeatImage string

+ Image string

+ ImageHasPulsarctl bool

+ ImageHasWget bool

+ ImagePullPolicy corev1.PullPolicy

+ Input InputConf

+ LogTopic string

+ LogTopicAgent LogTopicAgent

+ MaxMessageRetry int32

+ MaxReplicas *int32

+ MinReplicas *int32

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs int32

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ PulsarPackageService *PulsarMessaging

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ ShowPreciseParallelism bool

+ SinkConfig *Config

+ SinkType string

+ StateConfig *Stateful

+ 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

+ GlobalBackendConfigRevision string

+ NamespacedBackendConfigRevision string

+ ObservedGeneration int64

+ PendingChange string

+ 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

+ type SourceConnectorSpec struct

+ BatchSourceConfig *BatchSourceConfig

+ ClassName string

+ Configs *Config

+ SourceType string

+ TypeClassName string

+ func (in *SourceConnectorSpec) DeepCopy() *SourceConnectorSpec

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

+ 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

+ BatchSourceConfig *BatchSourceConfig

+ ClassName string

+ CleanupImage string

+ ClusterName string

+ DownloaderImage string

+ FilebeatImage string

+ ForwardSourceMessageProperty *bool

+ Image string

+ ImageHasPulsarctl bool

+ ImageHasWget bool

+ ImagePullPolicy corev1.PullPolicy

+ LogTopic string

+ LogTopicAgent LogTopicAgent

+ MaxReplicas *int32

+ MinReplicas *int32

+ Name string

+ Namespace string

+ Output OutputConf

+ Pod PodPolicy

+ ProcessingGuarantee ProcessGuarantee

+ PulsarPackageService *PulsarMessaging

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RuntimeFlags string

+ SecretsMap map[string]SecretRef

+ ShowPreciseParallelism bool

+ SourceConfig *Config

+ SourceType string

+ StateConfig *Stateful

+ Tenant string

+ VolumeMounts []corev1.VolumeMount

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

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

+ type SourceStatus struct

+ Conditions map[Component]ResourceCondition

+ GlobalBackendConfigRevision string

+ NamespacedBackendConfigRevision string

+ ObservedGeneration int64

+ PendingChange string

+ 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

+ type TriggeringPolicy string

+ const SizedPolicyWith100MB

+ const SizedPolicyWith10MB

+ const SizedPolicyWith50MB

+ const TimedPolicyWithDaily

+ const TimedPolicyWithMonthly

+ const TimedPolicyWithWeekly

+ type VPASpec struct

+ ResourcePolicy *vpav1.PodResourcePolicy

+ UpdatePolicy *vpav1.PodUpdatePolicy

+ func (in *VPASpec) DeepCopy() *VPASpec

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

+ type WindowConfig struct

+ ActualWindowFunctionClassName string

+ LateDataTopic string

+ MaxLagMs *int64

+ ProcessingGuarantees WindowProcessGuarantee

+ SlidingIntervalCount *int32

+ SlidingIntervalDurationMs *int64

+ TimestampExtractorClassName *string

+ WatermarkEmitIntervalMs *int64

+ WindowLengthCount *int32

+ WindowLengthDurationMs *int64

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

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

+ type WindowProcessGuarantee string

v0.27.0-rc-3

Mar 23, 2026

v0.27.0-rc-2

Mar 23, 2026

Other modules containing this package

github.com/streamnative/function-mesh