Skip to main content

MeshEtlContext

Namespace: Meshmakers.Octo.MeshAdapter.Services.Pipeline

ETL context for the mesh adapter

public class MeshEtlContext : DefaultEtlContext, IEtlContext, IMeshEtlContext

Inheritance Object → DefaultEtlContext → MeshEtlContext
Implements IEtlContext, IMeshEtlContext

Properties​

TenantRepository​

public ITenantRepository TenantRepository { get; }

Property Value​

ITenantRepository

TenantId​

public string TenantId { get; }

Property Value​

String

PipelineExecutionId​

public Guid PipelineExecutionId { get; }

Property Value​

Guid

DataPipelineRtId​

public OctoObjectId DataPipelineRtId { get; }

Property Value​

OctoObjectId

TransactionStartedDateTime​

public DateTime TransactionStartedDateTime { get; }

Property Value​

DateTime

PipelineRtEntityId​

public RtEntityId PipelineRtEntityId { get; }

Property Value​

RtEntityId

ExternalReceivedDateTime​

public Nullable<DateTime> ExternalReceivedDateTime { get; }

Property Value​

Nullable<DateTime>

Properties​

public IDictionary<string, object> Properties { get; }

Property Value​

IDictionary<String, Object>

GlobalConfiguration​

public IGlobalConfiguration GlobalConfiguration { get; }

Property Value​

IGlobalConfiguration

Constructors​

MeshEtlContext(String, ITenantRepository, OctoObjectId, Guid, RtEntityId, DateTime, Nullable<DateTime>, IGlobalConfiguration, IDictionary<String, Object>)​

Create a new instance of MeshEtlContext

public MeshEtlContext(string tenantId, ITenantRepository tenantRepository, OctoObjectId dataPipelineRtId, Guid pipelineExecutionId, RtEntityId pipelineRtEntityId, DateTime adapterReceivedDateTime, Nullable<DateTime> externalReceivedDateTime, IGlobalConfiguration globalConfiguration, IDictionary<string, object> properties)

Parameters​

tenantId String
Tenant identifier

tenantRepository ITenantRepository
Tenant repository

dataPipelineRtId OctoObjectId
Data pipeline runtime identifier

pipelineExecutionId Guid
Guid that identifies the pipeline execution instance

pipelineRtEntityId RtEntityId
Pipeline identifier

adapterReceivedDateTime DateTime
Received date time from the adapter

externalReceivedDateTime Nullable<DateTime>
Date and time when the value was received by an optional external system

globalConfiguration IGlobalConfiguration
Global configuration for the pipeline

properties IDictionary<String, Object>
properties that are shared between the different stages of the ETL process and different runs of the pipeline