startPipeline method

Future<StartPipelineResponse> startPipeline({
  1. required String pipelineName,
})

Starts an OpenSearch Ingestion pipeline. For more information, see Starting an OpenSearch Ingestion pipeline.

May throw AccessDeniedException. May throw ConflictException. May throw DisabledOperationException. May throw InternalException. May throw ResourceNotFoundException. May throw ValidationException.

Parameter pipelineName : The name of the pipeline to start.

Implementation

Future<StartPipelineResponse> startPipeline({
  required String pipelineName,
}) async {
  final response = await _protocol.send(
    payload: null,
    method: 'PUT',
    requestUri:
        '/2022-01-01/osis/startPipeline/${Uri.encodeComponent(pipelineName)}',
    exceptionFnMap: _exceptionFns,
  );
  return StartPipelineResponse.fromJson(response);
}