nats

Documentation

Index

• Variables
• type AddStreamOptions
• type Client
• type ClientOption
  • func WithEventListeners(listeners ...EventListener) ClientOption
  • func WithLogger(logger *slog.Logger) ClientOption
  • func WithNatsUrl(url string) ClientOption
• type DefaultClient
  • func NewDefaultClient(opts ...ClientOption) (*DefaultClient, error)
  • func (c *DefaultClient) AddStream(ctx context.Context, opts *AddStreamOptions) error
  • func (c *DefaultClient) Close() error
  • func (c *DefaultClient) Monitor(_ context.Context) error
  • func (c *DefaultClient) Name() string
  • func (c *DefaultClient) Publish(ctx context.Context, opts *PublishOptions) error
• type EventListener
  • func OnMsgFailedEvent(onMsgFailedEvent func(subj string, duration time.Duration)) EventListener
  • func OnMsgPublishedEvent(onMsgPublishedEvent func(subj string, duration time.Duration)) EventListener
• type PublishOptions

Variables

var (
	ErrClientDisconnected = errors.New("could not reach nats: connection closed")
)

Types

type AddStreamOptions

type AddStreamOptions struct {
	StreamName string
}

type Client

type Client interface {
	server.NamedMonitor
	io.Closer

	AddStream(ctx context.Context, opts *AddStreamOptions) error
	Publish(ctx context.Context, opts *PublishOptions) error
}

type ClientOption

type ClientOption func(*DefaultClient)

func WithEventListeners

func WithEventListeners(listeners ...EventListener) ClientOption

func WithLogger

func WithLogger(logger *slog.Logger) ClientOption

func WithNatsUrl

func WithNatsUrl(url string) ClientOption

type DefaultClient

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

func NewDefaultClient

func NewDefaultClient(opts ...ClientOption) (*DefaultClient, error)

func (*DefaultClient) AddStream

func (c *DefaultClient) AddStream(ctx context.Context, opts *AddStreamOptions) error

func (*DefaultClient) Close

func (c *DefaultClient) Close() error

func (*DefaultClient) Monitor

func (c *DefaultClient) Monitor(_ context.Context) error

func (*DefaultClient) Name

func (c *DefaultClient) Name() string

func (*DefaultClient) Publish

func (c *DefaultClient) Publish(ctx context.Context, opts *PublishOptions) error

type EventListener

type EventListener func(*DefaultClient)

func OnMsgFailedEvent

func OnMsgFailedEvent(onMsgFailedEvent func(subj string, duration time.Duration)) EventListener

func OnMsgPublishedEvent

func OnMsgPublishedEvent(onMsgPublishedEvent func(subj string, duration time.Duration)) EventListener

type PublishOptions

type PublishOptions struct {
	Subj  string
	MsgId string
	Data  []byte
}