Versions in this module Expand all Collapse all v0 v0.1.1 Feb 22, 2026 v0.1.0 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
Go to main page