enats

package

v0.4.2 Latest Latest Go to latest Published: Mar 27, 2024 License: Apache-2.0 Imports: 11 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

Repository

github.com/pme-sh/pmesh

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ToConsumerQueueName(pfx, topic string) string
func ToSubject(topic string) string
func ToTopic(subject string) string
type Client
type Gateway
- func New() (r *Gateway)
- func (r *Gateway) Close(ctx context.Context) (err error)
- func (r *Gateway) Open(ctx context.Context) (err error)

Constants ¶

View Source

const EventStreamPrefix = "ev."

Variables ¶

This section is empty.

Functions ¶

func ToConsumerQueueName ¶

func ToConsumerQueueName(pfx, topic string) string

Given a user-specified topic, return the queue name to use for NATS consumers.

func ToSubject ¶ added in v0.3.2

func ToSubject(topic string) string

Given a user-specified topic, return the subject names to use for NATS consumers/publishers.

func ToTopic ¶

func ToTopic(subject string) string

Given a nats subject, return the user-specified topic.

Types ¶

type Client ¶

type Client struct {
	*nats.Conn
	Jet jetstream.JetStream
}

func (*Client) Consumer ¶

func (r *Client) Consumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (c jetstream.Consumer, err error)

func (*Client) KVStore ¶

func (r *Client) KVStore(ctx context.Context, cfg jetstream.KeyValueConfig) (kv jetstream.KeyValue, err error)

Wrappers

func (*Client) Stream ¶

func (r *Client) Stream(ctx context.Context, cfg jetstream.StreamConfig) (str jetstream.Stream, err error)

type Gateway ¶

type Gateway struct {
	Client
	Server *autonats.Server

	// Internal resources
	PeerKV, SchedulerKV jetstream.KeyValue
	// Global resources for the user
	DefaultKV, ResultKV jetstream.KeyValue

	EventStream jetstream.Stream
	// contains filtered or unexported fields
}

func New ¶

func New() (r *Gateway)

func (*Gateway) Close ¶

func (r *Gateway) Close(ctx context.Context) (err error)

func (*Gateway) Open ¶

func (r *Gateway) Open(ctx context.Context) (err error)

Source Files ¶

View all Source files

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