jetstreamclient

Documentation

Index

• type Client
  • func New(config *Config) (*Client, error)
  • func (c *Client) OrganizationSubject() string
  • func (c *Client) PersonSubject() string
  • func (c *Client) SubscribeOrganization(cb func(msg *nats.Msg)) (*nats.Subscription, error)
  • func (c *Client) SubscribePerson(cb func(msg *nats.Msg)) (*nats.Subscription, error)
• type Config

Types

type Client

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

func New

func New(config *Config) (*Client, error)

func (*Client) OrganizationSubject

func (c *Client) OrganizationSubject() string

func (*Client) PersonSubject

func (c *Client) PersonSubject() string

func (*Client) SubscribeOrganization

func (c *Client) SubscribeOrganization(cb func(msg *nats.Msg)) (*nats.Subscription, error)

func (*Client) SubscribePerson

func (c *Client) SubscribePerson(cb func(msg *nats.Msg)) (*nats.Subscription, error)

type Config

type Config struct {
	NatsUrl    string
	StreamName string
	Logger     *zap.SugaredLogger
	Nkey       string
	NkeySeed   string
}