VerifyException : Directory: /home/runner/work/axonserver-connector-dotnet/axonserver-connector-dotnet/test/AxonIQ.AxonServer.Connector.Tests
NotEqual:
  - Received: PublicApiAssertions.VerifyApiChanges.received.txt
    Verified: PublicApiAssertions.VerifyApiChanges.verified.txt

FileContent:

NotEqual:

Received: PublicApiAssertions.VerifyApiChanges.received.txt
[assembly: System.Reflection.AssemblyMetadata("RepositoryUrl", "https://github.com/AxonIQ/axonserver-connector-dotnet")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleTo("AxonIQ.AxonClusterIntegrationTests")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleTo("AxonIQ.AxonServer.Connector.Tests")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleTo("AxonIQ.AxonServerIntegrationTests")]
[assembly: System.Runtime.Versioning.TargetFramework(".NETCoreApp,Version=v8.0", FrameworkDisplayName=".NET 8.0")]
namespace AxonIQ.AxonServer.Connector
{
    public readonly struct AggregateId : System.IEquatable<AxonIQ.AxonServer.Connector.AggregateId>
    {
        public AggregateId(string value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.AggregateId other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
        public static bool operator !=(AxonIQ.AxonServer.Connector.AggregateId left, AxonIQ.AxonServer.Connector.AggregateId right) { }
        public static bool operator ==(AxonIQ.AxonServer.Connector.AggregateId left, AxonIQ.AxonServer.Connector.AggregateId right) { }
    }
    public static class AxonServerAuthentication
    {
        public static readonly AxonIQ.AxonServer.Connector.IAxonServerAuthentication None;
        public static AxonIQ.AxonServer.Connector.IAxonServerAuthentication UsingToken(string token) { }
    }
    public class AxonServerConnection : AxonIQ.AxonServer.Connector.IAxonServerConnection, System.IAsyncDisposable
    {
        public AxonServerConnection(AxonIQ.AxonServer.Connector.Context context, AxonIQ.AxonServer.Connector.AxonServerConnectorOptions options) { }
        public AxonIQ.AxonServer.Connector.IAdminChannel AdminChannel { get; }
        public AxonIQ.AxonServer.Connector.ClientIdentity ClientIdentity { get; }
        public AxonIQ.AxonServer.Connector.ICommandChannel CommandChannel { get; }
        public AxonIQ.AxonServer.Connector.Context Context { get; }
        public AxonIQ.AxonServer.Connector.IControlChannel ControlChannel { get; }
        public AxonIQ.AxonServer.Connector.IEventChannel EventChannel { get; }
        public bool IsClosed { get; }
        public bool IsConnected { get; }
        public bool IsReady { get; }
        public AxonIQ.AxonServer.Connector.IQueryChannel QueryChannel { get; }
        public System.Threading.Tasks.Task CloseAsync() { }
        public System.Threading.Tasks.ValueTask DisposeAsync() { }
        public System.Threading.Tasks.Task WaitUntilConnectedAsync() { }
        public System.Threading.Tasks.Task WaitUntilReadyAsync() { }
    }
    public class AxonServerConnectionFactory : System.IAsyncDisposable
    {
        public AxonServerConnectionFactory(AxonIQ.AxonServer.Connector.AxonServerConnectorOptions options) { }
        public System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.IAxonServerConnection> ConnectAsync(AxonIQ.AxonServer.Connector.Context context, System.Threading.CancellationToken ct = default) { }
        public System.Threading.Tasks.ValueTask DisposeAsync() { }
    }
    public static class AxonServerConnectorConfiguration
    {
        public const string ClientInstanceId = "ClientInstanceId";
        public const string ComponentName = "ComponentName";
        public const string DefaultSection = "AxonIQ";
        public const string RoutingServers = "RoutingServers";
    }
    public static class AxonServerConnectorDefaults
    {
        public static readonly AxonIQ.AxonServer.Connector.IAxonServerAuthentication Authentication;
        public static readonly System.Collections.Generic.IReadOnlyDictionary<string, string> ClientTags;
        public static readonly System.TimeSpan DefaultChannelInstructionPurgeFrequency;
        public static readonly System.TimeSpan DefaultChannelInstructionTimeout;
        public static readonly AxonIQ.AxonServer.Connector.PermitCount DefaultCommandPermits;
        public static readonly System.TimeSpan DefaultEventProcessorUpdateFrequency;
        public static readonly AxonIQ.AxonServer.Connector.PermitCount DefaultQueryPermits;
        public static readonly AxonIQ.AxonServer.Connector.ReconnectOptions DefaultReconnectOptions;
        public static readonly AxonIQ.AxonServer.Connector.PermitCount MinimumCommandPermits;
        public static readonly AxonIQ.AxonServer.Connector.PermitCount MinimumQueryPermits;
        public static readonly int Port;
        public static readonly System.Collections.Generic.IReadOnlyCollection<System.Net.DnsEndPoint> RoutingServers;
    }
    public static class AxonServerConnectorHeaders
    {
        public const string AccessToken = "AxonIQ-Access-Token";
        public const string Context = "AxonIQ-Context";
    }
    public class AxonServerConnectorOptions
    {
        public AxonIQ.AxonServer.Connector.IAxonServerAuthentication Authentication { get; }
        public AxonIQ.AxonServer.Connector.ClientInstanceId ClientInstanceId { get; }
        public System.Collections.Generic.IReadOnlyDictionary<string, string> ClientTags { get; }
        public System.Func<System.DateTimeOffset> Clock { get; }
        public System.TimeSpan CommandChannelInstructionPurgeFrequency { get; }
        public System.TimeSpan CommandChannelInstructionTimeout { get; }
        public AxonIQ.AxonServer.Connector.PermitCount CommandPermits { get; }
        public AxonIQ.AxonServer.Connector.ComponentName ComponentName { get; }
        public System.TimeSpan EventProcessorUpdateFrequency { get; }
        public Grpc.Net.Client.GrpcChannelOptions? GrpcChannelOptions { get; }
        public System.Collections.Generic.IReadOnlyList<Grpc.Core.Interceptors.Interceptor> Interceptors { get; }
        public Microsoft.Extensions.Logging.ILoggerFactory LoggerFactory { get; }
        public System.TimeSpan QueryChannelInstructionPurgeFrequency { get; }
        public System.TimeSpan QueryChannelInstructionTimeout { get; }
        public AxonIQ.AxonServer.Connector.PermitCount QueryPermits { get; }
        public AxonIQ.AxonServer.Connector.ReconnectOptions ReconnectOptions { get; }
        public System.Collections.Generic.IReadOnlyList<System.Net.DnsEndPoint> RoutingServers { get; }
        public static AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder For(AxonIQ.AxonServer.Connector.ComponentName componentName) { }
        public static AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder For(AxonIQ.AxonServer.Connector.ComponentName componentName, AxonIQ.AxonServer.Connector.ClientInstanceId clientInstanceId) { }
        public static AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder FromConfiguration(Microsoft.Extensions.Configuration.IConfiguration configuration) { }
    }
    public class AxonServerException : System.Exception
    {
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message) { }
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message, System.Exception innerException) { }
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message, string location) { }
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message, string location, System.Collections.Generic.IReadOnlyCollection<string> details) { }
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message, string location, System.Exception innerException) { }
        public AxonServerException(AxonIQ.AxonServer.Connector.ClientIdentity clientIdentity, AxonIQ.AxonServer.Connector.ErrorCategory errorCategory, string message, string location, System.Collections.Generic.IReadOnlyCollection<string> details, System.Exception innerException) { }
        public AxonIQ.AxonServer.Connector.ClientIdentity ClientIdentity { get; }
        public System.Collections.Generic.IReadOnlyCollection<string> Details { get; }
        public AxonIQ.AxonServer.Connector.ErrorCategory ErrorCategory { get; }
        public string Location { get; }
    }
    public class ClientIdentity : System.IEquatable<AxonIQ.AxonServer.Connector.ClientIdentity>
    {
        public ClientIdentity(AxonIQ.AxonServer.Connector.ComponentName ComponentName, AxonIQ.AxonServer.Connector.ClientInstanceId ClientInstanceId, System.Collections.Generic.IReadOnlyDictionary<string, string> ClientTags, System.Version Version) { }
        public AxonIQ.AxonServer.Connector.ClientInstanceId ClientInstanceId { get; init; }
        public System.Collections.Generic.IReadOnlyDictionary<string, string> ClientTags { get; init; }
        public AxonIQ.AxonServer.Connector.ComponentName ComponentName { get; init; }
        public System.Version Version { get; init; }
    }
    public readonly struct ClientInstanceId
    {
        public ClientInstanceId(string value) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
        public static AxonIQ.AxonServer.Connector.ClientInstanceId GenerateFrom(AxonIQ.AxonServer.Connector.ComponentName component) { }
    }
    public readonly struct CommandName
    {
        public CommandName(string value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.CommandName other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
    }
    public readonly struct ComponentName
    {
        public static readonly AxonIQ.AxonServer.Connector.ComponentName Default;
        public ComponentName(string value) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public AxonIQ.AxonServer.Connector.ComponentName PrefixWith(AxonIQ.AxonServer.Connector.ComponentName prefix) { }
        public AxonIQ.AxonServer.Connector.ComponentName PrefixWith(string prefix) { }
        public AxonIQ.AxonServer.Connector.ComponentName SuffixWith(AxonIQ.AxonServer.Connector.ComponentName suffix) { }
        public AxonIQ.AxonServer.Connector.ComponentName SuffixWith(string suffix) { }
        public override string ToString() { }
        public static AxonIQ.AxonServer.Connector.ComponentName GenerateRandomName() { }
    }
    public readonly struct Context : System.IEquatable<AxonIQ.AxonServer.Connector.Context>
    {
        public static readonly AxonIQ.AxonServer.Connector.Context Admin;
        public static readonly AxonIQ.AxonServer.Connector.Context Default;
        public Context(string value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.Context other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
        public void WriteTo(Grpc.Core.Metadata metadata) { }
    }
    public static class DateTimeOffsetMath
    {
        public static System.DateTimeOffset Max(System.DateTimeOffset left, System.DateTimeOffset right) { }
        public static System.DateTimeOffset Min(System.DateTimeOffset left, System.DateTimeOffset right) { }
    }
    public class ErrorCategory
    {
        public static readonly System.Collections.Generic.IReadOnlyList<AxonIQ.AxonServer.Connector.ErrorCategory> All;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory AuthenticationInvalidToken;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory AuthenticationTokenMissing;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory CommandDispatchError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory CommandExecutionError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory ConcurrencyException;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory ConnectionFailed;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory DatafileReadError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory DatafileWriteError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory DirectoryCreationFailed;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory EventPayloadTooLarge;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory GrpcMessageTooLarge;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory IndexReadError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory IndexWriteError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory InstructionAckError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory InstructionExecutionError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory InvalidEventSequence;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory NoEventStoreMasterAvailable;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory NoHandlerForCommand;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory NoHandlerForQuery;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory Other;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory QueryDispatchError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory QueryExecutionError;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory TransactionRolledBack;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory UnsupportedInstruction;
        public static readonly AxonIQ.AxonServer.Connector.ErrorCategory ValidationFailed;
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
        public static AxonIQ.AxonServer.Connector.ErrorCategory Parse(string errorCode) { }
    }
    public static class EventChannelExtensions
    {
        public static System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Event.Confirmation> AppendEvents(this AxonIQ.AxonServer.Connector.IEventChannel channel, params Io.Axoniq.Axonserver.Grpc.Event.Event[] events) { }
    }
    public readonly struct EventProcessorName
    {
        public EventProcessorName(string value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.EventProcessorName other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public override string ToString() { }
    }
    public static class EventQueryResultEntryExtensions
    {
        public static bool GetValueAsBoolean(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static double GetValueAsDouble(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static long GetValueAsInt64(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static bool? GetValueAsNullableBoolean(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static double? GetValueAsNullableDouble(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static long? GetValueAsNullableInt64(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static string? GetValueAsNullableString(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
        public static string GetValueAsString(this AxonIQ.AxonServer.Connector.IEventQueryResultEntry entry, string column) { }
    }
    public readonly struct EventSequenceNumber
    {
        public EventSequenceNumber(long value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.EventSequenceNumber other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public long ToInt64() { }
    }
    public readonly struct EventStreamToken : System.IEquatable<AxonIQ.AxonServer.Connector.EventStreamToken>
    {
        public static readonly AxonIQ.AxonServer.Connector.EventStreamToken None;
        public EventStreamToken(long value) { }
        public bool Equals(AxonIQ.AxonServer.Connector.EventStreamToken other) { }
        public override bool Equals(object? obj) { }
        public override int GetHashCode() { }
        public long ToInt64() { }
        public override string ToString() { }
        public static bool operator !=(AxonIQ.AxonServer.Connector.EventStreamToken left, AxonIQ.AxonServer.Connector.EventStreamToken right) { }
        public static bool operator ==(AxonIQ.AxonServer.Connector.EventStreamToken left, AxonIQ.AxonServer.Connector.EventStreamToken right) { }
    }
    public delegate System.Threading.Tasks.ValueTask HeartbeatMissed();
    public interface IAdminChannel
    {
        System.Threading.Tasks.Task AddNodeToReplicationGroupAsync(Io.Axoniq.Axonserver.Grpc.Admin.JoinReplicationGroup request);
        System.Threading.Tasks.Task CreateContextAsync(Io.Axoniq.Axonserver.Grpc.Admin.CreateContextRequest request);
        System.Threading.Tasks.Task CreateOrUpdateApplicationAsync(Io.Axoniq.Axonserver.Grpc.Admin.ApplicationRequest request);
        System.Threading.Tasks.Task CreateOrUpdateUserAsync(Io.Axoniq.Axonserver.Grpc.Admin.CreateOrUpdateUserRequest request);
        System.Threading.Tasks.Task CreateReplicationGroupAsync(Io.Axoniq.Axonserver.Grpc.Admin.CreateReplicationGroupRequest request);
        System.Threading.Tasks.Task DeleteApplicationAsync(string applicationName);
        System.Threading.Tasks.Task DeleteContextAsync(Io.Axoniq.Axonserver.Grpc.Admin.DeleteContextRequest request);
        System.Threading.Tasks.Task DeleteReplicationGroupAsync(Io.Axoniq.Axonserver.Grpc.Admin.DeleteReplicationGroupRequest request);
        System.Threading.Tasks.Task DeleteUserAsync(string username);
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.ApplicationOverview>> GetAllApplicationsAsync();
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.ContextOverview>> GetAllContextsAsync();
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.NodeOverview>> GetAllNodesAsync();
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.ReplicationGroupOverview>> GetAllReplicationGroupsAsync();
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.UserOverview>> GetAllUsersAsync();
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.ApplicationOverview> GetApplicationAsync(string applicationName);
        System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<Io.Axoniq.Axonserver.Grpc.Admin.LoadBalancingStrategy>> GetBalancingStrategiesAsync();
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.ContextOverview> GetContextOverviewAsync(string context);
        System.Collections.Generic.IAsyncEnumerable<Io.Axoniq.Axonserver.Grpc.Admin.EventProcessor> GetEventProcessors();
        System.Collections.Generic.IAsyncEnumerable<Io.Axoniq.Axonserver.Grpc.Admin.EventProcessor> GetEventProcessorsByComponent(AxonIQ.AxonServer.Connector.ComponentName component);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.ReplicationGroupOverview> GetReplicationGroupAsync(string replicationGroup);
        System.Threading.Tasks.Task LoadBalanceEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier, string strategy);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Result> MergeEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Result> MoveEventProcessorSegmentAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier, AxonIQ.AxonServer.Connector.SegmentId segmentId, AxonIQ.AxonServer.Connector.ClientInstanceId targetClient);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Result> PauseEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Token> RefreshTokenAsync(string applicationName);
        System.Threading.Tasks.Task RemoveNodeFromReplicationGroupAsync(Io.Axoniq.Axonserver.Grpc.Admin.LeaveReplicationGroup request);
        System.Threading.Tasks.Task SetAutoLoadBalanceStrategyAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier, string strategy);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Result> SplitEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Admin.Result> StartEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, AxonIQ.AxonServer.Connector.TokenStoreIdentifier identifier);
        System.Collections.Generic.IAsyncEnumerable<Io.Axoniq.Axonserver.Grpc.Admin.ContextUpdate> SubscribeToContextUpdates();
        System.Threading.Tasks.Task UpdateContextPropertiesAsync(Io.Axoniq.Axonserver.Grpc.Admin.UpdateContextPropertiesRequest request);
    }
    public interface IAggregateEventStream : System.Collections.Generic.IAsyncEnumerable<Io.Axoniq.Axonserver.Grpc.Event.Event>, System.IDisposable { }
    public interface IAppendEventsTransaction : System.IDisposable
    {
        System.Threading.Tasks.Task AppendEventAsync(Io.Axoniq.Axonserver.Grpc.Event.Event @event);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Event.Confirmation> CommitAsync();
        System.Threading.Tasks.Task RollbackAsync();
    }
    public interface IAxonServerAuthentication
    {
        void WriteTo(Grpc.Core.Metadata metadata);
    }
    public interface IAxonServerConnection : System.IAsyncDisposable
    {
        AxonIQ.AxonServer.Connector.IAdminChannel AdminChannel { get; }
        AxonIQ.AxonServer.Connector.ClientIdentity ClientIdentity { get; }
        AxonIQ.AxonServer.Connector.ICommandChannel CommandChannel { get; }
        AxonIQ.AxonServer.Connector.Context Context { get; }
        AxonIQ.AxonServer.Connector.IControlChannel ControlChannel { get; }
        AxonIQ.AxonServer.Connector.IEventChannel EventChannel { get; }
        bool IsClosed { get; }
        bool IsConnected { get; }
        bool IsReady { get; }
        AxonIQ.AxonServer.Connector.IQueryChannel QueryChannel { get; }
        System.Threading.Tasks.Task CloseAsync();
        System.Threading.Tasks.Task WaitUntilConnectedAsync();
        System.Threading.Tasks.Task WaitUntilConnectedAsync(System.TimeSpan timeout);
        System.Threading.Tasks.Task WaitUntilReadyAsync();
        System.Threading.Tasks.Task WaitUntilReadyAsync(System.TimeSpan timeout);
    }
    public interface IAxonServerConnectorOptionsBuilder
    {
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder AsClientInstanceId(AxonIQ.AxonServer.Connector.ClientInstanceId id);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder AsComponentName(AxonIQ.AxonServer.Connector.ComponentName name);
        AxonIQ.AxonServer.Connector.AxonServerConnectorOptions Build();
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithAuthenticationToken(string token);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithClientTag(string key, string value);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithClientTags(System.Collections.Generic.IEnumerable<System.Collections.Generic.KeyValuePair<string, string>> tags);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithClientTags(params System.Collections.Generic.KeyValuePair<string, string>[] tags);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithClock(System.Func<System.DateTimeOffset> clock);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithCommandChannelInstructionPurgeFrequency(System.TimeSpan frequency);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithCommandChannelInstructionTimeout(System.TimeSpan timeout);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithCommandPermits(AxonIQ.AxonServer.Connector.PermitCount count);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithDefaultRoutingServers();
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithEventProcessorUpdateFrequency(System.TimeSpan frequency);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithGrpcChannelOptions(Grpc.Net.Client.GrpcChannelOptions grpcChannelOptions);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithInterceptors(params Grpc.Core.Interceptors.Interceptor[] interceptors);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithLoggerFactory(Microsoft.Extensions.Logging.ILoggerFactory loggerFactory);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithQueryChannelInstructionPurgeFrequency(System.TimeSpan frequency);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithQueryChannelInstructionTimeout(System.TimeSpan timeout);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithQueryPermits(AxonIQ.AxonServer.Connector.PermitCount count);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithReconnectOptions(AxonIQ.AxonServer.Connector.ReconnectOptions options);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithRoutingServers(System.Collections.Generic.IEnumerable<System.Net.DnsEndPoint> servers);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithRoutingServers(params System.Net.DnsEndPoint[] servers);
        AxonIQ.AxonServer.Connector.IAxonServerConnectorOptionsBuilder WithoutAuthentication();
    }
    public interface ICommandChannel
    {
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.ICommandHandlerRegistration> RegisterCommandHandlerAsync(System.Func<Io.Axoniq.Axonserver.Grpc.Command.Command, System.Threading.CancellationToken, System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Command.CommandResponse>> handler, AxonIQ.AxonServer.Connector.LoadFactor loadFactor, params AxonIQ.AxonServer.Connector.CommandName[] commandNames);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Command.CommandResponse> SendCommandAsync(Io.Axoniq.Axonserver.Grpc.Command.Command command, System.Threading.CancellationToken ct);
    }
    public interface ICommandHandlerRegistration : System.IAsyncDisposable
    {
        System.Threading.Tasks.Task WaitUntilCompletedAsync();
    }
    public interface IControlChannel
    {
        System.Threading.Tasks.Task DisableHeartbeatAsync();
        System.Threading.Tasks.Task EnableHeartbeatAsync(System.TimeSpan interval, System.TimeSpan timeout);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.IEventProcessorRegistration> RegisterEventProcessorAsync(AxonIQ.AxonServer.Connector.EventProcessorName name, System.Func<System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Control.EventProcessorInfo?>> supplier, AxonIQ.AxonServer.Connector.IEventProcessorInstructionHandler handler);
        System.Threading.Tasks.Task SendInstructionAsync(Io.Axoniq.Axonserver.Grpc.Control.PlatformInboundInstruction instruction);
    }
    public interface IEventChannel
    {
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.Event.Confirmation> AppendSnapshotAsync(Io.Axoniq.Axonserver.Grpc.Event.Event snapshot);
        System.Threading.Tasks.Task<Io.Axoniq.Axonserver.Grpc.InstructionAck> CancelScheduleAsync(AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken token);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.EventSequenceNumber> FindHighestSequenceAsync(AxonIQ.AxonServer.Connector.AggregateId id);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.EventStreamToken> GetFirstTokenAsync();
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.EventStreamToken> GetLastTokenAsync();
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.EventStreamToken> GetTokenAtAsync(long instant);
        AxonIQ.AxonServer.Connector.IAggregateEventStream LoadSnapshots(AxonIQ.AxonServer.Connector.AggregateId id, AxonIQ.AxonServer.Connector.EventSequenceNumber? from = default, AxonIQ.AxonServer.Connector.EventSequenceNumber? to = default, int maxResults = 1);
        AxonIQ.AxonServer.Connector.IAggregateEventStream OpenStream(AxonIQ.AxonServer.Connector.AggregateId id, bool allowSnapshots = true);
        AxonIQ.AxonServer.Connector.IAggregateEventStream OpenStream(AxonIQ.AxonServer.Connector.AggregateId id, AxonIQ.AxonServer.Connector.EventSequenceNumber from, AxonIQ.AxonServer.Connector.EventSequenceNumber? to = default);
        AxonIQ.AxonServer.Connector.IEventStream OpenStream(AxonIQ.AxonServer.Connector.EventStreamToken token, AxonIQ.AxonServer.Connector.PermitCount bufferSize, AxonIQ.AxonServer.Connector.PermitCount? refillBatch = default, bool forceReadFromLeader = false);
        System.Collections.Generic.IAsyncEnumerable<AxonIQ.AxonServer.Connector.IEventQueryResultEntry> QueryEvents(string expression, bool liveStream);
        System.Collections.Generic.IAsyncEnumerable<AxonIQ.AxonServer.Connector.IEventQueryResultEntry> QuerySnapshotEvents(string expression, bool liveStream);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken> RescheduleAsync(AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken token, Google.Protobuf.WellKnownTypes.Duration duration, Io.Axoniq.Axonserver.Grpc.Event.Event @event);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken> RescheduleAsync(AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken token, System.DateTimeOffset instant, Io.Axoniq.Axonserver.Grpc.Event.Event @event);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken> ScheduleEventAsync(Google.Protobuf.WellKnownTypes.Duration duration, Io.Axoniq.Axonserver.Grpc.Event.Event @event);
        System.Threading.Tasks.Task<AxonIQ.AxonServer.Connector.ScheduledEventCancellationToken> ScheduleEventAsync(System.DateTimeOffset instant, Io.Axoniq.Axonserver.Grpc.Event.Event @event);
        AxonIQ.AxonServer.Connector.IAppendEventsTransaction StartAppendEventsTransaction();
    }
    public interface IEventProcessorInstructionHandler
    {
        System.Threading.Tas…ction.OriginalName("APPLIED")]
        Applied = 3,
    }
    public sealed class TransformedEvent : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent>
    {
        public const int EventFieldNumber = 2;
        public const int TokenFieldNumber = 1;
        public TransformedEvent() { }
        public TransformedEvent(Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent other) { }
        public Io.Axoniq.Axonserver.Grpc.Event.Event Event { get; set; }
        public long Token { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Event.TransformedEvent other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
}
namespace Io.Axoniq.Axonserver.Grpc.Query
{
    public sealed class QueryComplete : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryComplete>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryComplete>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryComplete>
    {
        public const int MessageIdFieldNumber = 1;
        public const int RequestIdFieldNumber = 2;
        public QueryComplete() { }
        public QueryComplete(Io.Axoniq.Axonserver.Grpc.Query.QueryComplete other) { }
        public string MessageId { get; set; }
        public string RequestId { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryComplete> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryComplete Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryComplete other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryComplete other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryFlowControl : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl>
    {
        public const int PermitsFieldNumber = 2;
        public const int QueryReferenceFieldNumber = 1;
        public QueryFlowControl() { }
        public QueryFlowControl(Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl other) { }
        public long Permits { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryReference QueryReference { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryProviderInbound : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound>
    {
        public const int AckFieldNumber = 1;
        public const int InstructionIdFieldNumber = 4;
        public const int QueryCancelFieldNumber = 5;
        public const int QueryFieldNumber = 2;
        public const int QueryFlowControlFieldNumber = 6;
        public const int SubscriptionQueryRequestFieldNumber = 3;
        public QueryProviderInbound() { }
        public QueryProviderInbound(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound other) { }
        public Io.Axoniq.Axonserver.Grpc.InstructionAck Ack { get; set; }
        public string InstructionId { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryRequest Query { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryReference QueryCancel { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryFlowControl QueryFlowControl { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound.RequestOneofCase RequestCase { get; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest SubscriptionQueryRequest { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound> Parser { get; }
        public int CalculateSize() { }
        public void ClearRequest() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
        public enum RequestOneofCase
        {
            None = 0,
            Ack = 1,
            Query = 2,
            SubscriptionQueryRequest = 3,
            QueryCancel = 5,
            QueryFlowControl = 6,
        }
    }
    public sealed class QueryProviderOutbound : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound>
    {
        public const int AckFieldNumber = 7;
        public const int FlowControlFieldNumber = 3;
        public const int InstructionIdFieldNumber = 8;
        public const int QueryCompleteFieldNumber = 5;
        public const int QueryResponseFieldNumber = 4;
        public const int SubscribeFieldNumber = 1;
        public const int SubscriptionQueryResponseFieldNumber = 6;
        public const int UnsubscribeFieldNumber = 2;
        public QueryProviderOutbound() { }
        public QueryProviderOutbound(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound other) { }
        public Io.Axoniq.Axonserver.Grpc.InstructionAck Ack { get; set; }
        public Io.Axoniq.Axonserver.Grpc.FlowControl FlowControl { get; set; }
        public string InstructionId { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryComplete QueryComplete { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryResponse QueryResponse { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound.RequestOneofCase RequestCase { get; }
        public Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription Subscribe { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse SubscriptionQueryResponse { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription Unsubscribe { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound> Parser { get; }
        public int CalculateSize() { }
        public void ClearRequest() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
        public enum RequestOneofCase
        {
            None = 0,
            Subscribe = 1,
            Unsubscribe = 2,
            FlowControl = 3,
            QueryResponse = 4,
            QueryComplete = 5,
            SubscriptionQueryResponse = 6,
            Ack = 7,
        }
    }
    public sealed class QueryReference : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryReference>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryReference>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryReference>
    {
        public const int RequestIdFieldNumber = 1;
        public QueryReference() { }
        public QueryReference(Io.Axoniq.Axonserver.Grpc.Query.QueryReference other) { }
        public string RequestId { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryReference> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryReference Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryReference other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryReference other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public static class QueryReflection
    {
        public static Google.Protobuf.Reflection.FileDescriptor Descriptor { get; }
    }
    public sealed class QueryRequest : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryRequest>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryRequest>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryRequest>
    {
        public const int ClientIdFieldNumber = 8;
        public const int ComponentNameFieldNumber = 9;
        public const int MessageIdentifierFieldNumber = 1;
        public const int MetaDataFieldNumber = 5;
        public const int PayloadFieldNumber = 4;
        public const int ProcessingInstructionsFieldNumber = 7;
        public const int QueryFieldNumber = 2;
        public const int ResponseTypeFieldNumber = 6;
        public const int TimestampFieldNumber = 3;
        public QueryRequest() { }
        public QueryRequest(Io.Axoniq.Axonserver.Grpc.Query.QueryRequest other) { }
        public string ClientId { get; set; }
        public string ComponentName { get; set; }
        public string MessageIdentifier { get; set; }
        public Google.Protobuf.Collections.MapField<string, Io.Axoniq.Axonserver.Grpc.MetaDataValue> MetaData { get; }
        public Io.Axoniq.Axonserver.Grpc.SerializedObject Payload { get; set; }
        public Google.Protobuf.Collections.RepeatedField<Io.Axoniq.Axonserver.Grpc.ProcessingInstruction> ProcessingInstructions { get; }
        public string Query { get; set; }
        public Io.Axoniq.Axonserver.Grpc.SerializedObject ResponseType { get; set; }
        public long Timestamp { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryRequest> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryRequest Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryRequest other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryRequest other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryResponse : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse>
    {
        public const int ErrorCodeFieldNumber = 2;
        public const int ErrorMessageFieldNumber = 3;
        public const int MessageIdentifierFieldNumber = 1;
        public const int MetaDataFieldNumber = 5;
        public const int PayloadFieldNumber = 4;
        public const int ProcessingInstructionsFieldNumber = 6;
        public const int RequestIdentifierFieldNumber = 7;
        public QueryResponse() { }
        public QueryResponse(Io.Axoniq.Axonserver.Grpc.Query.QueryResponse other) { }
        public string ErrorCode { get; set; }
        public Io.Axoniq.Axonserver.Grpc.ErrorMessage ErrorMessage { get; set; }
        public string MessageIdentifier { get; set; }
        public Google.Protobuf.Collections.MapField<string, Io.Axoniq.Axonserver.Grpc.MetaDataValue> MetaData { get; }
        public Io.Axoniq.Axonserver.Grpc.SerializedObject Payload { get; set; }
        public Google.Protobuf.Collections.RepeatedField<Io.Axoniq.Axonserver.Grpc.ProcessingInstruction> ProcessingInstructions { get; }
        public string RequestIdentifier { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryResponse Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryResponse other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryResponse other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public static class QueryService
    {
        public static Google.Protobuf.Reflection.ServiceDescriptor Descriptor { get; }
        public class QueryServiceClient : Grpc.Core.ClientBase<Io.Axoniq.Axonserver.Grpc.Query.QueryService.QueryServiceClient>
        {
            protected QueryServiceClient() { }
            public QueryServiceClient(Grpc.Core.CallInvoker callInvoker) { }
            public QueryServiceClient(Grpc.Core.ChannelBase channel) { }
            protected QueryServiceClient(Grpc.Core.ClientBase.ClientBaseConfiguration configuration) { }
            protected override Io.Axoniq.Axonserver.Grpc.Query.QueryService.QueryServiceClient NewInstance(Grpc.Core.ClientBase.ClientBaseConfiguration configuration) { }
            public virtual Grpc.Core.AsyncDuplexStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound, Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound> OpenStream(Grpc.Core.CallOptions options) { }
            public virtual Grpc.Core.AsyncDuplexStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.QueryProviderOutbound, Io.Axoniq.Axonserver.Grpc.Query.QueryProviderInbound> OpenStream(Grpc.Core.Metadata headers = null, System.DateTime? deadline = default, System.Threading.CancellationToken cancellationToken = default) { }
            public virtual Grpc.Core.AsyncServerStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse> Query(Io.Axoniq.Axonserver.Grpc.Query.QueryRequest request, Grpc.Core.CallOptions options) { }
            public virtual Grpc.Core.AsyncServerStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.QueryResponse> Query(Io.Axoniq.Axonserver.Grpc.Query.QueryRequest request, Grpc.Core.Metadata headers = null, System.DateTime? deadline = default, System.Threading.CancellationToken cancellationToken = default) { }
            public virtual Grpc.Core.AsyncDuplexStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest, Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse> Subscription(Grpc.Core.CallOptions options) { }
            public virtual Grpc.Core.AsyncDuplexStreamingCall<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest, Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse> Subscription(Grpc.Core.Metadata headers = null, System.DateTime? deadline = default, System.Threading.CancellationToken cancellationToken = default) { }
        }
    }
    public sealed class QuerySubscription : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription>
    {
        public const int ClientIdFieldNumber = 5;
        public const int ComponentNameFieldNumber = 4;
        public const int MessageIdFieldNumber = 1;
        public const int QueryFieldNumber = 2;
        public const int ResultNameFieldNumber = 3;
        public QuerySubscription() { }
        public QuerySubscription(Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription other) { }
        public string ClientId { get; set; }
        public string ComponentName { get; set; }
        public string MessageId { get; set; }
        public string Query { get; set; }
        public string ResultName { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QuerySubscription other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryUpdate : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate>
    {
        public const int ClientIdFieldNumber = 5;
        public const int ComponentNameFieldNumber = 6;
        public const int ErrorCodeFieldNumber = 7;
        public const int ErrorMessageFieldNumber = 8;
        public const int MessageIdentifierFieldNumber = 2;
        public const int MetaDataFieldNumber = 4;
        public const int PayloadFieldNumber = 3;
        public QueryUpdate() { }
        public QueryUpdate(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate other) { }
        public string ClientId { get; set; }
        public string ComponentName { get; set; }
        public string ErrorCode { get; set; }
        public Io.Axoniq.Axonserver.Grpc.ErrorMessage ErrorMessage { get; set; }
        public string MessageIdentifier { get; set; }
        public Google.Protobuf.Collections.MapField<string, Io.Axoniq.Axonserver.Grpc.MetaDataValue> MetaData { get; }
        public Io.Axoniq.Axonserver.Grpc.SerializedObject Payload { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryUpdateComplete : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete>
    {
        public const int ClientIdFieldNumber = 2;
        public const int ComponentNameFieldNumber = 3;
        public QueryUpdateComplete() { }
        public QueryUpdateComplete(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete other) { }
        public string ClientId { get; set; }
        public string ComponentName { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class QueryUpdateCompleteExceptionally : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally>
    {
        public const int ClientIdFieldNumber = 2;
        public const int ComponentNameFieldNumber = 3;
        public const int ErrorCodeFieldNumber = 5;
        public const int ErrorMessageFieldNumber = 6;
        public QueryUpdateCompleteExceptionally() { }
        public QueryUpdateCompleteExceptionally(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally other) { }
        public string ClientId { get; set; }
        public string ComponentName { get; set; }
        public string ErrorCode { get; set; }
        public Io.Axoniq.Axonserver.Grpc.ErrorMessage ErrorMessage { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class SubscriptionQuery : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery>
    {
        public const int NumberOfPermitsFieldNumber = 2;
        public const int QueryRequestFieldNumber = 3;
        public const int SubscriptionIdentifierFieldNumber = 1;
        public const int UpdateResponseTypeFieldNumber = 4;
        public SubscriptionQuery() { }
        public SubscriptionQuery(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery other) { }
        public long NumberOfPermits { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryRequest QueryRequest { get; set; }
        public string SubscriptionIdentifier { get; set; }
        public Io.Axoniq.Axonserver.Grpc.SerializedObject UpdateResponseType { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery> Parser { get; }
        public int CalculateSize() { }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
    }
    public sealed class SubscriptionQueryRequest : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest>
    {
        public const int FlowControlFieldNumber = 4;
        public const int GetInitialResultFieldNumber = 3;
        public const int SubscribeFieldNumber = 1;
        public const int UnsubscribeFieldNumber = 2;
        public SubscriptionQueryRequest() { }
        public SubscriptionQueryRequest(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest other) { }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery FlowControl { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery GetInitialResult { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest.RequestOneofCase RequestCase { get; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery Subscribe { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQuery Unsubscribe { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest> Parser { get; }
        public int CalculateSize() { }
        public void ClearRequest() { }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryRequest other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
        public enum RequestOneofCase
        {
            None = 0,
            Subscribe = 1,
            Unsubscribe = 2,
            GetInitialResult = 3,
            FlowControl = 4,
        }
    }
    public sealed class SubscriptionQueryResponse : Google.Protobuf.IBufferMessage, Google.Protobuf.IDeepCloneable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse>, Google.Protobuf.IMessage, Google.Protobuf.IMessage<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse>, System.IEquatable<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse>
    {
        public const int CompleteExceptionallyFieldNumber = 6;
        public const int CompleteFieldNumber = 5;
        public const int InitialResultFieldNumber = 3;
        public const int MessageIdentifierFieldNumber = 1;
        public const int SubscriptionIdentifierFieldNumber = 2;
        public const int UpdateFieldNumber = 4;
        public SubscriptionQueryResponse() { }
        public SubscriptionQueryResponse(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse other) { }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateComplete Complete { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdateCompleteExceptionally CompleteExceptionally { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryResponse InitialResult { get; set; }
        public string MessageIdentifier { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse.ResponseOneofCase ResponseCase { get; }
        public string SubscriptionIdentifier { get; set; }
        public Io.Axoniq.Axonserver.Grpc.Query.QueryUpdate Update { get; set; }
        public static Google.Protobuf.Reflection.MessageDescriptor Descriptor { get; }
        public static Google.Protobuf.MessageParser<Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse> Parser { get; }
        public int CalculateSize() { }
        public void ClearResponse() { }
        public Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse Clone() { }
        public bool Equals(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse other) { }
        public override bool Equals(object other) { }
        public override int GetHashCode() { }
        public void MergeFrom(Google.Protobuf.CodedInputStream input) { }
        public void MergeFrom(Io.Axoniq.Axonserver.Grpc.Query.SubscriptionQueryResponse other) { }
        public override string ToString() { }
        public void WriteTo(Google.Protobuf.CodedOutputStream output) { }
        public enum ResponseOneofCase
        {
            None = 0,
            InitialResult = 3,
            Update = 4,
            Complete = 5,
            CompleteExceptionally = 6,
        }
    }
}