jetstream

package module

v0.0.0-...-0b0f5e7 Latest Latest Go to latest Published: Jan 7, 2022 License: MIT Imports: 4 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/archaron/jetstream

Links

Open Source Insights

README ¶

Jetstream NATS Module for Helium

GitHub

Module provides you with the following things:

*nats.Conn represents a bare connection to a nats-server. It can send and receive []byte payloads
nats.JetStreamContext represents a streaming context. It can Publish and Subscribe to messages within the NATS JetStream cluster.

Documentation ¶

Index ¶

Constants
Variables
func NewStreamer(bus *Client, opts StreamerConfig) (nats.JetStreamContext, error)
type Client
- func NewConnection(opts *Config) (bus *Client, err error)
type Config
- func NewDefaultConfig(v *viper.Viper) (*Config, error)
type Error
- func (e Error) Error() string
type StreamerConfig
- func NewDefaultStreamerConfig(v *viper.Viper) StreamerConfig

Constants ¶

View Source

const (

	// ErrEmptyConfig when given empty options
	ErrEmptyConfig = Error("nats empty config")
)

Variables ¶

View Source

var (
	// Module is default Nats client
	Module = module.Module{
		{Constructor: NewDefaultConfig},
		{Constructor: NewConnection},
		{Constructor: NewDefaultStreamerConfig},
		{Constructor: NewStreamer},
	}
)

Functions ¶

func NewStreamer ¶

func NewStreamer(bus *Client, opts StreamerConfig) (nats.JetStreamContext, error)

NewStreamer is jetstream client

Types ¶

type Client ¶

type Client = nats.Conn

Client alias

func NewConnection ¶

func NewConnection(opts *Config) (bus *Client, err error)

NewConnection of nats client

type Config ¶

type Config = nats.Options

Config alias

func NewDefaultConfig ¶

func NewDefaultConfig(v *viper.Viper) (*Config, error)

type Error ¶

type Error string

Error is constant error

func (Error) Error ¶

func (e Error) Error() string

Error returns error message string

type StreamerConfig ¶

type StreamerConfig = []nats.JSOpt

func NewDefaultStreamerConfig ¶

func NewDefaultStreamerConfig(v *viper.Viper) StreamerConfig

Source Files ¶

View all Source files

jetstream.go

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