Class NatsSvcEndpointBase

Namespace

NATS.Client.Services

Assembly

NATS.Client.Services.dll

Endpoint base class exposing general stats.

public abstract class NatsSvcEndpointBase : NatsSubBase, INatsSvcEndpoint, IAsyncDisposable

Inheritance

object

NatsSubBase

NatsSvcEndpointBase

Implements

INatsSvcEndpoint

IAsyncDisposable

Derived

NatsSvcEndpoint<T>

Inherited Members

NatsSubBase.Subject

NatsSubBase.QueueGroup

NatsSubBase.Exception

NatsSubBase.PendingMsgs

NatsSubBase.EndReason

NatsSubBase.Connection

NatsSubBase.ReadyAsync()

NatsSubBase.UnsubscribeAsync()

NatsSubBase.DisposeAsync()

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

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

NatsSubBase.SetException(Exception)

NatsSubBase.ResetIdleTimeout()

NatsSubBase.DecrementMaxMsgs()

NatsSubBase.TryComplete()

NatsSubBase.EndSubscription(NatsSubEndReason)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsSvcEndpointBase(INatsConnection, string, string?, NatsSubOpts?)

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.