http

Documentation

Index

• func HandleHealthcheck() fasthttp.RequestHandler
• func HandlePublish(natsPool *NatsConnPool) fasthttp.RequestHandler
• func HandleStatus() fasthttp.RequestHandler
• func HandleVersion() fasthttp.RequestHandler
• func Handler(natsUrl string, lg *logger.HttpLogger) fasthttp.RequestHandler
• func WebsocketHandleSubscribe(natsPool *NatsConnPool) fasthttp.RequestHandler
• func WebsocketHandleSubscribeWithQueue(natsPool *NatsConnPool) fasthttp.RequestHandler
• func WebsocketSubscribe(rctx *fasthttp.RequestCtx, nc *nats.Conn, topic string) error
• func WebsocketSubscribeWithQueue(rctx *fasthttp.RequestCtx, nc *nats.Conn, topic, group string) error
• type NatsConnFunc
  • func ConnFunc(url string, opts []nats.Option) NatsConnFunc
• type NatsConnPool
  • func NewNatsConnPool(url string, customOptions ...nats.Option) *NatsConnPool
  • func (p *NatsConnPool) Get() (*nats.Conn, error)
  • func (p *NatsConnPool) Put(nc *nats.Conn)

Functions

func HandleHealthcheck

func HandleHealthcheck() fasthttp.RequestHandler

func HandlePublish

func HandlePublish(natsPool *NatsConnPool) fasthttp.RequestHandler

func HandleStatus

func HandleStatus() fasthttp.RequestHandler

func HandleVersion

func HandleVersion() fasthttp.RequestHandler

func Handler

func Handler(natsUrl string, lg *logger.HttpLogger) fasthttp.RequestHandler

func WebsocketHandleSubscribe

func WebsocketHandleSubscribe(natsPool *NatsConnPool) fasthttp.RequestHandler

func WebsocketHandleSubscribeWithQueue

func WebsocketHandleSubscribeWithQueue(natsPool *NatsConnPool) fasthttp.RequestHandler

func WebsocketSubscribe

func WebsocketSubscribe(rctx *fasthttp.RequestCtx, nc *nats.Conn, topic string) error

func WebsocketSubscribeWithQueue

func WebsocketSubscribeWithQueue(rctx *fasthttp.RequestCtx, nc *nats.Conn, topic, group string) error

Types

type NatsConnFunc

type NatsConnFunc func() (*nats.Conn, error)

func ConnFunc

func ConnFunc(url string, opts []nats.Option) NatsConnFunc

type NatsConnPool

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

func NewNatsConnPool

func NewNatsConnPool(url string, customOptions ...nats.Option) *NatsConnPool

func (*NatsConnPool) Get

func (p *NatsConnPool) Get() (*nats.Conn, error)

func (*NatsConnPool) Put

func (p *NatsConnPool) Put(nc *nats.Conn)