Liftbridge.Net

.NET client for Liftbridge, a system that provides lightweight, fault-tolerant message streams for NATS.

Liftbridge provides the following high-level features:

• Log-based API for NATS
• Replicated for fault-tolerance
• Horizontally scalable
• Wildcard subscription support
• At-least-once delivery support and message replay
• Message key-value support
• Log compaction by key

Report Bug · Request Feature

Table of Contents

1. About The Project
2. Getting Started
   • Prerequisites
   • Installation
3. Usage
4. Roadmap
5. Contributing
6. License
7. Contact
8. Acknowledgements

About The Project

Getting Started

To get a local copy up and running follow these simple steps.

Prerequisites

A running Liftbridge cluster. For testing, the Liftbridge repository includes Docker configurations.

Installation

NuGet

This library is in early development and not published to NuGet. Development builds are based on master and deployed to GitHub packages.

Source

1. Clone the repo

   git clone https://github.com/mamaar/Liftbridge.Net.git

2. Install NPM packages

   dotnet build

Usage

var options = new ClientOptions { 
    Brokers = new[] { new BrokerAddress { Host = "localhost", Port = 9292 }, } 
};
var client = new ClientAsync(options);

var subject = "foo";
var streamName = "foo-stream";

// Create a stream on the NATS subject "foo"
await client.CreateStream(streamName, subject);

// Publish a message on the stream
var message = System.Text.Encoding.ASCII.GetBytes("hello, world");
await client.Publish(streamName, message, new MessageOptions { });

// Subscribe to the stream starting from the beginning
var subscription = client.Subscribe(streamName, new SubscriptionOptions
{
    Partition = 0,
    StartPosition = Proto.StartPosition.Earliest,
});
await foreach (var message in subscription)
{
    var messageString = System.Text.Encoding.UTF8.GetString(message.Value);
    System.Console.WriteLine(messageString);
}

Roadmap

See the open issues for a list of proposed features (and known issues).

Contributing

Contributions are what make the open source community such an amazing place to be learn, inspire, and create. Any contributions you make are greatly appreciated.

1. Fork the Project
2. Create your Feature Branch (git checkout -b feature/AmazingFeature)
3. Commit your Changes (git commit -m 'Add some AmazingFeature')
4. Push to the Branch (git push origin feature/AmazingFeature)
5. Open a Pull Request

License

Distributed under the Apache License 2.0 License. See LICENSE for more information.

Contact

Project Link: https://github.com/mamaar/Liftbridge.Net

Acknowledgements

• Liftbridge