Class ExtractionPipelineExtensions

Namespace

Cognite.Simulator.Utils

Assembly

Cognite.Simulator.Utils.dll

Extension methods for extraction pipelines

public static class ExtractionPipelineExtensions

Inheritance

object

ExtractionPipelineExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

AddConfiguration<T>(IServiceCollection, string, Type[], string, CancellationToken, int, int[])

Use type: remote to fetch the config from Fusion, or use type: local to use the local file instead Example from config.yml using the remote config from Fusion type: remote # this is required cognite: project: ... host: ... extraction-pipeline: pipeline-id: ... # as well as this idp-authentication: ...

public static Task<T> AddConfiguration<T>(this IServiceCollection services, string path, Type[] types, string appId, CancellationToken token, int version = 1, int[] acceptedConfigVersions = null) where T : BaseConfig

Parameters

services IServiceCollection

Service collection

path string

Path to config file

types Type[]

Types to use for deserialization

appId string

App ID for measuring network data

token CancellationToken

Cancellation token

version int

Config version

acceptedConfigVersions int[]

Accepted config versions

Returns

Task<T>

Type Parameters

T

The complete config object to be parsed

AddExtractionPipeline(IServiceCollection, ConnectorConfig)

Adds a extraction pipeline to the service collection

public static void AddExtractionPipeline(this IServiceCollection services, ConnectorConfig config)

Parameters

services IServiceCollection

Service collection

config ConnectorConfig

Connector configuration