nats

Documentation

Index

• type Builder
• type ConnectionBuilder
  • func NewBuilder(url, name string, opts ...natsio.Option) (*ConnectionBuilder, error)
  • func (b *ConnectionBuilder) Build() Interface
• type Interface

Types

type Builder

type Builder interface {
	Build() Interface
}

type ConnectionBuilder

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

func NewBuilder

func NewBuilder(url, name string, opts ...natsio.Option) (*ConnectionBuilder, error)

func (*ConnectionBuilder) Build

func (b *ConnectionBuilder) Build() Interface

type Interface

type Interface interface {
	// Connect connects to NATS and returns an error if it cannot connect.
	// It also registers both the connect and disconnect handlers.
	Connect(handler natsio.ConnHandler, errorHandler natsio.ConnErrHandler) error

	// Disconnect disconnects the NATS connection.
	Disconnect()
}