README
¶
Jrpc2 NATS Channel
Status: EXPERIMENTAL
Package natschannel provides an implementation of the
jrpc2 module's
Channel
interface using NATS as the transport.
Documentation
Full go doc style documentation for the project can be viewed online without
installing this package by using the excellent GoDoc site here:
http://godoc.org/github.com/41north/natschannel.go
You can also view the documentation locally once the package is installed with
the godoc tool by running godoc -http=":6060" and pointing your browser to
http://localhost:6060/pkg/github.com/41north/natschannel.go
Installation
$ go get -u github.com/41north/natschannel.go
Add this import line to the file you're working in:
import "github.com/41north/natschannel.go"
Quick Start
// connects to the nats server and binds the channel to the 'foo.bar' subject
channel, err := natschannel.Dial("nats://localhost:4222", "foo.bar")
// wraps an existing nats connection and binds the channel to the 'foo.bar' subject
channel, err := natschannel.New(conn, "foo.bar")
License
natschannel.go is licensed under the Apache 2.0 License
Contact
If you want to get in touch drop us an email at [email protected]
Documentation
¶
Index ¶
Examples ¶
Constants ¶
const (
DefaultInboxSize = 256
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
Channel implements the jrpc2 Channel interface over a NATS connection.
func Dial ¶
Dial dials the specified nats url ("nats://...") and binds it to the provided subject with the given options.
Example ¶
channel, err := natschannel.Dial("nats://localhost:4222", "foo.bar")
if err != nil {
panic(err)
}
err = channel.Close()
func New ¶
New wraps the given nats.Conn to implement the Channel interface.
Example ¶
conn, err := nats.Connect("nats://localhost:4222")
if err != nil {
panic(err)
}
channel, err := natschannel.New(conn, "foo.bar")
if err != nil {
panic(err)
}
err = channel.Close()
func (*Channel) Close ¶
Close implements the corresponding method of the Channel interface. Any active subscriptions are drained, the inbox channel closed and then the connection closed.
type Option ¶
Option is a builder function for modifying Options.
func InboxSize ¶
InboxSize specifies the size of the msg inbox channel used for receiving responses.
func NatsOptions ¶
NatsOptions allows for passing nats.Option to the nats.Conn that is being dialed.
type Options ¶
Options represents a collection of options used for controlling how nats.Conn are created and how the resultant Channel is bound to the nats.Conn.
func DefaultOptions ¶
func DefaultOptions() Options
DefaultOptions returns the default options for the Channel.
Source Files