update pf proto

Author: freeznet

.dockerignore.protogen

@@ -0,0 +1,50 @@
+# Git files
+.git
+.gitignore
+
+# Documentation
+*.md
+docs/
+
+# Build artifacts
+bin/
+artifacts/
+dist/
+
+# IDE files
+.vscode/
+.idea/
+*.swp
+*.swo
+
+# OS files
+.DS_Store
+Thumbs.db
+
+# Docker files (except the ones we need)
+Dockerfile
+*.dockerfile
+.dockerignore
+
+# Test files
+*_test.go
+testdata/
+
+# CI/CD
+.github/
+.travis.yml
+.circleci/
+
+# Other unnecessary files for protobuf generation
+charts/
+config/
+hack/
+images/
+manifests/
+mesh-worker-service/
+tools/
+LICENSE
+install.sh
+bump_version.sh
+*.sh
+!controllers/proto/generate.sh 

Dockerfile.protogen

@@ -0,0 +1,42 @@
+# Build environment for protobuf generation
+# Requirements: protoc 3.17.3, protoc-gen-go v1.3.5
+# Using Debian base to avoid musl/glibc compatibility issues with protoc x86_64 binaries
+FROM golang:1.24.2
+
+# Install system dependencies
+RUN apt-get update && apt-get install -y \
+    bash \
+    curl \
+    unzip \
+    git \
+    make \
+    && rm -rf /var/lib/apt/lists/*
+
+# Set environment variables
+ENV PROTOC_VERSION=3.17.3
+ENV PROTOC_GEN_GO_VERSION=v1.3.5
+
+# Install protoc 3.17.3
+RUN set -eux; \
+    PROTOC_ZIP="protoc-${PROTOC_VERSION}-linux-x86_64.zip"; \
+    curl -OL "https://github.com/protocolbuffers/protobuf/releases/download/v${PROTOC_VERSION}/${PROTOC_ZIP}"; \
+    unzip -o "$PROTOC_ZIP" -d /usr/local; \
+    rm -f "$PROTOC_ZIP"
+
+# Install protoc-gen-go 1.25.0
+RUN go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
+
+# Verify installations
+RUN protoc --version
+
+# Set working directory
+WORKDIR /workspace
+
+# Copy the entire project
+COPY . .
+
+# Make sure generate.sh is executable
+RUN chmod +x controllers/proto/generate.sh
+
+# Default command: run the generate script
+CMD ["/workspace/controllers/proto/generate.sh", "/workspace"]

README-protogen.md

@@ -0,0 +1,71 @@
+# Protobuf Generation Docker Environment
+
+This Docker environment contains the tools and environment required to generate function-mesh protobuf Go definitions.
+
+## Requirements
+
+- protoc: v3.17.3
+- protoc-gen-go: v1.25.0
+- protoc-gen-go-grpc: v1.0.0
+- Go: 1.24.2+
+
+**Note**: This image uses a Debian base (not Alpine) to ensure compatibility with the protoc x86_64 binary, which is compiled for glibc rather than musl libc.
+
+## Build and Usage
+
+### 1. Build Docker Image
+
+```bash
+docker build -f Dockerfile.protogen -t function-mesh-protogen .
+```
+
+### 2. Run Protobuf Generation
+
+```bash
+# Run container and generate protobuf files
+docker run --rm -v $(pwd):/workspace function-mesh-protogen
+
+# Or run interactively for debugging
+docker run --rm -it -v $(pwd):/workspace function-mesh-protogen bash
+```
+
+### 3. Manual Script Execution
+
+If you need manual control over the generation process:
+
+```bash
+# Enter container
+docker run --rm -it -v $(pwd):/workspace function-mesh-protogen bash
+
+# Execute manually inside container
+cd /workspace
+./controllers/proto/generate.sh /workspace
+```
+
+## Generated Files
+
+The script will update the following files:
+- `controllers/proto/Function.pb.go`
+
+## Environment Verification
+
+You can verify tool versions inside the container:
+
+```bash
+protoc --version              # Should show libprotoc 3.17.3
+go version                   # Should show go1.24.2+
+```
+
+## Troubleshooting
+
+If you encounter permission issues, ensure the generate.sh script has execute permissions:
+
+```bash
+chmod +x controllers/proto/generate.sh
+```
+
+If you encounter protoc-gen-go not found issues, ensure $GOPATH/bin is in PATH:
+
+```bash
+export PATH=$PATH:$(go env GOPATH)/bin
+``` 

api/compute/v1alpha1/common.go

@@ -315,6 +315,16 @@ type ProducerConfig struct {
 	CryptoConfig                       *CryptoConfig   `json:"cryptoConfig,omitempty"`
 	BatchBuilder                       string          `json:"batchBuilder,omitempty"`
 	CompressionType                    CompressionType `json:"compressionType,omitempty"`
+	BatchingConfig                     *BatchingConfig `json:"batchingConfig,omitempty"`
+}
+
+type BatchingConfig struct {
+	Enabled                                          bool   `json:"enabled,omitempty"`
+	BatchingMaxPublishDelayMs                        int32  `json:"batchingMaxPublishDelayMs,omitempty"`
+	RoundRobinRouterBatchingPartitionSwitchFrequency int32  `json:"roundRobinRouterBatchingPartitionSwitchFrequency,omitempty"`
+	BatchingMaxMessages                              int32  `json:"batchingMaxMessages,omitempty"`
+	BatchingMaxBytes                                 int32  `json:"batchingMaxBytes,omitempty"`
+	BatchBuilder                                     string `json:"batchBuilder,omitempty"`
 }
 
 type CryptoConfig struct {