Class TaskReporter

Type handling reporting of events related to a single task.

Inheritance

object

BaseErrorReporter

TaskReporter

Inherited Members

BaseErrorReporter.BeginWarning(string, string, DateTime?)

BaseErrorReporter.Warning(string, string, DateTime?)

BaseErrorReporter.BeginError(string, string, DateTime?)

BaseErrorReporter.Error(string, string, DateTime?)

BaseErrorReporter.BeginFatal(string, string, DateTime?)

BaseErrorReporter.Fatal(string, string, DateTime?)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Cognite.Extractor.Utils.Unstable.Tasks

Assembly: ExtractorUtils.dll

Syntax

public class TaskReporter : BaseErrorReporter

Constructors

TaskReporter(string, IIntegrationSink)

Constructor.

Declaration

public TaskReporter(string taskName, IIntegrationSink sink)

Parameters

Type	Name	Description
string	taskName	Name of the task, must be unique.
IIntegrationSink	sink	Sink for task events.

Methods

NewError(ErrorLevel, string, string?, DateTime?)

Create a new extractor error belonging to this reporter.

Declaration

public override ExtractorError NewError(ErrorLevel level, string description, string? details = null, DateTime? now = null)

Parameters

Type	Name	Description
ErrorLevel	level	Error level.
string	description	Short error description.
string	details	Long error details.
DateTime?	now	Optional current timestamp.

Returns

Type	Description
ExtractorError

Overrides

BaseErrorReporter.NewError(ErrorLevel, string, string?, DateTime?)

ReportEnd(TaskUpdatePayload?, DateTime?)

Report that this task has ended.

Declaration

public void ReportEnd(TaskUpdatePayload? update = null, DateTime? timestamp = null)

Parameters

Type	Name	Description
TaskUpdatePayload	update	Message and context tied to task run
DateTime?	timestamp

ReportStart(TaskUpdatePayload?, DateTime?)

Report that this task has started.

Declaration

public void ReportStart(TaskUpdatePayload? update = null, DateTime? timestamp = null)

Parameters

Type	Name	Description
TaskUpdatePayload	update	Message and context tied to task run
DateTime?	timestamp

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)