pubsub

package
v0.0.0-...-d19fc40 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 29, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package pubsub contains Pub/Sub client wrappers to be able to UT things.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

Client matches the interface exposed by pubsub.Client see https://godoc.org/cloud.google.com/go/pubsub#Client

func NewClient

func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (Client, error)

NewClient creates a new wrapped Pub/Sub client.

type CreateFn

type CreateFn func(ctx context.Context, projectID string, opts ...option.ClientOption) (Client, error)

CreateFn is a factory function to create a Pub/Sub client.

type SubscriptionConfig

type SubscriptionConfig struct {
	Topic               Topic
	AckDeadline         time.Duration
	RetainAckedMessages bool
	RetentionDuration   time.Duration
	Labels              map[string]string
}

SubscriptionConfig re-implements pubsub.SubscriptionConfig to allow us to use a wrapped Topic internally.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL