gcppubsub

Overview ¶

Package gcppubsub provides a Google Cloud Pub/Sub driver for unimq.

To use this driver, import it in your application:

import (
    "github.com/teamlify-devx/unimq"
    _ "github.com/teamlify-devx/unimq/drivers/gcppubsub"
)

Then open a connection:

client, err := unimq.Open(ctx, "gcp_pubsub", &unimq.Config{
    ClientID: "my-project-id",
})

Configuration options via Extra map:

• "credentials_file": Path to service account credentials JSON file
• "subscription.ack_deadline": Ack deadline in seconds (default: 10)
• "subscription.create": Auto-create subscription if not exists (default: true)
• "publisher.batch_size": Maximum messages per batch
• "publisher.delay_threshold": Delay threshold in milliseconds