Function NewApiExtractor

backend/helpers/pluginhelper/api/api_extractor.go:48–61

NewApiExtractor creates a new ApiExtractor, TODO: replaced with NewStatefulApiExtractor

(args ApiExtractorArgs)

// NewApiExtractor creates a new ApiExtractor, TODO: replaced with NewStatefulApiExtractor
func NewApiExtractor(args ApiExtractorArgs) (*ApiExtractor, errors.Error) {
	// process args
	rawDataSubTask, err := NewRawDataSubTask(args.RawDataSubTaskArgs)
	if err != nil {
		return nil, err
	}
	if args.BatchSize == 0 {
		args.BatchSize = 500
	}
	return &ApiExtractor{
		RawDataSubTask: rawDataSubTask,
		args:           &args,
	}, nil
}

func setRawDataOrigin(result interface{}, originValue common.RawDataOrigin) bool {
	originField := reflectField(result, "RawDataOrigin")