mini-elastic-load.go

func Compute(req sandboxrpc.ComputeRequest) ([]sandboxrpc.ComputeResponse, error) {
	idx, err := utils.OpenIndex(false)
	if err != nil {
		return nil, errors.New("Something went wrong while creating the index: " + err.Error())
	}
	defer idx.Close()

	datums, err := fetchMajesticCSV()
	if err != nil {
		return nil, err
	}

	err = utils.UpdateIndex(idx, datums)
	if err != nil {
		return nil, err
	}

	return []sandboxrpc.ComputeResponse{utils.ExportStats(idx)}, nil
}