Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

made transport adapter components public #6838

Merged
merged 2 commits into from
Jul 17, 2023
Merged

made transport adapter components public #6838

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
2f40b3f
made transport adapter components public
Aaronontheweb Jul 14, 2023
ca14367
Merge branch 'dev' into make-transportadapters-public
Aaronontheweb Jul 17, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
50 changes: 50 additions & 0 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveRemote.DotNet.verified.txt
View file
Open in desktop
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just made all of this public - needed to develop external transport adapters for Akka.Remote.

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
Open in desktop
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
Open in desktop
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