publisher

package

v0.0.0-...-c1b7731 Latest Latest Go to latest Published: Mar 14, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package publisher contains the code to talk to Google Pub/Sub.

This section is empty.

This section is empty.

This section is empty.

type Option interface {
	// contains filtered or unexported methods
}

An Option provides additional configuration to the Publisher.

func WithHTTPCounter(l *latch.Counter) Option

WithHTTPCounter uses the given counter to signal if there are any in-flight http requests.

func WithHTTPMux(m *http.ServeMux, pathPrefix string) Option

WithHTTPMux will register handlers in the given ServeMux to accept incoming connections and publish them.

func WithSharedKeys(keys []string) Option

WithSharedKeys provides a limited degree of authentication between the bridge server and the CDC client.

func WithTopicPrefix(prefix string) Option

WithTopicPrefix will prepend the given prefix to the table name.

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

A Publisher is used to manage Topic instances.

func New(client *pubsub.Client, options ...Option) *Publisher

New constructs a new Publisher around the given Client.

func (p *Publisher) Publish(ctx context.Context, table string, data []byte, attrs map[string]string) (*pubsub.PublishResult, error)

Publish will send the given message and attributes to the Pub/Sub endpoint.