Struct FunctionConfig 

pub struct FunctionConfig {
    pub tenant: String,
    pub namespace: String,
    pub name: String,
    pub class_name: String,
    pub inputs: Vec<String>,
    pub output: String,
    pub runtime: String,
    pub parallelism: i32,
    pub user_config: Option<Value>,
}

Pulsar Functions configuration — the subset of Java’s org.apache.pulsar.common.functions.FunctionConfig that the URL-based register / update calls actually require. The Java type carries ~30 fields (process / k8s runtime tuning, secrets, deadletter topics, …); we expose the load-bearing ones an operator running a pre-compiled JAR needs. Unknown fields on the wire are tolerated by the broker, so adding extra knobs is an additive change later.

tenant / namespace / name are duplicated in the body because the broker re-validates them against the URL path (Java’s WorkerUtils.validateFunctionName). The CLI fills these in from the fully qualified name the operator passes on the command line.

runtime is the string "JAVA", "PYTHON", or "GO" — matches Java’s org.apache.pulsar.common.functions.FunctionConfig.Runtime enum serialised by name.

Fields

tenant: String

Owning tenant.

namespace: String

Owning namespace (bare name, not tenant/namespace).

name: String

Function name (unique within the namespace).

class_name: String

Fully qualified entry-point class name (com.acme.MyFunction for Java; module.fn for Python; main for Go).

inputs: Vec<String>

Input topics the function subscribes to.

output: String

Output topic the function produces to. Empty when the function has no output sink.

runtime: String

Runtime — "JAVA", "PYTHON", or "GO".

parallelism: i32

Number of parallel instances the worker schedules.

user_config: Option<Value>

Optional opaque user-config map passed to the function’s Context#getUserConfigValue. JSON object on the wire.

Trait Implementations

impl Clone for FunctionConfig

fn clone(&self) -> FunctionConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FunctionConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FunctionConfig

fn default() -> FunctionConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FunctionConfig

where FunctionConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FunctionConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.