natsdriver

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, conn *nats.Conn, opts ...Option) (*Client, error)
  • func (client *Client) Close(ctx context.Context) error
  • func (client *Client) Subscribe(ctx context.Context, subject string) (*pubsub.Subscription, error)
• type Config
• type Option

Types

type Client

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

Client handles the subscriptions to NATS subjects

func NewClient

func NewClient(ctx context.Context, conn *nats.Conn, opts ...Option) (*Client, error)

NewClient constructor creates the client with the specified config

func (*Client) Close

func (client *Client) Close(ctx context.Context) error

Close closes the connection to NATS server

func (*Client) Subscribe

func (client *Client) Subscribe(ctx context.Context, subject string) (*pubsub.Subscription, error)

Subscribe method subscribes to the NATS subject

type Config

type Config struct {
	NatsURL  string
	NatsOpts nats.Option
}

Config contains the configuration need to connect to NATS server

type Option

type Option func(*Client) error

Option is a self-refrential function for configuration