Class NatsSvcEndpoint<T>

Namespace

NATS.Client.Services

Assembly

NATS.Client.Services.dll

NATS service endpoint.

public class NatsSvcEndpoint<T> : NatsSvcEndpointBase, INatsSvcEndpoint, IAsyncDisposable

Type Parameters

T

Serialized type to use when receiving data.

Inheritance

object

NatsSubBase

NatsSvcEndpointBase

NatsSvcEndpoint<T>

Implements

INatsSvcEndpoint

IAsyncDisposable

Inherited Members

NatsSubBase.Subject

NatsSubBase.QueueGroup

NatsSubBase.Exception

NatsSubBase.PendingMsgs

NatsSubBase.EndReason

NatsSubBase.Connection

NatsSubBase.ReadyAsync()

NatsSubBase.UnsubscribeAsync()

NatsSubBase.ReceiveAsync(string, string, ReadOnlySequence<byte>?, ReadOnlySequence<byte>)

NatsSubBase.SetException(Exception)

NatsSubBase.ResetIdleTimeout()

NatsSubBase.DecrementMaxMsgs()

NatsSubBase.EndSubscription(NatsSubEndReason)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsSvcEndpoint(NatsConnection, string?, string, Func<NatsSvcMsg<T>, ValueTask>, string, IDictionary<string, string>?, INatsDeserialize<T>, NatsSubOpts?, CancellationToken)

Creates a new instance of NatsSvcEndpoint<T>.

Properties

AverageProcessingTime

Average processing time in nanoseconds.

Errors

Number of errors.

LastError

Last error message.

Metadata

Endpoint metadata.

Name

The name of the endpoint.

ProcessingTime

Total processing time in nanoseconds.

Requests

Number of requests received.

Methods

DisposeAsync()

ReceiveInternalAsync(string, string?, ReadOnlySequence<byte>?, ReadOnlySequence<byte>)

Invoked when a MSG or HMSG arrives for the subscription. This method is invoked while reading from the socket. Buffers belong to the socket reader and you should process them as quickly as possible or create a copy before you return from this method.

TryComplete()

Invoked to signal end of the subscription.