server

Dec 11, 2025

Changes in this version

type Client

+ func (c *Client) DeleteConsumer(ctx context.Context, stream, name string) error

+ func (c *Client) DeleteStream(ctx context.Context, name string) error

Nov 30, 2025

Changes in this version

+ type Client struct

+ func (c *Client) CreateConsumer(ctx context.Context, stream string, subjects []string) (jetstream.Consumer, error)

+ func (c *Client) CreateDurableConsumer(ctx context.Context, stream, name string, subjects []string) (jetstream.Consumer, error)

+ func (c *Client) CreateObjectStore(ctx context.Context, name, description string) error

+ func (c *Client) CreateStream(ctx context.Context, name string, subjects []string) (jetstream.Stream, error)

+ func (c *Client) DeleteObjectStore(ctx context.Context, name string) error

+ func (c *Client) GetObjectStore(ctx context.Context, name string) (*ObjectStore, error)

+ func (c *Client) ListObjectStores(ctx context.Context) ([]*ObjectStore, error)

+ func (c *Client) ListStreams(ctx context.Context) ([]string, error)

+ func (c *Client) Publish(ctx context.Context, msg *nats.Msg) error

+ type ObjectStore struct

+ func NewObjectStore(ctx context.Context, store jetstream.ObjectStore) (*ObjectStore, error)

+ func (o *ObjectStore) Close() error

+ func (o *ObjectStore) Description() string

+ func (o *ObjectStore) Name() string

+ func (o *ObjectStore) Size() uint64

Jun 16, 2025

Changes in this version

+ func New(logger *slog.Logger, servers []string, userJWT, userKey, caCertFile string) (*nats.Conn, error)