Class RedisHighAvailabilityManager

Class used to manage an extractor using a Redis database.

Inheritance

object

HighAvailabilityManager

RedisHighAvailabilityManager

Implements

IHighAvailabilityManager

Inherited Members

HighAvailabilityManager.WaitToBecomeActive()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Cognite.Extractor.Utils

Assembly: ExtractorUtils.dll

Syntax

public class RedisHighAvailabilityManager : HighAvailabilityManager, IHighAvailabilityManager

Constructors

RedisHighAvailabilityManager(HighAvailabilityConfig, ILogger<HighAvailabilityManager>, PeriodicScheduler, CancellationTokenSource, TimeSpan?, TimeSpan?)

Constructor.

Declaration

public RedisHighAvailabilityManager(HighAvailabilityConfig config, ILogger<HighAvailabilityManager> logger, PeriodicScheduler scheduler, CancellationTokenSource source, TimeSpan? interval = null, TimeSpan? inactivityThreshold = null)

Parameters

Type	Name	Description
HighAvailabilityConfig	config	Configuration object.
ILogger<HighAvailabilityManager>	logger	Logger.
PeriodicScheduler	scheduler	Scheduler.
CancellationTokenSource	source	CancellationToken source.
TimeSpan?	interval	Optional update state interval.
TimeSpan?	inactivityThreshold	Optional threshold for extractor being inactive.

Implements

IHighAvailabilityManager

Extension Methods

DataModelUtils.GetOrCreateResourcesAsync<T, T2>(T2, IEnumerable<InstanceIdentifier>, Func<IEnumerable<InstanceIdentifier>, IEnumerable<SourcedNodeWrite<T>>>, Func<IEnumerable<SourcedNodeWrite<T>>, SanitationMode, (IEnumerable<SourcedNodeWrite<T>>, IEnumerable<CogniteError<SourcedNodeWrite<T>>>)>, int, int, RetryMode, SanitationMode, CancellationToken)