blob: 266ae15502990572b25c9b7d4d80dcfd6364e07d [file] [log] [blame]
using System;
namespace DotPulsar.Abstractions
{
/// <summary>
/// A pulsar client abstraction.
/// </summary>
public interface IPulsarClient : IAsyncDisposable
{
/// <summary>
/// Create a producer.
/// </summary>
IProducer CreateProducer(ProducerOptions options);
/// <summary>
/// Create a consumer.
/// </summary>
IConsumer CreateConsumer(ConsumerOptions options);
/// <summary>
/// Create a reader.
/// </summary>
IReader CreateReader(ReaderOptions options);
}
}