mamaar / liftbridge.net Goto Github PK

.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

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

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

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

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

1. Clone the repo

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

2. Install NPM packages

   dotnet build

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);
}

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

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

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

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

• Liftbridge