Class EdgeRegistrySchemaExtensions.Client

Namespace

Azure.Iot.Operations.Services.EdgeRegistry.Generated

Assembly

Azure.Iot.Operations.Services.dll

public abstract class EdgeRegistrySchemaExtensions.Client : IAsyncDisposable

Inheritance

object

EdgeRegistrySchemaExtensions.Client

Implements

IAsyncDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

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

Construct a new instance of this client.

public Client(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 that should be the same for the duration of this client's lifetime.

Properties

CreateSchemaActionInvoker

public EdgeRegistrySchemaExtensions.CreateSchemaActionInvoker CreateSchemaActionInvoker { get; }

Property Value

EdgeRegistrySchemaExtensions.CreateSchemaActionInvoker

CreateSchemaVersionActionInvoker

public EdgeRegistrySchemaExtensions.CreateSchemaVersionActionInvoker CreateSchemaVersionActionInvoker { get; }

Property Value

EdgeRegistrySchemaExtensions.CreateSchemaVersionActionInvoker

GetSchemaActionInvoker

public EdgeRegistrySchemaExtensions.GetSchemaActionInvoker GetSchemaActionInvoker { get; }

Property Value

EdgeRegistrySchemaExtensions.GetSchemaActionInvoker

GetSchemaVersionActionInvoker

public EdgeRegistrySchemaExtensions.GetSchemaVersionActionInvoker GetSchemaVersionActionInvoker { get; }

Property Value

EdgeRegistrySchemaExtensions.GetSchemaVersionActionInvoker

ListSchemaVersionsActionInvoker

public EdgeRegistrySchemaExtensions.ListSchemaVersionsActionInvoker ListSchemaVersionsActionInvoker { get; }

Property Value

EdgeRegistrySchemaExtensions.ListSchemaVersionsActionInvoker

Methods

CreateSchemaAsync(CreateSchemaAttributes, CommandRequestMetadata?, Dictionary<string, string>?, TimeSpan?, CancellationToken)

Invoke a command.

public RpcCallAsync<Schema> CreateSchemaAsync(CreateSchemaAttributes request, CommandRequestMetadata? requestMetadata = null, Dictionary<string, string>? additionalTopicTokenMap = null, TimeSpan? commandTimeout = null, CancellationToken cancellationToken = default)

Parameters

request CreateSchemaAttributes

The data for this command request.

requestMetadata CommandRequestMetadata

The metadata for this command request.

additionalTopicTokenMap Dictionary<string, string>

The topic token replacement map to use in addition to the topic tokens specified in the constructor. If this map contains any keys that the topic tokens specified in the constructor also has, then values specified in this map will take precedence.

commandTimeout TimeSpan?

How long the command will be available on the broker for an executor to receive.

cancellationToken CancellationToken

Cancellation token.

Returns

RpcCallAsync<Schema>

The command response.

CreateSchemaVersionAsync(CreateSchemaVersionAttributes, CommandRequestMetadata?, Dictionary<string, string>?, TimeSpan?, CancellationToken)

Invoke a command.

public RpcCallAsync<SchemaVersion> CreateSchemaVersionAsync(CreateSchemaVersionAttributes request, CommandRequestMetadata? requestMetadata = null, Dictionary<string, string>? additionalTopicTokenMap = null, TimeSpan? commandTimeout = null, CancellationToken cancellationToken = default)

Parameters

request CreateSchemaVersionAttributes

The data for this command request.

requestMetadata CommandRequestMetadata

The metadata for this command request.

additionalTopicTokenMap Dictionary<string, string>

The topic token replacement map to use in addition to the topic tokens specified in the constructor. If this map contains any keys that the topic tokens specified in the constructor also has, then values specified in this map will take precedence.

commandTimeout TimeSpan?

How long the command will be available on the broker for an executor to receive.

cancellationToken CancellationToken

Cancellation token.

Returns

RpcCallAsync<SchemaVersion>

The command response.

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, CancellationToken)

public ValueTask DisposeAsync(bool disposing, CancellationToken cancellationToken = default)

Parameters

disposing bool

cancellationToken CancellationToken

Returns

ValueTask

GetSchemaAsync(GetSchemaInputArguments, CommandRequestMetadata?, Dictionary<string, string>?, TimeSpan?, CancellationToken)

Invoke a command.

public RpcCallAsync<Schema> GetSchemaAsync(GetSchemaInputArguments request, CommandRequestMetadata? requestMetadata = null, Dictionary<string, string>? additionalTopicTokenMap = null, TimeSpan? commandTimeout = null, CancellationToken cancellationToken = default)

Parameters

request GetSchemaInputArguments

The data for this command request.

requestMetadata CommandRequestMetadata

The metadata for this command request.

additionalTopicTokenMap Dictionary<string, string>

The topic token replacement map to use in addition to the topic tokens specified in the constructor. If this map contains any keys that the topic tokens specified in the constructor also has, then values specified in this map will take precedence.

commandTimeout TimeSpan?

How long the command will be available on the broker for an executor to receive.

cancellationToken CancellationToken

Cancellation token.

Returns

RpcCallAsync<Schema>

The command response.

GetSchemaVersionAsync(GetSchemaVersionInputArguments, CommandRequestMetadata?, Dictionary<string, string>?, TimeSpan?, CancellationToken)

Invoke a command.

public RpcCallAsync<SchemaVersion> GetSchemaVersionAsync(GetSchemaVersionInputArguments request, CommandRequestMetadata? requestMetadata = null, Dictionary<string, string>? additionalTopicTokenMap = null, TimeSpan? commandTimeout = null, CancellationToken cancellationToken = default)

Parameters

request GetSchemaVersionInputArguments

The data for this command request.

requestMetadata CommandRequestMetadata

The metadata for this command request.

additionalTopicTokenMap Dictionary<string, string>

The topic token replacement map to use in addition to the topic tokens specified in the constructor. If this map contains any keys that the topic tokens specified in the constructor also has, then values specified in this map will take precedence.

commandTimeout TimeSpan?

How long the command will be available on the broker for an executor to receive.

cancellationToken CancellationToken

Cancellation token.

Returns

RpcCallAsync<SchemaVersion>

The command response.

ListSchemaVersionsAsync(ListSchemaVersionsInputArguments, CommandRequestMetadata?, Dictionary<string, string>?, TimeSpan?, CancellationToken)

Invoke a command.

public RpcCallAsync<ListSchemaVersionsOutputArguments> ListSchemaVersionsAsync(ListSchemaVersionsInputArguments request, CommandRequestMetadata? requestMetadata = null, Dictionary<string, string>? additionalTopicTokenMap = null, TimeSpan? commandTimeout = null, CancellationToken cancellationToken = default)

Parameters

request ListSchemaVersionsInputArguments

The data for this command request.

requestMetadata CommandRequestMetadata

The metadata for this command request.

additionalTopicTokenMap Dictionary<string, string>

The topic token replacement map to use in addition to the topic tokens specified in the constructor. If this map contains any keys that the topic tokens specified in the constructor also has, then values specified in this map will take precedence.

commandTimeout TimeSpan?

How long the command will be available on the broker for an executor to receive.

cancellationToken CancellationToken

Cancellation token.

Returns

RpcCallAsync<ListSchemaVersionsOutputArguments>

The command response.

StopAsync(CancellationToken)

Stop accepting telemetry for all telemetry receivers and make all command invokers unsubscribe from command topics.

public Task StopAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Cancellation token.

Returns

Task