server

package

v0.4.1 Latest Latest Go to latest Published: Dec 11, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(
	servers []string,
	userJWT,
	userSeed,
	serverCert string,
) (*Client, error)

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) DeleteConsumer(ctx context.Context, stream, name string) error

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

func (c *Client) DeleteStream(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 {
	*natsfs.FS
	// contains filtered or unexported fields
}

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