@@ -85,7 +85,6 @@ This design focuses on exporting **Health Events** - hardware and cluster health
8585│ │ (Pluggable Destinations) │ │
8686│ │ │ │
8787│ │ Publish(event) error │ │
88- │ │ PublishBatch(events) error │ │
8988│ └────────────────────────────────────────────────────────────────┘ │
9089│ │ │ │ │
9190│ ↓ ↓ ↓ │
@@ -170,9 +169,6 @@ type EventSink interface {
170169 // Publish sends a single event to the sink
171170 Publish (ctx context.Context , event *CloudEvent) error
172171
173- // PublishBatch sends multiple events atomically (optional)
174- PublishBatch (ctx context.Context , events []*CloudEvent) error
175-
176172 // Close flushes pending events and releases resources
177173 Close (ctx context.Context ) error
178174}
@@ -350,7 +346,6 @@ func transformEntities(entities []*pb.Entity) []map[string]string {
350346}
351347```
352348
353- ** Note:** Platform connector already enriches metadata (chassis_serial, providerID, topology labels); exporter passes through without modification.
354349
355350### 3. Event Stream Pipeline
356351
@@ -380,9 +375,6 @@ type HTTPPublisher interface {
380375 // Publish single event
381376 Publish (ctx context.Context , event CloudEvent ) error
382377
383- // Publish batch of events
384- PublishBatch (ctx context.Context , events []CloudEvent ) error
385-
386378 // Close publisher and flush pending events
387379 Close (ctx context.Context ) error
388380}
@@ -394,10 +386,6 @@ type HTTPPublisherConfig struct {
394386 RetryBackoff time.Duration // Initial backoff duration
395387 Timeout time.Duration // Request timeout
396388
397- // Batching configuration
398- BatchSize int // Events per batch
399- BatchTimeout time.Duration // Max time to wait for batch
400-
401389 // Authentication
402390 OIDCTokenProvider TokenProvider // OIDC token provider
403391
@@ -426,7 +414,6 @@ On first deployment (when no resume token exists), the exporter automatically ex
426414type BackfillConfig struct {
427415 MaxAge time.Duration // How far back to backfill (e.g., 24h, 7d, 30d)
428416 MaxEvents int // Optional: safety limit
429- BatchSize int // Events per batch
430417 RateLimit int // Events per second
431418}
432419```
@@ -461,7 +448,6 @@ scopes = ["events:write"]
461448# Optional: limit how far back to backfill
462449# max_age = "720h" # Uncomment to limit backfill window (24h, 168h=7d, 720h=30d)
463450# max_events = 1000000 # Optional: safety limit
464- batch_size = 500
465451rate_limit = 1000 # events per second, don't overwhelm sink
466452
467453[datastore ]
0 commit comments