nats

Documentation

Index

• Variables
• type NATSServer
  • func NewNATSServer(ctx context.Context, logger nserver.Logger, opts ...NatsOption) (*NATSServer, error)
  • func (n *NATSServer) ListenAndServe() (err error)
  • func (n *NATSServer) Shutdown()
• type NatsOption
  • func AllowNonTLS(v bool) NatsOption
  • func ClusterID(clusterID string) NatsOption
  • func Host(url string) NatsOption
  • func Port(port int) NatsOption
  • func StoreDir(StoreDir string) NatsOption
  • func TLSConfig(c *tls.Config) NatsOption

Variables

var NATSListenAndServeLoopTimer = 1 * time.Second

Types

type NATSServer

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

func NewNATSServer

func NewNATSServer(ctx context.Context, logger nserver.Logger, opts ...NatsOption) (*NATSServer, error)

func (*NATSServer) ListenAndServe

func (n *NATSServer) ListenAndServe() (err error)

ListenAndServe runs the NATSServer in a blocking way until the server is shutdown or an error occurs

func (*NATSServer) Shutdown

func (n *NATSServer) Shutdown()

type NatsOption

type NatsOption func(*nserver.Options)

NatsOption configures the nats server

func AllowNonTLS

func AllowNonTLS(v bool) NatsOption

AllowNonTLS sets the allow non tls options for the nats server

func ClusterID

func ClusterID(clusterID string) NatsOption

ClusterID sets the name for the nats cluster

func Host

func Host(url string) NatsOption

Host sets the host URL for the nats server

func Port

func Port(port int) NatsOption

Port sets the host URL for the nats server

func StoreDir

func StoreDir(StoreDir string) NatsOption

StoreDir sets the folder for persistence

func TLSConfig

func TLSConfig(c *tls.Config) NatsOption

TLSConfig sets the tls config for the nats server