Class ReloadableStreamFilter

A script plugin seen as one Titanium.Web.Proxy.Abstractions.Scripting.IStreamScriptFilter of a passthrough listener. A listener keeps its filters for the life of the process, so this one asks current for the plugin of the configuration that is in force when a connection arrives, and pins that plugin to the connection: every later event of the connection goes to the same plugin, as its per-connection state lives there. Calls are counted against the owning PluginHost.

Inheritance

object

ReloadableStreamFilter

Implements

IStreamScriptFilter

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Titanium.Web.Proxy.Plugins

Assembly: Titanium.Web.Proxy.dll

Syntax

public sealed class ReloadableStreamFilter : IStreamScriptFilter

Constructors

ReloadableStreamFilter(string, Func<PluginHost?>)

Declaration

public ReloadableStreamFilter(string name, Func<PluginHost?> current)

Parameters

Type	Name	Description
string	name
Func<PluginHost>	current

Methods

OnCloseAsync(StreamConnectionContext)

Runs once when the connection ends. A throw is swallowed.

Declaration

public ValueTask OnCloseAsync(StreamConnectionContext context)

Parameters

Type	Name	Description
StreamConnectionContext	context

Returns

Type	Description
ValueTask

OnDownstreamDataAsync(StreamConnectionContext, ReadOnlyMemory<byte>, CancellationToken)

Runs for each piece read from the client, before it is sent upstream.

Declaration

public ValueTask<StreamFilterResult> OnDownstreamDataAsync(StreamConnectionContext context, ReadOnlyMemory<byte> data, CancellationToken cancellationToken)

Parameters

Type	Name	Description
StreamConnectionContext	context
ReadOnlyMemory<byte>	data
CancellationToken	cancellationToken

Returns

Type	Description
ValueTask<StreamFilterResult>

OnNewConnectionAsync(StreamConnectionContext, CancellationToken)

Runs once at accept, before any route is used. May deny or choose a cluster.

Declaration

public ValueTask<StreamFilterResult> OnNewConnectionAsync(StreamConnectionContext context, CancellationToken cancellationToken)

Parameters

Type	Name	Description
StreamConnectionContext	context
CancellationToken	cancellationToken

Returns

Type	Description
ValueTask<StreamFilterResult>

OnUpstreamDataAsync(StreamConnectionContext, ReadOnlyMemory<byte>, CancellationToken)

Runs for each piece read from the upstream, before it is sent to the client.

Declaration

public ValueTask<StreamFilterResult> OnUpstreamDataAsync(StreamConnectionContext context, ReadOnlyMemory<byte> data, CancellationToken cancellationToken)

Parameters

Type	Name	Description
StreamConnectionContext	context
ReadOnlyMemory<byte>	data
CancellationToken	cancellationToken

Returns

Type	Description
ValueTask<StreamFilterResult>

Implements

Titanium.Web.Proxy.Abstractions.Scripting.IStreamScriptFilter