JsonPipelineConfigurationSerializer
Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline.Configuration.Serializer
Implements the pipeline configuration serializer using JSON format
public class JsonPipelineConfigurationSerializer : IJsonPipelineConfigurationSerializer, IPipelineConfigurationSerializer
Inheritance Object → JsonPipelineConfigurationSerializer
Implements IJsonPipelineConfigurationSerializer, IPipelineConfigurationSerializer
Constructors
JsonPipelineConfigurationSerializer(INodeQualifiedNameLookupService)
Constructor
public JsonPipelineConfigurationSerializer(INodeQualifiedNameLookupService nodeQualifiedNameLookupService)
Parameters
nodeQualifiedNameLookupService INodeQualifiedNameLookupService
Methods
SerializeAsync(NodeDefinitionRoot)
public Task<string> SerializeAsync(NodeDefinitionRoot nodeDefinition)
Parameters
nodeDefinition NodeDefinitionRoot
Returns
SerializeAsync(StreamWriter, NodeDefinitionRoot)
public Task SerializeAsync(StreamWriter streamWriter, NodeDefinitionRoot nodeDefinition)
Parameters
streamWriter StreamWriter
nodeDefinition NodeDefinitionRoot
Returns
DeserializeAsync(String)
public Task<NodeDefinitionRoot> DeserializeAsync(string formattedText)
Parameters
formattedText String
Returns
DeserializeAsync(Stream, Nullable<CancellationToken>)
public Task<NodeDefinitionRoot> DeserializeAsync(Stream stream, Nullable<CancellationToken> cancellationToken)
Parameters
stream Stream
cancellationToken Nullable<CancellationToken>