apiconnectors

Documentation

Index

• type NatsConnector
  • func NatsInit(controllerData apiresources.ControllerData, config config.Config) (conn *NatsConnector, err error)
  • func (conn *NatsConnector) Close() (err error)

Types

type NatsConnector

type NatsConnector struct {
	ConnPtr *nats.Conn
	SubPtr  *nats.Subscription
}

Connector for processing requests from NATS broker

func NatsInit

func NatsInit(controllerData apiresources.ControllerData, config config.Config) (conn *NatsConnector, err error)

Create ant init instance of NATS connector

func (*NatsConnector) Close

func (conn *NatsConnector) Close() (err error)