pubsub

Feb 20, 2026

Changes in this version

+ type Client struct

+ func New(c *pubsub.Client, topic string, subscription string, logger types.Logger, ...) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Init() (*Client, error)

+ func (c *Client) Name() string

+ func (c *Client) Receive(ctx context.Context, sinkCh chan<- *types.FifoQueueItem) error

+ func (c *Client) Send(ctx context.Context, groupID, dedupID, body string) error

+ type Option func(*Options)

+ func WithPubSubClient(client pubsubClient) Option

+ func WithPublisherByteThreshold(n int) Option

+ func WithPublisherCountThreshold(n int) Option

+ func WithPublisherDelayThreshold(d time.Duration) Option

+ func WithSubscriberMaxDurationPerAckExtension(d time.Duration) Option

+ func WithSubscriberMaxExtension(d time.Duration) Option

+ func WithSubscriberMaxOutstandingBytes(n int) Option

+ func WithSubscriberMaxOutstandingMessages(n int) Option

+ func WithSubscriberMinDurationPerAckExtension(d time.Duration) Option

+ func WithSubscriberShutdownTimeout(d time.Duration) Option

+ type Options struct

+ type WebhookHandler struct

+ func NewWebhookHandler(c *pubsub.Client, isOrdered bool, opts ...Option) *WebhookHandler

+ func (c *WebhookHandler) Close()

+ func (c *WebhookHandler) HandleWebhook(ctx context.Context, topic string, data *types.WebhookCallback, ...) error

+ func (c *WebhookHandler) Init(_ context.Context) (*WebhookHandler, error)

+ func (c *WebhookHandler) ShouldHandleWebhook(_ context.Context, target string) bool