pubsub

package

v1.6.0 Latest Latest Go to latest Published: Feb 10, 2026 License: AGPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func WithoutCancel(ctx context.Context) context.Context

type Client struct {
	// contains filtered or unexported fields
}

func New(opt ...OptionFunc) *Client

func (c *Client) Close()

func (c *Client) Topic(id string) *Topic

type Event interface {
	Attributes() map[string]string
}

type OptionFunc = func(option *options)

func WithProject(project string) OptionFunc

func WithRetries(retries int) OptionFunc

func WithRetryDelay(retryDelay time.Duration) OptionFunc

type Topic struct {
	// contains filtered or unexported fields
}

func (t *Topic) Publish(ctx context.Context, value interface{})

func (t *Topic) PublishSync(ctx context.Context, value interface{}) error