Documentation ¶
Index ¶
- Variables
- func ConsumerInfo(c *Client, domain string, consumer string, stream string) (*nats.ConsumerInfo, error)
- func ConsumerList(c *Client, domain string, stream string) ([]string, error)
- func GetPublicKeys(jwt string) (string, string, error)
- func StreamInfo(c *Client, domain string, stream string) (*nats.StreamInfo, error)
- func StreamList(c *Client, domain string) ([]string, error)
- type Client
- func (c *Client) CreateConsumer(domain string, stream string, config *nats.ConsumerConfig) error
- func (c *Client) CreateStream(domain string, config *nats.StreamConfig) error
- func (c *Client) DeleteConsumer(domain string, stream string, consumer string) error
- func (c *Client) DeleteStream(domain string, name string) error
- func (c *Client) Disconnect()
- func (c *Client) UpdateConsumer(domain string, stream string, config *nats.ConsumerConfig) error
- func (c *Client) UpdateStream(domain string, config *nats.StreamConfig) error
- type Config
Constants ¶
This section is empty.
Variables ¶
var (
ErrNatsConfig = errors.New("secret does not contain a valid nats configuration")
)
Functions ¶
func ConsumerInfo ¶
func ConsumerInfo(c *Client, domain string, consumer string, stream string) (*nats.ConsumerInfo, error)
ConsumerInfo returns the consumer info for a given consumer name for a given domain and stream
func ConsumerList ¶
ConsumerList returns a list of consumer names for a given domain
func StreamInfo ¶
StreamInfo returns the stream info for a given stream name for a given domain
Types ¶
type Client ¶
type Client struct { Address string UserPublicKey string AccountPublicKey string // contains filtered or unexported fields }
func (*Client) CreateConsumer ¶
CreateConsumer creates a new jetstream consumer with a given configuration for a given domain and stream
func (*Client) CreateStream ¶
CreateStream creates a new jetstream stream with a given configuration for a given domain
func (*Client) DeleteConsumer ¶
DeleteConsumer deletes a jetstream consumer with a given name for a given domain and stream
func (*Client) DeleteStream ¶
DeleteStream deletes a jetstream stream with a given name for a given domain
func (*Client) Disconnect ¶
func (c *Client) Disconnect()
func (*Client) UpdateConsumer ¶
UpdateConsumer updates a jetstream consumer with a given configuration for a given domain and stream
func (*Client) UpdateStream ¶
UpdateStream updates a jetstream stream with a given configuration for a given domain