event

package

v0.1.5 Latest Latest Go to latest Published: Mar 31, 2025 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

View Source

const NATS_RECONNECT_BUF_SIZE = 5 * 1024 * 1024

This section is empty.

func Publish[T any](nb *NatsBus, msg T, topic string) error

Not a method due to Golang limitations on generics there, so we just pass the bus as a parameter.

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

func NewNatsBus(logger hclog.Logger) *NatsBus

func (nb *NatsBus) Close()

func (nb *NatsBus) Connect(server string) error