grpcpubsub

package

v4.4.0 Latest Latest Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 15 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

View Source

const Scheme = "grpc"

Scheme is the URL scheme grpc pubsub registers its URLOpeners under on pubsub.DefaultMux.

This section is empty.

func NewSubscription(path string, opts ...Option) (*pubsub.Subscription, error)

NewSubscription returns a *pubsub.Subscription representing a NATS subscription or NATS queue subscription. The subject is the NATS Subject to subscribe to; for more info, see https://nats.io/documentation/writing_applications/subjects.

func NewTopic(path, pubKey string, opts ...Option) (*pubsub.Topic, error)

NewTopic creates a new in-memory topic.

type Option func(*Options)

func WithContext(ctx context.Context) Option

func WithPublisher(pub Publisher) Option

WithPublisher sets the RPC client

func WithQueue(s string) Option

WithQueue defines the queue used by the subscriber

func WithSubscriber(sub interface{}) Option

WithSubscriber sets the client

type Options struct {
	Context context.Context
	Queue   string
}

type Publisher interface {
	Send(*pb.PublishRequest) error
}

type Subscriber interface {
	Recv() (*pb.SubscribeResponse, error)
}

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

URLOpener opens grpc pubsub URLs like "cells://topic".

The URL's host+path is used as the topic to create or subscribe to.

Query parameters:

ackdeadline: The ack deadline for OpenSubscription, in time.ParseDuration formats. Defaults to 1m.

func (o *URLOpener) OpenSubscriptionURL(ctx context.Context, u *url.URL) (*pubsub.Subscription, error)

OpenSubscriptionURL opens a pubsub.Subscription based on u.

func (o *URLOpener) OpenTopicURL(ctx context.Context, u *url.URL) (*pubsub.Topic, error)

OpenTopicURL opens a pubsub.Topic based on u.

Path	Synopsis
handler