Configuration

extensions:
  events:
    bus:
      defaultBroker: "memory"       # default broker for Publish()
      maxRetries: 3
      retryDelay: "5s"
      enableMetrics: true
      enableTracing: false
      bufferSize: 1000              # event channel buffer
      workerCount: 10               # concurrent event workers
      processingTimeout: "30s"

    store:
      type: "memory"                # "memory", "postgres", "mongodb"
      database: ""                  # database connection name (for postgres/mongodb)
      table: "events"               # events table/collection name

    brokers:
      - name: "memory"
        type: "memory"
        enabled: true
        priority: 1

      - name: "nats"
        type: "nats"
        enabled: true
        priority: 2
        config:
          url: "nats://localhost:4222"
          clusterID: "my-cluster"

      - name: "redis"
        type: "redis"
        enabled: false
        priority: 3
        config:
          url: "redis://localhost:6379"

    metrics:
      enabled: true
      publishInterval: "30s"
      enablePerType: true
      enablePerHandler: true

ext := events.NewExtensionWithConfig(events.Config{
    Bus: events.BusConfig{
        DefaultBroker: "memory",
        WorkerCount:   20,
        BufferSize:    5000,
    },
    Store: events.StoreConfig{
        Type:  "memory",
        Table: "events",
    },
    Brokers: []events.BrokerConfig{
        {Name: "memory", Type: "memory", Enabled: true, Priority: 1},
    },
})