Class DataMinerConnectorDataMapper

Namespace

Skyline.DataMiner.DataSources.OpenConfig.Gnmi.Protocol.DataMapper

Assembly

Skyline.DataMiner.DataSources.OpenConfig.Gnmi.Protocol.dll

Maps paths in a YANG model to containers in a DataMiner connector. This could either be a standalone parameter or a table.

When a notification comes in for a path that is stored in the inventory, this object will automatically set it in the corresponding parameter or table.

public class DataMinerConnectorDataMapper : IDataMapper

Inheritance

object

DataMinerConnectorDataMapper

Implements

IDataMapper

Extension Methods

TypeExtensions.ChangeType<T>(object)

Constructors

DataMinerConnectorDataMapper(SLProtocol, IEnumerable<IDataMinerConnectorDataEntity>)

Initializes a new instance of the DataMinerConnectorDataMapper class.

Properties

DefaultThrottlingInterval

The default throttling value in milliseconds.

MaxAllowedThrottlingInterval

The maximum allowed throttling value in milliseconds.

ThrottleInterval

The time interval in milliseconds between applying gNMI notifications to the in-memory data model before forwarding them to SLProtocol. Reduces the frequency of SLProtocol calls, potentially improving throughput.

Setting it to 0 or lower will disable throttling. The default value is DefaultThrottlingInterval. The maximum allowed value is MaxAllowedThrottlingInterval. If a higher value is configured, it will automatically default to the maximum.

Methods

GetPathForPid(int)

Gets the path that matches with the parameter ID.

ProcessSubscribeResponse(SubscribeResponse, DataValueOriginType, string)

Processes the gNMI Gnmi.SubscribeResponse and adapts the parameter values accordingly.

ReadExistingValues()

Reads out the parameter values and stores them internally.

RegisterSubscriptionPaths(string, IEnumerable<Path>, Action<IEnumerable<GnmiResponseValue>>, SubscriptionMode)

Registers the parameter IDs that are linked with a subscription name.

RemoveMissingRowForPid(int, string)

Removes the row from the table where the PK is equal to pk on the condition that the row also has the deleted status.

RemoveMissingRowsForPid(int)

Removes all rows from the table that have the deleted status.

RemoveMissingRowsForPid(int, IEnumerable<string>)

Removes the rows from the table that are present in the pks on the condition that they also have the deleted status.

SetLogger(ILogger)

Assigns a logger interface.

SuppressCommunication(bool)

Suppresses the communication, no more values will be filled in or logging will be written out.

UnregisterSubscriptionPaths(string)

Unregisters the parameter IDs that are linked with a subscription name.