ingestion

Documentation

Overview

Package ingestion - in charge of ingesting the given data - based on the configuration file.

Index

• func IngestSource(ingestClient *azkustoingest.Ingestion, DataSourceUri string, ...)
• func WaitForIngestionToComplete(waitForIngestSeconds int)

Functions

func IngestSource

func IngestSource(ingestClient *azkustoingest.Ingestion, DataSourceUri string, ctx context.Context, options []azkustoingest.FileOption, databaseName string, tableName string, source string)

IngestSource Ingests both files and blob sources and handles error accordingly

func WaitForIngestionToComplete

func WaitForIngestionToComplete(waitForIngestSeconds int)

WaitForIngestionToComplete Halts the program for WaitForIngestSeconds, allowing the queued ingestion process to complete