Skip to content

Commit

Permalink
made transport adapter components public (#6838)
Browse files Browse the repository at this point in the history 
Needed for some work we're doing outside the main Akka.NET project
  • Loading branch information
@Aaronontheweb
Aaronontheweb authored Jul 17, 2023
1 parent 54f4967 commit 8580932
Show file tree
Hide file tree
Showing 3 changed files with 107 additions and 7 deletions.
50 changes: 50 additions & 0 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveRemote.DotNet.verified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -479,6 +479,18 @@ namespace Akka.Remote.Transport
public override System.Threading.Tasks.Task<System.ValueTuple<Akka.Actor.Address, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.IAssociationEventListener>>> Listen() { }
public override System.Threading.Tasks.Task<bool> Shutdown() { }
}
public abstract class AbstractTransportAdapterHandle : Akka.Remote.Transport.AssociationHandle
{
protected AbstractTransportAdapterHandle(Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
protected AbstractTransportAdapterHandle(Akka.Actor.Address originalLocalAddress, Akka.Actor.Address originalRemoteAddress, Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
public Akka.Actor.Address OriginalLocalAddress { get; }
public Akka.Actor.Address OriginalRemoteAddress { get; }
protected Akka.Remote.Transport.SchemeAugmenter SchemeAugmenter { get; }
public Akka.Remote.Transport.AssociationHandle WrappedHandle { get; }
protected bool Equals(Akka.Remote.Transport.AbstractTransportAdapterHandle other) { }
public override bool Equals(object obj) { }
public override int GetHashCode() { }
}
public abstract class Activity
{
protected Activity() { }
Expand Down Expand Up @@ -506,6 +518,17 @@ namespace Akka.Remote.Transport
protected override System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> InterceptListen(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> listenerTask) { }
public override System.Threading.Tasks.Task<bool> Shutdown() { }
}
public abstract class ActorTransportAdapterManager : Akka.Actor.UntypedActor
{
protected Akka.Remote.Transport.IAssociationEventListener AssociationListener;
protected System.Collections.Generic.Queue<object> DelayedEvents;
protected Akka.Actor.Address LocalAddress;
protected long UniqueId;
protected ActorTransportAdapterManager() { }
protected long NextId() { }
protected override void OnReceive(object message) { }
protected abstract void Ready(object message);
}
public class AkkaProtocolException : Akka.Actor.AkkaException
{
public AkkaProtocolException(string message, System.Exception cause = null) { }
Expand All @@ -517,6 +540,12 @@ namespace Akka.Remote.Transport
public Akka.Actor.Address LocalAddress { get; }
public Akka.Actor.Address RemoteAddress { get; }
}
public sealed class AssociateUnderlying : Akka.Remote.Transport.TransportOperation
{
public AssociateUnderlying(Akka.Actor.Address remoteAddress, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> statusPromise) { }
public Akka.Actor.Address RemoteAddress { get; }
public System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> StatusPromise { get; }
}
public abstract class AssociationHandle
{
protected AssociationHandle(Akka.Actor.Address localAddress, Akka.Actor.Address remoteAddress) { }
Expand Down Expand Up @@ -568,6 +597,11 @@ namespace Akka.Remote.Transport
Shutdown = 1,
Quarantined = 2,
}
public sealed class DisassociateUnderlying : Akka.Remote.Transport.TransportOperation, Akka.Event.IDeadLetterSuppression
{
public DisassociateUnderlying(Akka.Remote.Transport.DisassociateInfo info = 0) { }
public Akka.Remote.Transport.DisassociateInfo Info { get; }
}
public sealed class Disassociated : Akka.Actor.INoSerializationVerificationNeeded, Akka.Event.IDeadLetterSuppression, Akka.Remote.Transport.IHandleEvent
{
public Disassociated(Akka.Remote.Transport.DisassociateInfo info) { }
Expand Down Expand Up @@ -669,6 +703,17 @@ namespace Akka.Remote.Transport
public ListenAttempt(Akka.Actor.Address boundAddress) { }
public Akka.Actor.Address BoundAddress { get; }
}
public sealed class ListenUnderlying : Akka.Remote.Transport.TransportOperation
{
public ListenUnderlying(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> upstreamListener) { }
public Akka.Actor.Address ListenAddress { get; }
public System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> UpstreamListener { get; }
}
public sealed class ListenerRegistered : Akka.Remote.Transport.TransportOperation
{
public ListenerRegistered(Akka.Remote.Transport.IAssociationEventListener listener) { }
public Akka.Remote.Transport.IAssociationEventListener Listener { get; }
}
public class SchemeAugmenter
{
public readonly string AddedSchemeIdentifier;
Expand Down Expand Up @@ -788,6 +833,11 @@ namespace Akka.Remote.Transport
public virtual System.Threading.Tasks.Task<bool> ManagementCommand(object message) { }
public abstract System.Threading.Tasks.Task<bool> Shutdown();
}
public abstract class TransportOperation : Akka.Actor.INoSerializationVerificationNeeded
{
public static readonly System.TimeSpan AskTimeout;
protected TransportOperation() { }
}
public sealed class UnderlyingTransportError : Akka.Actor.INoSerializationVerificationNeeded, Akka.Remote.Transport.IHandleEvent
{
public UnderlyingTransportError(System.Exception cause, string message) { }
Expand Down
50 changes: 50 additions & 0 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveRemote.Net.verified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -479,6 +479,18 @@ namespace Akka.Remote.Transport
public override System.Threading.Tasks.Task<System.ValueTuple<Akka.Actor.Address, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.IAssociationEventListener>>> Listen() { }
public override System.Threading.Tasks.Task<bool> Shutdown() { }
}
public abstract class AbstractTransportAdapterHandle : Akka.Remote.Transport.AssociationHandle
{
protected AbstractTransportAdapterHandle(Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
protected AbstractTransportAdapterHandle(Akka.Actor.Address originalLocalAddress, Akka.Actor.Address originalRemoteAddress, Akka.Remote.Transport.AssociationHandle wrappedHandle, string addedSchemeIdentifier) { }
public Akka.Actor.Address OriginalLocalAddress { get; }
public Akka.Actor.Address OriginalRemoteAddress { get; }
protected Akka.Remote.Transport.SchemeAugmenter SchemeAugmenter { get; }
public Akka.Remote.Transport.AssociationHandle WrappedHandle { get; }
protected bool Equals(Akka.Remote.Transport.AbstractTransportAdapterHandle other) { }
public override bool Equals(object obj) { }
public override int GetHashCode() { }
}
public abstract class Activity
{
protected Activity() { }
Expand Down Expand Up @@ -506,6 +518,17 @@ namespace Akka.Remote.Transport
protected override System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> InterceptListen(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> listenerTask) { }
public override System.Threading.Tasks.Task<bool> Shutdown() { }
}
public abstract class ActorTransportAdapterManager : Akka.Actor.UntypedActor
{
protected Akka.Remote.Transport.IAssociationEventListener AssociationListener;
protected System.Collections.Generic.Queue<object> DelayedEvents;
protected Akka.Actor.Address LocalAddress;
protected long UniqueId;
protected ActorTransportAdapterManager() { }
protected long NextId() { }
protected override void OnReceive(object message) { }
protected abstract void Ready(object message);
}
public class AkkaProtocolException : Akka.Actor.AkkaException
{
public AkkaProtocolException(string message, System.Exception cause = null) { }
Expand All @@ -517,6 +540,12 @@ namespace Akka.Remote.Transport
public Akka.Actor.Address LocalAddress { get; }
public Akka.Actor.Address RemoteAddress { get; }
}
public sealed class AssociateUnderlying : Akka.Remote.Transport.TransportOperation
{
public AssociateUnderlying(Akka.Actor.Address remoteAddress, System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> statusPromise) { }
public Akka.Actor.Address RemoteAddress { get; }
public System.Threading.Tasks.TaskCompletionSource<Akka.Remote.Transport.AssociationHandle> StatusPromise { get; }
}
public abstract class AssociationHandle
{
protected AssociationHandle(Akka.Actor.Address localAddress, Akka.Actor.Address remoteAddress) { }
Expand Down Expand Up @@ -568,6 +597,11 @@ namespace Akka.Remote.Transport
Shutdown = 1,
Quarantined = 2,
}
public sealed class DisassociateUnderlying : Akka.Remote.Transport.TransportOperation, Akka.Event.IDeadLetterSuppression
{
public DisassociateUnderlying(Akka.Remote.Transport.DisassociateInfo info = 0) { }
public Akka.Remote.Transport.DisassociateInfo Info { get; }
}
public sealed class Disassociated : Akka.Actor.INoSerializationVerificationNeeded, Akka.Event.IDeadLetterSuppression, Akka.Remote.Transport.IHandleEvent
{
public Disassociated(Akka.Remote.Transport.DisassociateInfo info) { }
Expand Down Expand Up @@ -669,6 +703,17 @@ namespace Akka.Remote.Transport
public ListenAttempt(Akka.Actor.Address boundAddress) { }
public Akka.Actor.Address BoundAddress { get; }
}
public sealed class ListenUnderlying : Akka.Remote.Transport.TransportOperation
{
public ListenUnderlying(Akka.Actor.Address listenAddress, System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> upstreamListener) { }
public Akka.Actor.Address ListenAddress { get; }
public System.Threading.Tasks.Task<Akka.Remote.Transport.IAssociationEventListener> UpstreamListener { get; }
}
public sealed class ListenerRegistered : Akka.Remote.Transport.TransportOperation
{
public ListenerRegistered(Akka.Remote.Transport.IAssociationEventListener listener) { }
public Akka.Remote.Transport.IAssociationEventListener Listener { get; }
}
public class SchemeAugmenter
{
public readonly string AddedSchemeIdentifier;
Expand Down Expand Up @@ -788,6 +833,11 @@ namespace Akka.Remote.Transport
public virtual System.Threading.Tasks.Task<bool> ManagementCommand(object message) { }
public abstract System.Threading.Tasks.Task<bool> Shutdown();
}
public abstract class TransportOperation : Akka.Actor.INoSerializationVerificationNeeded
{
public static readonly System.TimeSpan AskTimeout;
protected TransportOperation() { }
}
public sealed class UnderlyingTransportError : Akka.Actor.INoSerializationVerificationNeeded, Akka.Remote.Transport.IHandleEvent
{
public UnderlyingTransportError(System.Exception cause, string message) { }
Expand Down
14 changes: 7 additions & 7 deletions src/core/Akka.Remote/Transport/TransportAdapters.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -303,7 +303,7 @@ public override Task<bool> Shutdown()
/// <summary>
/// TBD
/// </summary>
internal abstract class AbstractTransportAdapterHandle : AssociationHandle
public abstract class AbstractTransportAdapterHandle : AssociationHandle
{
/// <summary>
/// TBD
Expand Down Expand Up @@ -385,7 +385,7 @@ public override int GetHashCode()
/// <summary>
/// Marker interface for all transport operations
/// </summary>
internal abstract class TransportOperation : INoSerializationVerificationNeeded
public abstract class TransportOperation : INoSerializationVerificationNeeded
{
/// <summary>
/// TBD
Expand All @@ -396,7 +396,7 @@ internal abstract class TransportOperation : INoSerializationVerificationNeeded
/// <summary>
/// TBD
/// </summary>
internal sealed class ListenerRegistered : TransportOperation
public sealed class ListenerRegistered : TransportOperation
{
/// <summary>
/// TBD
Expand All @@ -416,7 +416,7 @@ public ListenerRegistered(IAssociationEventListener listener)
/// <summary>
/// TBD
/// </summary>
internal sealed class AssociateUnderlying : TransportOperation
public sealed class AssociateUnderlying : TransportOperation
{
/// <summary>
/// TBD
Expand All @@ -443,7 +443,7 @@ public AssociateUnderlying(Address remoteAddress, TaskCompletionSource<Associati
/// <summary>
/// TBD
/// </summary>
internal sealed class ListenUnderlying : TransportOperation
public sealed class ListenUnderlying : TransportOperation
{
/// <summary>
/// TBD
Expand All @@ -470,7 +470,7 @@ public ListenUnderlying(Address listenAddress, Task<IAssociationEventListener> u
/// <summary>
/// TBD
/// </summary>
internal sealed class DisassociateUnderlying : TransportOperation, IDeadLetterSuppression
public sealed class DisassociateUnderlying : TransportOperation, IDeadLetterSuppression
{
/// <summary>
/// TBD
Expand Down Expand Up @@ -556,7 +556,7 @@ public override Task<bool> Shutdown()
/// <summary>
/// TBD
/// </summary>
internal abstract class ActorTransportAdapterManager : UntypedActor
public abstract class ActorTransportAdapterManager : UntypedActor
{
/// <summary>
/// Lightweight Stash implementation
Expand Down

0 comments on commit 8580932

Please sign in to comment.