nats

package
v0.0.0-...-0af3362 Latest Latest
Warning

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

Go to latest
Published: Nov 16, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HttpToNats

func HttpToNats(conn *nats.Conn, handler http.Handler) nats.MsgHandler

func NewAsyncBroker

func NewAsyncBroker(url string) (gear.AsyncBroker, error)

func NewHttpResponse

func NewHttpResponse(conn *nats.Conn, msg *nats.Msg) *httpResponse

func NewSyncBroker

func NewSyncBroker(url string) (gear.SyncBroker, error)

Types

type Gateway

type Gateway interface {
	gear.HttpMux

	Unhandle(pattern string)
}

func NewGateway

func NewGateway(url string, options ...nats.Option) (Gateway, error)

Jump to

Keyboard shortcuts

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