events

package
v1.6.2 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2026 License: MIT Imports: 1 Imported by: 0

Documentation

Overview

Package events publishes events over the "events" NATS connection.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Publisher

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

Publisher publishes events to NATS subjects.

func NewPublisher

func NewPublisher(conn *nats.Conn) *Publisher

NewPublisher provides the publisher on the events connection, which inject builds with the health and log plugins. @Provide(index=0) @Inject(index=0, name=events, plugins=[health, log])

func (*Publisher) Closed

func (p *Publisher) Closed() bool

Closed reports whether the connection was closed.

func (*Publisher) Publish

func (p *Publisher) Publish(subject string, data []byte) error

Publish sends data to subject and waits until the server has it.

Jump to

Keyboard shortcuts

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