README
¶
embedded-nats
Start NATS server in a goroutine
Documentation
¶
Overview ¶
enats package provides embedded NATS server that starts in a goroutine on localhost. Useful for testing inter-service communication.
Copyright 2020 KaaIoT Technologies, LLC ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EmbeddedNATS ¶
type EmbeddedNATS struct {
Port int
Conn *nats.Conn
// contains filtered or unexported fields
}
EmbeddedNATS combines an embedded NATS server and NATS client connected to it that can be used for testing inter-service communication.
func NewEmbeddedNATS ¶
func NewEmbeddedNATS() (*EmbeddedNATS, error)
NewEmbeddedNATS creates a new embedded NATS server bound to a randomly chosen free localhost port. One of the return parameters is always nil.
func (*EmbeddedNATS) Start ¶
func (n *EmbeddedNATS) Start() error
Start the embedded NATS server in a separate goroutine and connect the Conn to it.
func (*EmbeddedNATS) Stop ¶
func (n *EmbeddedNATS) Stop()
Stop disconnects the NATS client and shuts down the embedded NATS server.
Source Files