Class SchemaRegistry.Service

Namespace

Azure.Iot.Operations.Services.SchemaRegistry.SchemaRegistry

Assembly

Azure.Iot.Operations.Services.dll

[ServiceGroupId("schema-registry-edge")]
public abstract class SchemaRegistry.Service : IAsyncDisposable

Inheritance

object

SchemaRegistry.Service

Implements

IAsyncDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

Service(ApplicationContext, IMqttPubSubClient, Dictionary<string, string>?)

Construct a new instance of this service.

public Service(ApplicationContext applicationContext, IMqttPubSubClient mqttClient, Dictionary<string, string>? topicTokenMap = null)

Parameters

applicationContext ApplicationContext

The shared context for your application.

mqttClient IMqttPubSubClient

The MQTT client to use.

topicTokenMap Dictionary<string, string>

The topic token replacement map to use for all operations by default. Generally, this will include the token values for topic tokens such as "modelId" which should be the same for the duration of this service's lifetime. Note that additional topic tokens can be specified per-telemetry message.

Properties

GetCommandExecutor

public SchemaRegistry.GetCommandExecutor GetCommandExecutor { get; }

Property Value

SchemaRegistry.GetCommandExecutor

PutCommandExecutor

public SchemaRegistry.PutCommandExecutor PutCommandExecutor { get; }

Property Value

SchemaRegistry.PutCommandExecutor

Methods

DisposeAsync()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.

public ValueTask DisposeAsync()

Returns

ValueTask

A task that represents the asynchronous dispose operation.

DisposeAsync(bool)

public ValueTask DisposeAsync(bool disposing)

Parameters

disposing bool

Returns

ValueTask

GetAsync(GetRequestSchema, CommandRequestMetadata, CancellationToken)

public abstract Task<ExtendedResponse<GetResponsePayload>> GetAsync(GetRequestSchema request, CommandRequestMetadata requestMetadata, CancellationToken cancellationToken)

Parameters

request GetRequestSchema

requestMetadata CommandRequestMetadata

cancellationToken CancellationToken

Returns

Task<ExtendedResponse<GetResponsePayload>>

PutAsync(PutRequestSchema, CommandRequestMetadata, CancellationToken)

public abstract Task<ExtendedResponse<PutResponsePayload>> PutAsync(PutRequestSchema request, CommandRequestMetadata requestMetadata, CancellationToken cancellationToken)

Parameters

request PutRequestSchema

requestMetadata CommandRequestMetadata

cancellationToken CancellationToken

Returns

Task<ExtendedResponse<PutResponsePayload>>

StartAsync(int?, CancellationToken)

Begin accepting command invocations for all command executors.

public Task StartAsync(int? preferredDispatchConcurrency = null, CancellationToken cancellationToken = default)

Parameters

preferredDispatchConcurrency int?

The dispatch concurrency count for the command response cache to use.

cancellationToken CancellationToken

Cancellation token.

Returns

Task

StopAsync(CancellationToken)

public Task StopAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task